PHP 使用 Rabbitmq Demo

Posted licnlt

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了PHP 使用 Rabbitmq Demo相关的知识,希望对你有一定的参考价值。

一、发布消息类(client.php),发布者

<?php
$conn = [
    ‘host‘ => ‘127.0.0.1‘,
    ‘port‘ => ‘5672‘,
    ‘login‘ => ‘guest‘,
    ‘password‘ => ‘guest‘,
    ‘vhost‘=>‘/‘
];

//创建连接和channel
$conn = new AMQPConnection($conn);
if(!$conn->connect()) {
    die("Cannot connect to the broker!
");
}
$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 )."
";
}

 

二、接受消息类(server.php),订阅者

<?php
$conn = [
    ‘host‘ => ‘127.0.0.1‘,
    ‘port‘ => ‘5672‘,
    ‘login‘ => ‘guest‘,
    ‘password‘ => ‘guest‘,
    ‘vhost‘=>‘/‘
];

//创建连接和channel
$conn = new AMQPConnection($conn);
if(!$conn->connect()) {
    die("Cannot connect to the broker!
");
}
$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."
"; //处理消息
}, AMQP_AUTOACK);

$conn->disconnect();

  

三、需要将订阅者常驻于后台进程。

这里先使用下命令

php server.php

 然后打开另一个终端,使用

php client.php

 

以上是关于PHP 使用 Rabbitmq Demo的主要内容,如果未能解决你的问题,请参考以下文章

RabbitMQ 使用demo

队列系统rabbitmq

消息队列学习 -- RabbitMQ概念了解

用PHP尝试RabbitMQ(amqp扩展)实现消息的发送和接收

RabbitMQ应用Demo:使用exchange广播消息

RabbitMQ应用Demo:使用exchange广播消息