rabbimq 生产消费者
生产 消费者
2023-09-14 09:12:13 时间
composer.json
{ "require": { "php-amqplib/php-amqplib": "^2.9" } }
composer update
publish.php
<?php require_once "./vendor/autoload.php"; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; $conf = [ 'host' => '192.168.33.50', 'port' => 5672, 'user' => 'admin', 'pwd' => 'admin', 'vhost' => '/', ]; $exchangeName = 'ttt'; //交换机名 $queueName = 'ttt'; //队列名称 $routingKey = 'ttt'; //路由关键字(也可以省略) $conn = new AMQPStreamConnection( //建立生产者与mq之间的连接 $conf['host'], $conf['port'], $conf['user'], $conf['pwd'], $conf['vhost'] ); $channel = $conn->channel(); //在已连接基础上建立生产者与mq之间的通道 $channel->exchange_declare($exchangeName, 'direct', false, true, false); //声明初始化交换机 $channel->queue_declare($queueName, false, true, false, false); //声明初始化一条队列 $channel->queue_bind($queueName, $exchangeName, $routingKey); //将队列与某个交换机进行绑定,并使用路由关键字 $msgBody = json_encode(["name" => "iGoo", "age" => 22]); $msg = new AMQPMessage($msgBody, ['content_type' => 'text/plain', 'delivery_mode' => 2]); //生成消息 $r = $channel->basic_publish($msg, $exchangeName, $routingKey); //推送消息到某个交换机 $channel->close(); $conn->close();
consumer.php
<?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; $connection = new AMQPStreamConnection('192.168.33.50', 5672, 'admin', 'admin'); $channel = $connection->channel(); $exchangeName = 'ttt'; //交换机名 $queueName = 'ttt'; //队列名称 $routingKey = 'ttt'; //路由关键字(也可以省略) $channel->exchange_declare($exchangeName, 'direct', false, true, false); //声明初始化交换机 $channel->queue_declare($queueName, false, true, false, false); //声明初始化一条队列 $channel->queue_bind($queueName, $exchangeName, $routingKey); //将队列与某个交换机进行绑定,并使用路由关键字 echo ' [*] Waiting for messages. To exit press CTRL+C', "\n"; $callback = function($msg) { echo " [x] Received ", $msg->body, "\n"; }; $channel->basic_consume('ttt', '', false, true, false, false, $callback); while(count($channel->callbacks)) { $channel->wait(); } $channel->close(); $connection->close(); ?>
相关文章
- 通过MAC地址,自动判定生产环境、测试环境
- SAP S4HANA里关于生产订单的一些重要数据库表
- SAP S/4HANA生产订单的BAdI增强点之Initialize方法
- DockerCon 2016 Day2 : 企业生产环境可用
- 生产与消费(多线程练习题)
- Python:Django开发环境与生产环境的配置
- 制造业MES系统如何管理生产车间
- MySql一个生产死锁案例分析
- Hadoop(36):Hadoop调优之MapReduce生产经验
- a34.ansible 生产实战案例 -- 基于kubeadm安装kubernetes v1.22 -- 集群升级(二)
- a10.ansible 生产实战案例 -- docker基于二进制 playbook
- a9.ansible 生产实战案例 -- docker基于镜像仓库 roles
- a3.ansible 生产实战案例 -- 系统初始化roles
- a2.ansible 生产实战案例 -- 系统初始化playbook