在线时间:8:00-16:00
迪恩网络APP
随时随地掌握行业动态
扫描二维码
关注迪恩网络微信公众号
对于 Message 的 对于
 Topic Exchange 与其他 Exchange 的转化:
整合代码emit_log_topic.php <?php /** * 发送消息 */ $exchangeName = 'topic_logs'; $topic = empty($argv[1]) ? 'anonymous.info' : $argv[1]; // 主题 $message = empty($argv[2]) ? 'Hello World!' : $argv[2]; // 建立TCP连接 $connection = new AMQPConnection([ 'host' => 'localhost', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest' ]); $connection->connect() or die("Cannot connect to broker!\n"); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_TOPIC); $exchange->declareExchange(); $exchange->publish($message, $topic); echo "Message is sent: " . $message . "\n"; $connection->disconnect(); receive_logs_topic.php <?php /** * 接收消息 */ $exchangeName = 'topic_logs'; $topic = $argv[1]; // 建立TCP连接 $connection = new AMQPConnection([ 'host' => 'localhost', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest' ]); $connection->connect() or die("Cannot connect to broker!\n"); $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); $exchange->setType(AMQP_EX_TYPE_TOPIC); $exchange->declareExchange(); $queue = new AMQPQueue($channel); $queue->setFlags(AMQP_EXCLUSIVE); $queue->declareQueue(); $queue->bind($exchangeName, $topic); echo "Waiting for logs...\n"; while (TRUE) { $queue->consume('processLogs'); } $connection->disconnect(); function processLogs($envelope, $queue) { $logs = $envelope->getBody(); var_dump("Received: " . $logs); $queue->ack($envelope->getDeliveryTag()); // 手动发送ACK应答 } 先运行脚本: php receive_logs_topic.php *.laravel 然后再运行另外一个脚本: php emit_log_topic.php php.laravel
效果展示:
|
2022-08-30
2022-08-17
2022-11-06
2022-08-17
2022-08-15
请发表评论