1.首先，添加相应的源
在 Ubuntu 16.04 下
echo "deb https://dl.bintray.com/rabbitmq/debian xenial main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
在 Ubuntu 17.10 下
echo "deb https://dl.bintray.com/rabbitmq/debian artful main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list
2.配置公钥
wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -
3. 更新并安装服务
sudo apt-get update
sudo apt-get install rabbitmq-serve
安装结束后默认是运行的
invoke-rc.d rabbitmq-server stop/start //可以运行，该代码进行开启或关闭
开启页面管理
rabbitmq-plugins enable rabbitmq_management
运行该代码即可访问 :15672/ 进行页面管理
以上，安装RabbitMQ 服务就完成了。
RabbitMQ一些基本函数介绍
1.连接
// 连接服务，获取句柄
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$connection->isConnected() or die("Cannot connect to the broker!\n");
$channel = $connection->channel();
2.定义
//direct：在direct类型的exchange中，只有这两个routingkey完全相同，exchange才会选择对应的binging进行消息路由。
//fanout：此exchange的路由规则很简单直接将消息路由到所有绑定的队列中，无须对消息的routingkey进行匹配操作。
//topic：此类型exchange和上面的direct类型差不多，这里的routingkey可以有通配符：'*','#' ，其中'*'表示匹配一个单词，
// '#'则表示匹配没有或者多个单词，对 key 进行模式匹配，比如 ab* 可以传递到所有 ab* 的 queue
// headers : 不常用
$channel->exchange_declare('demo', 'direct'); //声明交换机，相当于定义规则
//passive: 消极处理， 判断是否存在队列，存在则返回，不存在直接抛出 PhpAmqpLib\Exception\AMQPProtocolChannelException 异常
//durable：true、false true：在服务器重启时，能够存活
//exclusive ：是否为当前连接的专用队列，在连接断开后，会自动删除该队列，生产环境中应该很少用到吧。
//autodelete：当没有任何消费者使用时，自动删除该队列
//nowait : 相当于一个async版的声明队列，可以看到是没有返回的。调完方法就结束。也不等队列创建结果
//auto_delete: 当所有消费客户端连接断开后，是否自动删除队列
//arguments: 附加参数，规则设置
$channel->queue_declare('kzae', false, false, false, false);
//队列绑定交换机
$channel->queue_bind('hello','amq.direct', 'bbb');
3.发送
//mandatory标志告诉服务器至少将该消息route到一个队列中，否则将消息返还给生产者；
//immediate标志告诉服务器如果该消息关联的queue上有消费者，则马上将消息投递给它，如果所有queue都没有消费者，
//直接把消息返还给生产者，不用将消息入队列等待消费者了
$channel->basic_publish($msg, 'amq.direct', 'bbb');
4.接收
//采用 no-ack 的方式进行确认，也就是说，每次 Consumer 接到数据后，不管是否处理完成，RabbitMQ Server 会立即把这个 Message 标记为完成，然后从 Queue 中删除
$channel->basic_consume('hello', '', false, false, false, false, $callback);
5.回调
$callback = function(PhpAmqpLib\Message\AMQPMessage $msg) {
echo " [x] Received ", $msg->body, "\n";
//delivery_info['channel']: PhpAmqpLib\Channel\AMQPChannel
var_dump($msg->delivery_info);
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']); //确认ack
};
6. 结束
$channel->close();
$connection->close();
CentOS 7.2 下 RabbitMQ 集群搭建
CentOS7环境安装使用专业的消息队列产品RabbitMQ