2017-09-29 17:00
在安装RabbitMQ服务器包时，服务器不会默认启动为守护进程。在系统启动时默认启动守护进程，作为管理员运行: chkconfig rabbitmq-server on
首先下载 php-amqplib
1.启动及关闭
/sbin/service rabbitmq-server stop/start/etc
2.添加用户操作
rabbitmqctl add_user rollen root
rabbitmqctl set_user_tags rollen administrator
rabbitmqctl set_permissions -p / rollen ".*" ".*" ".*"
3.连接操作需要注意的地方
地址 github
//基于yii2-queue扩展 就是因为没把queueName,exchangeName 带上，蛋疼了好久。
'queue' => [
'class' => \yii\queue\amqp\Queue::class,
'host' => '192.168.148.129',
'port' => 5672,
'user' => 'test',
'password' => 'root',
'queueName' => 'msgs',
'exchangeName'=>'router',
],
4.设置配置文件
cd /etc/rabbitmq
cp /usr/share/doc/rabbitmq-server-3.4.1/rabbitmq.config.example /etc/rabbitmq/
mv rabbitmq.config.example rabbitmq.config
5.设置用户访问
vi /etc/rabbitmq/rabbitmq.config
/**
找到{loopback_users,[]} 将注释去掉
*/
6.开启web管理界面
rabbitmq-plugins enable rabbitmq_management
service rabbitmq-server restart
7.防火墙开放15672端口
/sbin/iptables -I INPUT -p tcp --dport 15672 -j ACCEPT
/etc/rc.d/init.d/iptables save
9.使用的时候遇到的坑
关于exchange 和 messageQueue 的介绍
这是在百度上找到的答案,一开始无法理解，后面做过试验，才知道怎么回事
a)消费者是无法订阅或者获取不存在的MessageQueue中信息。
b)消息被Exchange接受以后，如果没有匹配的Queue，则会被丢弃。
解释：主要是b，queue主要是用来存储消息的队列，exchange才是来拿消息的人，和你在声明的时候没有半毛钱关系，并非要监听对应的queue才能拿到消息，只要你的exchange与生产者的exchange对应就ok了，只是之前queue里面的消息（不管是消费的还是未消费的）你都无法接收到，而生产者重新发送消息，这个时候你就可以收到了，这个可以用来做生成者的消息监听（注意：如果你声明的queue与生成者一致，此时两边并不会收到消息，只是rabbit将消息进行了分发）
10.后台运行
nohup php amqp_consumer.php >> /var/log/test.log 2>&1 &
11. rabbitMq交换器之fanout模式
插入图片
如图所示，这种类型的交换器会将收到的消息广播到绑定的队列上。消息通信模式很简单：当你发送一条消息到fanout交换器时，他会把消息投递到所有附加在此交换器上的队列。这允许你对单条消息做不同方式的反应。举例来说，一个web应用程序可能需要在用户上传新的图片时，用户相册必须清楚缓存，同事用户应该得到些积分奖励。你可以将两个队列绑定到图片上传交换器上(exchange)。一个用于清楚缓存，另一个用于增加用户积分。从这个场景中你可以了解到，使用交换器、绑定和队列比直接向指定的队列发送消息要有优势。假设应用程序的第一个需求是在图片上传到网站上后，需要清楚用户相册缓存。你可以通过只使用一个队列就能轻易完成。但是当产品负责人让你实现一个新功能，即在上传完成后给用户一点奖励，你该怎么办呢？如果你是直接将消息发送给队列的话，就不得不修改发送的代码，以将消息发送给新的用户积分队列。如果你使用的是fanout交换器的话，你唯一需要做的就是为新的消费写一段代码，然后声明新的队列并将其绑定到fanout交换器上。
总结
由于最近有个项目需要进行系统间的通信，上级选择了rabbitMq，我们也没辙，开始使用吃奶的力气在学习，越到最后发现，这种解耦的方式确实不错，看来还要继续研究研究。
