php-amqplib库操作RabbitMQ

Godtoy 发布于2019-06-28 14:26 / 750人阅读

摘要：安装操作库在你的项目目录下的文件中增加下面内容增加这行然后接着执行。分别为规则说明精准推送广播。推送到绑定到此交换机下的所有队列组播。

mq的安装和php的扩扎在另外文章说明

RabbitMQ基本原理

首先，建议去大概了解下RabbitMQ(以下简称mq)的基本工作原理，可以参考这篇文章
最主要的几个对象如下

对象名称
borker	相当于mq server
channel	通道或者频道
exchange	交换机
queue	队列
vhost	虚拟主机(项目队列隔离使用)

这几个对象在上面的文章说描述的已经非常清楚，这里不要叙述了。

安装操作库

在你的项目目录下的composer.json文件中增加下面内容

{
  "require": {
      "php-amqplib/php-amqplib": "2.7.*" //增加这行
  }
}

然后接着执行composer update php-amqplib/php-amqplib。更加方便的做法是如果你的项目已经有了composer.json那么执行执行
composer require php-amqplib/php-amqplib便可以直接进行安装了

示例演示

首先需要定义交换机、队列以及路由关键字(routing key) 下面是示例代码

 "127.0.0.1",
        "port" => 5672,
        "user" => "kd_dev",
        "pwd" => "kd_dev",
        "vhost" => "/",
];
$exchangeName = "kd_sms_send_ex"; //交换机名
$queueName = "kd_sms_send_q"; //队列名称
$routingKey = "sms_send"; //路由关键字(也可以省略)

$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();

有几个地方需要注意：

$routingKey其实是可以省略的，但是一般都带上方便交换机对消息进行不同队列的推送

如果绑定的时候使用了$routingKey,那么在bashic_publish的时候也要指定$routingKey，不然交换机无法路由到指定队列，默认就推送到不使用关键字的队列了(这在我实验的时候遇到的一个坑)

上面的exchange_declare和queue_declare以及queue_bind其实也不是必须的，如果在代码运行之前这行交换机和队列名称以及通过管理后台的方式手动添加在mq上，那么可以执行使用，而不需要上面的这3句代码。

执行上面的代码后你也可以在mq管理后台看到对应的显示，如下图
添加后的交换机显示

添加后的队列显示

队列与交换机的绑定关系，以及绑定的路由关键字

路由匹配

上面的代码中，当我们声明初始化交换机的时候第二个参数使用direct参数，其实还有另外3种参数可选。分别为

规则	说明
direct	精准推送
fanout	广播。推送到绑定到此交换机下的所有队列
topic	组播。比如上面我绑定的关键字是sms_send，那么他可以推送到*.sms_send的所有队列
headers	这个目前不知道是如何推送的

下一篇在简单的演示一下客户端如何消费队列

---更新---
更新一下在创建交换机和队列的时候各个常用参数说明

    name: $queue    // should be unique in fanout exchange. [队列名称]
    passive: false  // don"t check if a queue with the same name exists [是否检测同名队列]
    durable: false // the queue will not survive server restarts [是否开启队列持久化]
    exclusive: false // the queue might be accessed by other channels [队列是否可以被其他队列访问]
    auto_delete: true //the queue will be deleted once the channel is closed. [通道关闭后是否删除队列]

    name: $exchange [交换机名称]
    type: direct [路由类型]
    passive: false []
    durable: true [交换机是否开启持久化]
    auto_delete: false //the exchange won"t be deleted once the channel is closed.

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/26182.html

RabbitMQ+PHP 教程一（Hello World）

摘要：在中间的框是一个队列的消息缓冲区，保持代表的消费。本教程介绍，这是一个开放的通用的协议消息。我们将在本教程中使用，解决依赖管理。发送者将连接到，发送一条消息，然后退出。注意，这与发送发布的队列匹配。介绍 RabbitMQ是一个消息代理器：它接受和转发消息。你可以把它当作一个邮局：当你把邮件放在信箱里时，你可以肯定邮差先生最终会把邮件送到你的收件人那里。在这个比喻中，RabbitMQ就...

silencezwm 2019-06-28 14:11 评论0 收藏0
RabbitMQ使用

摘要：的定义是使用语言开发的开源消息队列系统，完整的实现了高级抽象层消息通信协议。交换机接受发送的消息，并根据绑定规则转发到对应的队列。默认是无名交换使用空字符串标识。消息队列是内部对象，用于存储未被消费的消息。 RabbitMQ的定义 RabbitMQ是使用erlang语言开发的开源消息队列系统，完整的实现了AMPQ（高级抽象层消息通信协议）。 Mac下RabbitMQ安装使用Hom...

codeKK 2019-06-28 14:18 评论0 收藏0
centos 下安装RabbmitMQ+PHP RabbmitMQ应用

摘要：你或许在思考数据分发无阻塞作业或者消息推送。所有的这些模式，都是消息队列的一部分。这部分代码可以改写应用作简单的异步队列任务的场景，但到了高并发高可用需求下就要进行额外的一些处理。在之后的文章中我会讲到的竞争消费模式和的用法。你或许在思考数据分发、无阻塞作业或者消息推送。或者你想要进行发布/订阅，异步任务，工作队列。所有的这些模式，都是消息队列的一部分。 1.安装RabbmitMQ ...

simpleapples 2019-07-01 12:35 评论0 收藏0
php 使用rabbitmq 踩坑记录

摘要：当关闭的时候，队列将被删除。空是自动删除绑定队列和交换机，生成发送消息到队列持久化，重启不会丢失，默认为，重启会丢失环境 1.安装rabbit php使用安装包，直接安装composer 安装php-amqplib/php-amqplib 这个包生产着连接mq server require_once __DIR__./vendor/autoload.php; use PhpAm...

leiyi 2019-07-01 12:42 评论0 收藏0
PHP RabbitMQ

摘要：消息队列，用于存储还未被消费者消费的消息。由在与时指定，而由发送时指定，两者的匹配方式由决定。需要为每一个创建，协议规定只有通过才能执行的命令。建议客户端线程之间不要共用，至少要保证共用的线程发送消息必须是串行的，但是建议尽量共用。安装 rabbitmq 在 mac 下可以直接用 brew 安装默认安装在 /usr/local/Cellar/下命令被软连接加入到了/usr/local...

anRui 2019-06-27 12:17 评论0 收藏0