PHP与RabbitMQ（下）

protected function getConn()
{
    $conf = Yii::$app->params[‘rabbitMQ‘];
    $conn = new AMQPStreamConnection($conf[‘host‘], $conf[‘port‘], $conf[‘user‘], $conf[‘password‘], $conf[‘vhost‘]);

    return $conn;
}

$conn = $this->getConn();
$channel = $conn->channel();

/*
 * 声明一个white队列和一个green队列
 * 参数介绍：
 * passive = false 没有此队列时不会报错
 * durable = true 队列持久化
 * exclusive = false 当一个连接关闭时队列不会删除
 * auto_delete = false 当最后一个消费者断开连接后队列不会自动删除
 * nowait = false 不返回执行结果
*/
$channel->queue_declare(‘white‘, false, true, false, false, false);
$channel->queue_declare(‘green‘, false, true, false, false, false);

//声明direct交换机
$channel->exchange_declare(‘direct_exchange‘, ‘direct‘, false, true, false, false, false);

/**
 * 将white队列绑定到direct交换机上
 * 此步骤可以省略，默认队列会有一个同名路由键，所以上一章中生产者是这样发送消息的：
 * $channel->basic_publish($msg, ‘‘, ‘white‘);
 */
$channel->queue_bind(‘white‘, ‘direct_exchange‘, ‘color.white‘);

$msgBody = ‘Hello White Rabbit!‘;

//delivery_mode = 2，消息持久化
$msg = new AMQPMessage($msgBody, [‘content_type‘ => ‘text/plain‘, ‘delivery_mode‘ => AMQPMessage::DELIVERY_MODE_PERSISTENT]);

$channel->basic_publish($msg, ‘direct_exchange‘, ‘color.white‘);

//声明fanout交换机
$channel->exchange_declare(‘fanout_exchange‘, ‘fanout‘, false, true, false, false, false);

//绑定white和green队列，fanout交换机无需路由键
$channel->queue_bind(‘white‘, ‘fanout_exchange‘);
$channel->queue_bind(‘green‘, ‘fanout_exchange‘);

//以下一行代码会同时给white和green队列发送一条消息
$channel->basic_publish($msg, ‘fanout_exchange‘);

//声明topic交换机
$channel->exchange_declare(‘topic_exchange‘, ‘topic‘, false, true, false, false, false);

/*
 * 绑定white和green队列
 * "#"表示0个或多个关键字, "*"表示匹配一个关键字
 */
$channel->queue_bind(‘white‘, ‘topic_exchange‘, ‘color.*‘);
$channel->queue_bind(‘green‘, ‘topic_exchange‘, ‘color.#‘);

//以下一行代码会给green队列发送一条消息
$channel->basic_publish($msg, ‘topic_exchange‘, ‘color.white.green‘);

//声明headers交换机
$channel->exchange_declare(‘headers_exchange‘, ‘headers‘, false, true, false, false, false);

$channel->queue_bind(‘white‘, ‘headers_exchange‘, ‘‘, false, new AMQPTable([
    ‘x-match‘ => ‘all‘, //要求所有参数都要符合
    ‘author‘ => ‘74percent‘,
    ‘type‘ => ‘color‘
]));

$channel->queue_bind(‘green‘, ‘headers_exchange‘, ‘‘, false, new AMQPTable([
    ‘x-match‘ => ‘any‘, //要求任意参数符合即可
    ‘author‘ => ‘74percent‘,
]));

$msg->set(‘application_headers‘, new AMQPTable([
    ‘author‘ => ‘74percent‘
]));

//以下一行代码会给green队列发送一条消息
$channel->basic_publish($msg, ‘headers_exchange‘);