最近研究RabbitMQ的一些心得

      关于RabbitMQ的文章网上转来转去最多的是一篇<<[RabbitMQ+Python入门经典] 兔子和兔子窝>>(随便给个连接了).这篇文章的讲解是很风趣,很适合用来理解一些基础概念.理解了概念之后就要进行一些实际性的实验了.原文给的python的例子.不是笔者想要的,笔者要用php的.

 

      关于php和rabbitmq网上又有一篇被转来转去的文章<<安装 php-rabbit: RabbitMQ 的 PHP 扩展>>.文章里提到的php-rabbit,笔者死活是访问不了:

 

      让几个不一样地方的哥们帮着访问下载,都下载不了,推断多是这个项目被删除了.问一个哥们儿,说他们那用的是php-amqp.从官方下的库居然很差使.因而死皮懒脸的管哥们要了他们正在用的版本和示例,又鉴于网上 php-amqp版本的rabbit操做细节甚少(能够说没有么?),因而有了今天这份儿总结.

测试平台:

Distributor ID: Ubuntu

Description: Ubuntu 9.10

Release: 9.10

Codename: karmic

 

      既然是ubuntu,安装rabbitmq服务端是很easy的事情,一条命令搞定:

apt-get install rabbitmq-server

 

      接下来的就是折腾了将近两天的心得体会了.

 

      1.必需掌握的指令

添加用户:

rabbitmqctl add_user rainbird password

添加权限:

rabbitmqctl set_permissions -p "/" rainbird ".*" ".*" ".*"

删除测试用户:

rabbitmqctl delete_user guest

 

全部指令列表(很简单的英文):

add_user        <UserName> <Password>

delete_user     <UserName>

change_password <UserName> <NewPassword>

list_users

add_vhost    <VHostPath>

delete_vhost <VHostPath>

list_vhosts

set_permissions   [-p <VHostPath>] <UserName> <Regexp> <Regexp> <Regexp>

clear_permissions [-p <VHostPath>] <UserName>

list_permissions  [-p <VHostPath>]

list_user_permissions <UserName>

list_queues    [-p <VHostPath>] [<QueueInfoItem> ...]

list_exchanges [-p <VHostPath>] [<ExchangeInfoItem> ...]

list_bindings  [-p <VHostPath>] 

list_connections [<ConnectionInfoItem> ...]

       2.vhost  / 不能删除

 

      删除/之后,新创建的vhost不能正常使用(即使不删除/,新创建的vhost也是不能正常使用).不知道为何,有待研究.

 

      3.关于持久化

 

      示例里没有一点儿和持久化相关的东东,而这倒是笔者最关心的,想一想做为消息服务器若是不能保证消息必定被接收到,算什么事儿啊?比着网上狂转的python版本从php-amqp的库里一点一点儿翻,找到了以下持久化的设置:

 

      接收端声明队列和交换机自动创建:

$ch->queue_declare($_QUEUE,false,true,false,false);

第三个参数设置true保证服务器重启后,自动创建队列

第五个参数设置成false防止接收端没链接的时候丢失消息

 $ch->exchange_declare($EXCHANGE, 'direct', false, true, false);

第四个参数设置true保证重启后,自动创建交换机

第五个参数设置false防止接收端断开后,交换机被删除

 

      发布端声明消息持久:

$message = new AMQPMessage(serialize($object), array('content_type' => 'text/plain', 'delivery_mode' => 2));

 

      同时知足了上面三个条件,就能够保证未接收的消息在服务器意外重启之后依然存在了.

 

      4.持久化的后遗症

 

      好比说你初始化了一个队列msgs.你会发现它真的持久了!每次服务器端重启后,经过list_queues命令查看的时候都存在.可是时间久了,这个msgs咱们并不须要了,怎么办呢?笔者发现,想清除这个队列只能删除它所在的vhost,而后再重建vhost,再设置vhost的权限.

rabbitmqctl delete_vhost /

rabbitmqctl add_vhost /

rabbitmqctl set_permissions -p / rainbird '.*' '.*' '.*'

 

      要注意,若是这个操做过程当中有接收端处于链接状态它们不会自动断开,但也不会再收到消息,须要手动从新链接一下.

 

      5.关于修改监听ip和监听端口

 

      出于一些须要,好比咱们有多个ip,咱们但愿rabbitmq仅运行在指定的ip上.或者考虑到安全问题,咱们但愿修改一下rabbitmq的监听端口.默认安装完成之后,在/etc下面会有一个rabbitmq的空目录,这时候咱们须要手工建立rabbitmq.conf,并写入相关内容.

vi /etc/rabbitmq/rabbitmq.conf

RABBITMQ_NODE_IP_ADDRESS=0.0.0.0

RABBITMQ_NODE_PORT=2222

 

      保存之后重启服务就生效了.

 

      这个东东网上又没介绍,翻了半天+无限尝试才搞出来.

 

      6.关于运行接收端cpu100%问题

 

      第一眼看到接收端会运行一个while等待消息的时候,笔者就知道这个进程确定cpu占用会100%.在代码里几处while尝试添加usleep无效后,笔者最后仍是在官方的问题列表里找到了答案:

vi +286 amqp_wire.inc

293 while ($read < $n && (false !== ($buf = fread($this->sock, $n - $read))))

294             {

295                 usleep(50000);

296                 $read += strlen($buf);

297                 $res .= $buf;

298             }   

 

      笔者的出发点是对的,只是没找对while.可能有人会奇怪为何要用usleep(50000)呢?实际上笔者有遇到运行php起来的daemon致使cpu100%的状况.当时笔者加的是usleep(500000)也就是半秒钟.这样就可使进程看上去cpu占用为0.没想到再降一个数量级也是能够正常的,此次算赚到了.

 

      7.学到了error_log函数

 

      之前有见过这个函数,觉得是向系统日志里写log的时候才用获得呢,没想到还能够像下面这样用:

function debug_msg($s)

{

    //error_log($s);

}

 

      在不一样的地方写上debug_msg,最后不用的时候时候,直接注释掉error_log,不错的小技巧!

 

      暂时就摸索出来这么多东西了,准备拿几个不重要的任务跑跑稳定性试试.