centos 下安装RabbmitMQ+PHP RabbmitMQ应用

你或许在思考数据分发、无阻塞作业或者消息推送。或者你想要进行发布/订阅，异步任务，工作队列。所有的这些模式，都是消息队列的一部分。1.安装RabbmitMQwget https://www.rabbitmq.com/releases/rabbitmq-server/v3.6.8/rabbitmq-server-3.6.8-1.el6.noarch.rpm获取rpm ,安装的时候会发现缺少依赖安装依赖erlangwget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpmrpm -Uvh erlang-solutions-1.0-1.noarch.rpmyum install erlang注意不要用epel的源直接yum安装，epel源的erlang版本太低安装依赖socatyum install socat最后rpm -Uvh rabbitmq-server-3.6.8-1.el6.noarch.rpm2.php的RabbmitMQ库{ “require”: { “php-amqplib/php-amqplib”: “2.6.” }}comoser install3.php+RabbmitMQ helloworld//send.phprequire_once DIR . ‘/vendor/autoload.php’;use PhpAmqpLib\Connection\AMQPStreamConnection;use PhpAmqpLib\Message\AMQPMessage;$connection = new AMQPStreamConnection(’localhost’, 5672, ‘guest’, ‘guest’);$channel = $connection->channel();$channel->queue_declare(‘hello’, false, false, false, false);$msg = new AMQPMessage(‘Hello World!’);$channel->basic_publish($msg, ‘’, ‘hello’); //发送一个消息到hello频道echo " [x] Sent ‘Hello World!’\n";$channel->close();$connection->close();//receive.phprequire_once DIR . ‘/vendor/autoload.php’;use PhpAmqpLib\Connection\AMQPStreamConnection;$connection = new AMQPStreamConnection(’localhost’, 5672, ‘guest’, ‘guest’);$channel = $connection->channel();$channel->queue_declare(‘hello’, false, false, false, false);echo ’ [] Waiting for messages. To exit press CTRL+C’, “\n”;$callback = function($msg) { echo " [x] Received “, $msg->body, “\n”;};//接收hello频道的消息$channel->basic_consume(‘hello’, ‘’, false, true, false, false, $callback);while(count($channel->callbacks)) { $channel->wait();}4.运行首先运行起来rabbmitMQ serverservice rabbmitmq-server start挂起receive.php接收消息处理php receive.php发送消息##另起一个窗口执行php send.php以上代码就构建了一个简单的消息队列消息从send.php 生产(p) 进入队列 交由 消费者(c)注意:当关闭了命令行窗口receive.php 进程将会结束，这个时候就需要借助supservisor 来将receive.php 脚本后台运行。这部分代码可以改写应用作简单的异步队列任务的场景，但到了高并发高可用需求下就要进行额外的一些处理。在之后的文章中我会讲到rabbmitMQ的竞争消费模式和superverisor的用法。