在线编程在线课堂在线测评Anycodes在线编程

编程论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

How to use bs4??
本帖最后由 carry0987 于
Double Queue 问题描述 : The new founded Balkan Investment Group Bank (
John 问题描述 : Little John is playing very funny game
linux-command Linux命令大全搜索工具,内容包含Linux命令
Coati 是一款跨平台的代码查看工具,适用于 C/C++ 和 Java。商业软件。特性:1. 索引
系统可承载海量并发,消息收发确认机制 保障消息必达 系统采用动态智
全平台视频监控,支持安卓苹果以及pcweb,支持海康大华等主流dvr,全部源码以及文档 单聊、群聊、商
如何访问类的私有属性? 下面以 TPathData 为例,
问题:从 XE4 以来,Firemonkey 曲线绘图在移动平台不平滑的问题一直令人诟病,提交到官方的 QC 也是族繁不及备载,官方似乎有意的
操作数据库(RODBC)   odbcConnect(dsn, uid="", p
数据模式:mode函数显示任何对象的模式。常见的单个的
系统可承载海量并发,消息收发确认机制 保障消息必达 系统采用动态智
RabbitMQ与PHP(一) 项
Iease团队扩编预备中,盼望能有Ruby或者java工程师加盟。全职兼职都可以。有爱好的伴侣请与我接洽。 邮件:i
ruby 怎么设置装备摆设GTK2,求教指导下!
#include #include #include #include using namespace std; int main() {
标题如图所示: 有n盏灯,编号1~n。一开端灯都是关着的
成熟的消息收发确认机制,支持万人大群 支持开发自定义的消息sdk接口,扩展性超强 支持单/
成熟的消息收发确认机制,支持万人大群 支持开发自定义的消息sdk接口,扩展性超强 支持单/
1. 注意列表和集合的区别 set 列表表现形式: list_1
Ajax   Ajax即“Asynchronous Javascript And
大师好,我比来在做布谷鸟优
分辨提取A和B图像Harris角点,接下来须要对

[基础编程] rabbitMQ+php

[复制链接]
发表于 2016-12-24 14:18:55 | 显示全部楼层 |阅读模式
RabbitMQ与PHP(一)

项目中使用RabbitMQ作为队列处理用户消息通知,消息由前端PHP代码产生,处理消息使用Python,这就导致代码一致性问题,调整消息定义时需要PHP和Python都进行修改。这两天抽时间研究了下,如何将消息的产生与处理(消费)全部用PHP来做。查资料时发现,关于PHP处理消息队列的资料很少,有必要把一些初学者容易混淆的地方再讲一下。
拟分成两部分: 一,RabbitMQ的原理与操作示例;二,具体服务安装及如何用PHP作为守护模式处理消息。
RabbitMQ是流行的开源消息队列系统,用erlang语言开发,完整的实现了AMPQ(高级消息队列协议)。网站在:http://www.rabbitmq.com/ 上面有教程和实例代码(Python和Java的)。

AMPQ协议为了能够满足各种消息队列需求,在概念上比较复杂。首先,rabbitMQ启动默认是没有任何配置的,需要客户端连接上去,设置交换机等才能工作。不把这些基础概念弄清楚,后面程序设计就容易产生问题。
1,vhosts : 虚拟主机

一个RabbitMQ的实体上可以有多个vhosts,用户与权限设置就是依附于vhosts。对一般PHP应用,不需要用户权限设定,直接使用默认就存在的"/"就可以了,用户可以使用默认就存在的"guest"。一个简单的配置示例:
  1. $conn_args = array(
  2.     'host' => '127.0.0.1',  
  3.     'port' => '5672',  
  4.     'login' => 'guest',  
  5.     'password' => 'guest',
  6.     'vhost'=>'/'
  7. );
复制代码
2,connection 与 channel : 连接与信道

connection是指物理的连接,一个client与一个server之间有一个连接;一个连接上可以建立多个channel,可以理解为逻辑上的连接。一般应用的情况下,有一个channel就够用了,不需要创建更多的channel。示例代码:
  1. //创建连接和channel
  2. $conn = new AMQPConnection($conn_args);   
  3. if (!$conn->connect()) {   
  4.     die("Cannot connect to the broker!\n");   
  5. }   
  6. $channel = new AMQPChannel($conn);  
  7. ##3,exchange 与  routingkey : 交换机 与 路由键##
复制代码
为了将不同类型的消息进行区分,设置了交换机与路由两个概念。比如,将A类型的消息发送到名为‘C1’的交换机,将类型为B的发送到'C2'的交换机。当客户端连接C1处理队列消息时,取到的就只是A类型消息。进一步的,如果A类型消息也非常多,需要进一步细化区分,比如某个客户端只处理A类型消息中针对K用户的消息,routingkey就是来做这个用途的。
  1. $e_name = 'e_linvo'; //交换机名
  2. $k_route = array(0=> 'key_1', 1=> 'key_2'); //路由key
  3. //创建交换机   
  4. $ex = new AMQPExchange($channel);   
  5. $ex->setName($e_name);
  6. $ex->setType(AMQP_EX_TYPE_DIRECT); //direct类型  
  7. $ex->setFlags(AMQP_DURABLE); //持久化
  8. echo "Exchange Status:".$ex->declare()."\n";   
  9. for($i=0; $i<5; ++$i){
  10.     echo "Send Message:".$ex->publish($message . date('H:i:s'), $k_route[i%2])."\n";  
  11. }
复制代码
由以上代码可以看到,发送消息时,只要有“交换机”就够了。至于交换机后面有没有对应的处理队列,发送方是不用管的。routingkey可以是空的字符串。在示例中,我使用了两个key交替发送消息,是为了下面更便于理解routingkey的作用。
对于交换机,有两个重要的概念:
A,类型。有三种类型: Fanout类型最简单,这种模型忽略routingkey;Direct类型是使用最多的,使用确定的routingkey。这种模型下,接收消息时绑定'key_1'则只接收key_1的消息;最后一种是Topic,这种模式与Direct类似,但是支持通配符进行匹配,比如: 'key_*',就会接受key_1和key_2。Topic貌似美好,但是有可能导致不严谨,所以还是推荐使用Direct。
B,持久化。指定了持久化的交换机,在重新启动时才能重建,否则需要客户端重新声明生成才行。
需要特别明确的概念:交换机的持久化,并不等于消息的持久化。只有在持久化队列中的消息,才能持久化;如果没有队列,消息是没有地方存储的;消息本身在投递时也有一个持久化标志的,PHP中默认投递到持久化交换机就是持久的消息,不用特别指定。
4,queue: 队列

讲了这么多,才讲到队列呀。事实上,队列仅是针对接收方(consumer)的,由接收方根据需求创建的。只有队列创建了,交换机才会将新接受到的消息送到队列中,交换机是不会在队列创建之前的消息放进来的。换句话说,在建立队列之前,发出的所有消息都被丢弃了。下面这个图比RabbitMQ官方的图更清楚——Queue是属于ReceiveMessage的一部分。

接下来看一下创建队列及接收消息的示例:
  1. $e_name = 'e_linvo'; //交换机名
  2. $q_name = 'q_linvo'; //队列名
  3. $k_route = ''; //路由key
  4. //创建连接和channel
  5. $conn = new AMQPConnection($conn_args);   
  6. if (!$conn->connect()) {   
  7.     die("Cannot connect to the broker!\n");   
  8. }   
  9. $channel = new AMQPChannel($conn);   
  10. //创建交换机   
  11. $ex = new AMQPExchange($channel);   
  12. $ex->setName($e_name);
  13. $ex->setType(AMQP_EX_TYPE_DIRECT); //direct类型  
  14. $ex->setFlags(AMQP_DURABLE); //持久化
  15. echo "Exchange Status:".$ex->declare()."\n";   
  16. //创建队列   
  17. $q = new AMQPQueue($channel);
  18. $q->setName($q_name);   
  19. $q->setFlags(AMQP_DURABLE); //持久化  
  20. //绑定交换机与队列,并指定路由键
  21. echo 'Queue Bind: '.$q->bind($e_name, $k_route)."\n";
  22. //阻塞模式接收消息
  23. echo "Message:\n";   
  24. $q->consume('processMessage', AMQP_AUTOACK); //自动ACK应答  
  25. $conn->disconnect();   
  26. /**
  27. * 消费回调函数
  28. * 处理消息
  29. */
  30. function processMessage($envelope, $queue) {
  31.     var_dump($envelope->getRoutingKey);
  32.     $msg = $envelope->getBody();
  33.     echo $msg."\n"; //处理消息
  34. }
复制代码
从上述示例中可以看到,交换机既可以由消息发送端创建,也可以由消息消费者创建。
创建一个队列(line:20)后,需要将队列绑定到交换机上(line:25)队列才能工作,routingkey也是在这里指定的。有的资料上写成bindingkey,其实一回事儿,弄两个名词反倒容易混淆。
消息的处理,是有两种方式:
A,一次性。用 $q->get([...]),不管取到取不到消息都会立即返回,一般情况下使用轮询处理消息队列就要用这种方式;
B,阻塞。用 $q->consum( callback, [...] ) 程序会进入持续侦听状态,每收到一个消息就会调用callback指定的函数一次,直到某个callback函数返回FALSE才结束。
关于callback,这里多说几句: PHP的call_back是支持使用数组的,比如: $c = new MyClass(); $c->counter = 100; $q->consume( array($c,'myfunc') ) 这样就可以调用自己写的处理类。MyClass中myfunc的参数定义,与上例中processMessage一样就行。
在上述示例中,使用的$routingkey = '', 意味着接收全部的消息。我们可以将其改为 $routingkey = 'key_1',可以看到结果中仅有设置routingkey为key_1的内容了。
注意: routingkey = 'key_1' 与 routingkey = 'key_2' 是两个不同的队列。假设: client1 与 client2 都连接到 key_1 的队列上,一个消息被client1处理之后,就不会被client2处理。而 routingkey = '' 是另类,client_all绑定到 '' 上,将消息全都处理后,client1和client2上也就没有消息了。
在程序设计上,需要规划好exchange的名称,以及如何使用key区分开不同类型的标记,在消息产生的地方插入发送消息代码。后端处理,可以针对每一个key启动一个或多个client,以提高消息处理的实时性。如何使用PHP进行多线程的消息处理,将在下一节中讲述。
更多消息模型,可以参考: http://www.rabbitmq.com/tutorials/tutorial-two-python.html



上一篇:php分页原理
下一篇:定制南方七星彩投注网站系统开发建设
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复

使用道具 举报

发表于 2017-1-22 12:29:43 | 显示全部楼层
楼主不知亡国恨,一天到晚打飞机。举头望明月,低头打飞机。洛阳亲友如相问,就说楼主打飞机。少壮不努力,楼主打飞机。垂死病中惊坐起,楼主还要打飞机。生当作人杰,死亦打飞机。人生自古谁无死,楼主继续打飞机。*众里寻他千百回,蓦然回首,楼主正在打飞机。
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-4-4 20:13:16 | 显示全部楼层
楼下是都比
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-5-17 20:11:45 | 显示全部楼层
fdgggggsdgfsgsg
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

 楼主| 发表于 2017-6-20 19:32:41 | 显示全部楼层
我已经对编程失去了所有的信心
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-6-23 19:53:40 | 显示全部楼层
楼主啊
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-7-3 07:31:25 | 显示全部楼层
一二一
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-7-3 10:29:40 | 显示全部楼层
放开编程让我来
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-7-5 16:39:18 | 显示全部楼层
这个帖子不错
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发表于 2017-7-10 04:41:06 | 显示全部楼层
这个帖子不错
在线编程(http://www.anycodes.cn)&编程论坛(http://www.52exe.cn)感谢您的支持!
回复 支持 反对

使用道具 举报

发布主题 上个主题 下个主题 快速回复 返回列表 官方QQ群
在线客服
客 服 中 心
群 机 器 人
网站二维码
收 起 客 服

QQ|Archiver|手机版|小黑屋|Anycodes ( ICP14002806Anycodes在线编程

GMT+8, 2018-11-15 04:46 , Processed in 2.107627 second(s), 96 queries .

Powered by Anycodes

© 2001-2013 吉林市群龙科技有限公司 Inc.

快速回复 返回顶部 返回列表