文档章节

PhalApi-RabbitMQ基于PhalApi专业队列拓展

喵了_个咪
 喵了_个咪
发布于 2017/04/08 16:37
字数 429
阅读 102
收藏 0

PhalApi-RabbitMQ基于PhalApi专业队列拓展

前言

RabbitMQ一直都是队列中的标杆,这次有幸PhalApi也能啃上RabbitMQ真是一件大好事,感谢**@牧鱼人**提供基于php-amqplib/php-amqplib封装的PhalApi-RabbitMQ扩展

关于RabbitMQ相关的安装集群配置可以参考笔者博客的MQ模块,地址如下 https://my.oschina.net/wenzhenxi/blog?catalog=5613216&temp=1491640864558

附上:

官网地址:http://www.phalapi.net/

开源中国Git地址:http://git.oschina.net/dogstar/PhalApi/tree/release

开源中国拓展Git地址:http://git.oschina.net/dogstar/PhalApi-Library

1.安装

使用PhalApi-RabbitMQ扩展和使用其他扩展也是一样简单,只需要把目录存放到Library即可进行使用

在Config中创建文件rabbitmq.php配置文件格式如下:

return array(
    'servers' => array(
        'host'     => '127.0.0.1',
        'port'     => '5672',
        'user'     => 'admin',
        'password' => 'admin',
        'vhost'    => '/',
    )
)

2.使用RabbitMQ写入和处理消息

然后就可以进行实例化使用了:

// 实例化RabbitMQ实例
$rm = RabbitMQ_Lite(DI()->config->get('rabbitmq.servers'));

// 检查test队列是否存在,如果不存在则创建,频繁调用会带来较大性能消耗
// 建议在出队列脚本处进行调用,写入队列不进行调用
$rm->queue_declare("test");

// 向队列写入一条消息
$rm->push("测试消息","test");

// 定义处理消息的方法
$func = function ($msg){
            echo $msg;
        };
// 处理任务(会阻塞进行)
$rm->pop("test",$func);

注:笔者能力有限有说的不对的地方希望大家能够指出,也希望多多交流!

官网QQ交流群:①群:421032344 ②群:459352221 欢迎大家的加入!

© 著作权归作者所有

共有 人打赏支持
喵了_个咪
粉丝 245
博文 140
码字总数 183725
作品 4
杨浦
技术主管
phalapi-进阶篇2(DI依赖注入和单例模式)

先在这里感谢phalapi框架创始人@dogstar,为我们提供了这样一个优秀的开源框架. 离上一次更新过去了快两周,在其中编写了一个关于DB分表分库解决大数据量的拓展,有兴趣的童鞋可以了解了解.废话...

喵了_个咪
2015/11/02
0
0
PhalApi问答社区终于建立啦~~~

小编怀着激动的心情来告诉大家,PhalApi终于搭建了自己的问答社区~~~ 请访问:http://qa.phalapi.net/ 历经数月,PhalApi终于建立了自己的问答社区,我们希望我们可以维护一个高质量的接口社...

暗夜在火星
2015/06/05
0
0
[PhalApi]与开源一起成长:PhalApi落地项目统计

PhalApi接口框架自2015年1月正式开源至现在已历经半年多,我们不仅仅只是提供了一个可用于快速开发的框架,还提供了优质的在线文档、搭建了自主问答社区、部署了官网、建立了QQ交流群以及各种...

暗夜在火星
2015/08/23
0
0
phalapi-进阶篇3(自动加载和拦截器)

先在这里感谢phalapi框架创始人@dogstar,为我们提供了这样一个优秀的开源框架. 最近工作上事情比较多所以更新比较慢希望大家见谅!这一次带来的是对于此框架自动加载机制的一个小引导,简单的聊...

喵了_个咪
2015/11/13
0
0
PhalApi官网发布和开源团队招募

官网发布 怀着激动的心情,我们的PhalApi官网终于上线了!虽然暂时还是比较简单的,而且网址也是IP(因为国外的服务器还在购买中),但这些都是暂时的!因为在不远的将来,我们会在www.phala...

暗夜在火星
2015/02/12
0
8

没有更多内容

加载失败,请刷新页面

加载更多

下一页

RabbitMQ在CentOS环境安装

1.废话不多说准备一台虚拟机,系统为centos,我这里使用的系统版本如下图所示:

凌晨一点
53分钟前
0
0
线程池相关

在java.util.concurrent包下,提供了一系列与线程池相关的类。 使用线程池的好处 降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的消耗; 提高响应速度。当任务到达时,任务...

edwardGe
55分钟前
0
0
学习大数据这三个关键技术是一定要掌握!

大数据时代全面来临,大数据、人工智能等技术引领科技创新潮流,获得国家政策大力支持,前景广阔。学习大数据技术的人自然是络绎不绝, 学习大数据虽然是一个趋势,但也要注意大数据培训课程...

董黎明
今天
0
0
jetbrains 上传代码到github

设置中找github 获取token 验证是否成功 测试git 生成key,一路回车即可 ssh-keygen -t rsa -C “youremail@example.com” 打开pub复制key,需要再次输入一次密码 验证是否成功,输入yes即可...

阿豪boy
今天
0
0
分布式服务框架(拾遗)

前言 现在的大部分工程都已经是基于分布式架构来处理。所以这里对分布式框架做一个简单的总结 常用的RPC框架 RPC框架原理 RPC(Remote Procedure Call,远程过程调用)一般用来实现部署在不同...

kukudeku
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部