RabbitMQ 常用的交换器类型有 fanout direct topic headers 这四种
1 docker pull rabbitmq:3.7.7-management //management是带管理页面的安装
2 docker run -d --name rabbitmq3.7.7 -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin 2888deb59dfc//最后是image id
测试:
浏览器输入:http://192.168.222.129:15672 默认用户名admin密码admin
php测试rabbitmq
composer安装扩展
"require": {
"php-amqplib/php-amqplib": ">=2.6.1"
}
新建send.php 端口号为5672
<?php
/**
* Des 描述
* Date 2020/8/24
* Time 10:31
* User ycl
*/
require 'vendor/autoload.php';
$conn = [
// Rabbitmq 服务地址
'host' => '192.168.222.129',
// Rabbitmq 服务端口
'port' => '5672',
// Rabbitmq 帐号
'login' => 'guest',
// Rabbitmq 密码
'password' => 'guest',
'vhost'=>'/'
];
//创建连接和channel
$conn = new AMQPConnection($conn);
if(!$conn->connect()) {
die("Cannot connect to the broker!\n");
}
$channel = new AMQPChannel($conn);
// 用来绑定交换机和队列
$routingKey = 'key_1';
$ex = new AMQPExchange($channel);
// 交换机名称
$exchangeName = 'ex1';
$ex->setName($exchangeName);
// 设置交换机类型
$ex->setType(AMQP_EX_TYPE_DIRECT);
// 设置交换机是否持久化消息
$ex->setFlags(AMQP_DURABLE);
$ex->declare();
for($i=0; $i<5; ++$i){
echo "Send Message:".$ex->publish(date('H:i:s')."用户".$i."注册" , $routingKey )."\n";
}
新建consume.php 端口号为5672
<?php
/**
* Des 描述
* Date 2020/8/24
* Time 10:32
* User ycl
*/
require 'vendor/autoload.php';
$conn = [
// Rabbitmq 服务地址
'host' => '192.168.222.129',
// Rabbitmq 服务端口
'port' => '5672',
// Rabbitmq 帐号
'login' => 'guest',
// Rabbitmq 密码
'password' => 'guest',
'vhost'=>'/'
];
try {
//创建连接和channel
$conn = new AMQPConnection($conn);
if (!$conn->connect()) {
die("Cannot connect to the broker!\n");
}
$channel = new AMQPChannel($conn);
$exchangeName = 'ex1';
//创建交换机
$ex = new AMQPExchange($channel);
$ex->setName($exchangeName);
$ex->setType(AMQP_EX_TYPE_DIRECT); //direct类型
$ex->setFlags(AMQP_DURABLE); //持久化
$ex->declare();
// 创建队列
$queueName = 'queue1';
$q = new AMQPQueue($channel);
$q->setName($queueName);
$q->setFlags(AMQP_DURABLE);
$q->declareQueue();
// 用于绑定队列和交换机,跟 send.php 中的一致。
$routingKey = 'key_1';
$q->bind($exchangeName, $routingKey);
//接收消息
$q->consume(function ($envelope, $queue) {
$msg = $envelope->getBody();
echo $msg . "\n"; //处理消息
}, AMQP_AUTOACK);
$conn->disconnect();
}catch (AMQPException $e){
echo $e->getMessage();
}
执行
先执行 php consume.php
新开窗口执行 php send.php
结果 consume.php执行窗口会有输出 成功