PHP与RabbitMQ（上）

时间：2019-12-10 00:23:59 阅读：103 评论：0 收藏：0 [点我收藏+]

一、下载

1.下载Erlang环境

https://www.erlang.org/downloads

技术分享图片

2.下载Rabbitmq-server

https://www.rabbitmq.com/install-windows.html

技术分享图片

二、安装

先安装Erlang，再安装rabbitmq-server，一直下一步即可。安装完之后使用cmd进入RabbitMQ Server文件下的sbin目录，执行：

rabbitmq-plugins enable rabbitmq_management

技术分享图片

打开浏览器，输入localhost:15672，出现如下界面则安装成功。

技术分享图片

默认账号：guest

默认密码：guest

我们创建个admin管理员账号：

技术分享图片

以admin管理员登录创建个test_host：

技术分享图片

三、Hello World

这里我以Yii框架为例介绍如何使用RabbitMQ，需要使用composer下载php-amqplib。

composer require php-amqplib/php-amqplib

生产者：

<?php

namespace app\commands;

use yii\console\Controller;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Connection\AMQPStreamConnection;

class ProductController extends Controller
{
    public function actionIndex()
    {
        $conn = new AMQPStreamConnection(‘localhost‘, 5672, ‘admin‘, ‘admin‘, ‘test_host‘);
        $channel = $conn->channel();

        $msgBody = ‘Hello White Rabbit!‘;

        $msg = new AMQPMessage($msgBody, [‘content_type‘ => ‘text/plain‘, ‘delivery_mode‘ => AMQPMessage::DELIVERY_MODE_PERSISTENT, ‘author‘ => ‘74percent‘]);
        //申明一个队列，所有的参数会在下一篇文章介绍
        $channel->queue_declare(‘white‘, false, true, false, false, false);
        //将消息发送到队列，这里并不是直接将消息发送到队列，而是通过交换机间接发送到队列
        $channel->basic_publish($msg, ‘‘, ‘white‘);

        echo "product: send msg success\n";
    }
}

控制台：

php yii product

技术分享图片

RabbitMQ出现了一个white队列，里面有一条消息未被消费：

技术分享图片

消费者：

<?php

namespace app\commands;

use yii\console\Controller;
use PhpAmqpLib\Connection\AMQPStreamConnection;

class ConsumeController extends Controller
{
    public function actionIndex()
    {
        $conn = new AMQPStreamConnection(‘localhost‘, 5672, ‘admin‘, ‘admin‘, ‘test_host‘);
        $channel = $conn->channel();

        $callback = function ($msg) {
            if (true) {
                echo "consume: " . $msg->body . "\n";
                //确认消费
                $msg->delivery_info[‘chanel‘]->basic_ack($msg->delivery_info[‘delivery_tag‘]);
            } else {
                //进行回滚操作
            }
        };

        $channel->basic_qos(null, 1, null);
        $channel->queue_declare(‘white‘, false, true, false, false, false);
        $channel->basic_consume(‘white‘, ‘‘, false, false, false, false, $callback);

        while (count($channel->callbacks)) {
            $channel->wait();
        }
    }
}

控制台：

php yii consume

技术分享图片

此时white队列中的一条消息已经被消费：

技术分享图片

PHP与RabbitMQ（上）

原文：https://www.cnblogs.com/74percent/p/12013950.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年09月23日 (328)
2021年09月24日 (313)
2021年09月17日 (191)
2021年09月15日 (369)
2021年09月16日 (411)
2021年09月13日 (439)
2021年09月11日 (398)
2021年09月12日 (393)
2021年09月10日 (160)
2021年09月08日 (222)