RabbitMQ 安装和简单应用

1、概念
消息队列（Message Queue，简称MQ），从字面意思上看，本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已。其主要用途：不同进程Process/线程Thread之间通信。
AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。
RabbitMQ是一个开源的AMQP实现，服务器端用Erlang语言编写，支持多种客户端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支持AJAX。用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。

2、搭建RabbitMQ环境
2.1 windows下安装（已验证）
（1）安装Erlang 下载：http://www.erlang.org/download/otp_win64_22.2.exe
（2）配置Erlang环境变量
首先新建系统用户变量 ERLANG_HOME = C:\Program Files\erl10.6（变量值就是你按照otp软件的路径）
最后在系统变量path的追加 %ERLANG_HOME%\bin;
（3）安装RabbitMQ 下载地址：http://www.rabbitmq.com/download.html
（4）启用管理工具
开始菜单双击 RabbitMQ Command Prompt (sbin dir)
进入C:\Program Files (x86)\RabbitMQ Server\rabbitmq_server-3.4.1\sbin
输入命令：rabbitmq-plugins enable rabbitmq_management
停止：net stop RabbitMQ 启动：net start RabbitMQ
在浏览器中输入地址查看：http://127.0.0.1:15672/ 使用默认账号登录：guest/ guest

2.2 linux下安装

3、写一个简单的“Hello World”测试程序
（1）安装PHP amqplib客户端库 composer require php-amqplib/php-amqplib
（2）构建一个发送消息的文件send.php，即“P”，发布消息

//引用所需文件
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
//建立一个连接通道，声明一个可以发送消息的队列hello
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('hello', false, false, false, false);

//定义一个消息，消息内容为Hello World!
$msg = new AMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'hello');

//发送完成后打印消息告诉发布消息的人：发送成功
echo " [x] Sent 'Hello World!'\n";
//关闭连接
$channel->close();
$connection->close();

（3）接着我们需要接受消息，创建一个文件：reveive.php

require_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";
};

//在接收消息的时候调用$callback函数
$channel->basic_consume('hello', '', false, true, false, false, $callback);

while(count($channel->callbacks)) {
    $channel->wait();
}

（4）分别运行send.php和receive.php
参考:
RabbitMQ教程 https://blog.csdn.net/hellozpc/article/details/81436980
消息队列-RabbitMq（PHP） https://blog.csdn.net/u014071426/article/details/53649226

最后编辑于：2020.03.03 15:51:35