略微加速

略速 - 互联网笔记

RabbitMQ php-amqplib使用--基本使用

2022-03-02 leiting (242阅读)

标签 PHP

1.一些基本概念:

vhost:虚拟主机,开设多个vhost,用作不同用户的权限分离。
channel:通道,建立一个访问通道。
Exchange:交换机,它指定消息按什么规则,路由到哪个队列。
Queue:队列,每个消息都会被投入到一个或多个队列。
Routing Key:路由,exchange根据这个关键字进行消息投递。
producer:消息生产者,就是投递消息的程序。
consumer:消息消费者,就是接受消息的程序。

2.建立生产者与mq之间的连接

$conn = new AMQPStreamConnection( $host,$port,$user,$password,$vhost);$host:  RabbitMQ服务器主机IP地址
$port:  RabbitMQ服务器端口
$user:  连接RabbitMQ服务器的用户名
$password:  连接RabbitMQ服务器的用户密码
$vhost:   连接RabbitMQ服务器的vhost(服务器可以有多个vhost,虚拟主机,类似nginx的vhost)

3.建立通道

$channel = $conn->channel($channel_id); //在已连接基础上建立生产者与mq之间的通道$channel_id 信道id,不传则获取$channel[“”]信道,再无则循环$this->channle数组,下标从1到最大信道数找第一个不是AMQPChannel对象的下标,实例化并返回AMQPChannel对象,无则抛出异常No free channel ids

4.声明初始化交换机

$channel->exchange_declare($exhcange_name,$type,$passive,$durable,$auto_delete);参数:
$exhcange_name 交换器名字
$type 交换器类型
$passive  false
  是否检测同名队列
durable false  交换机是否开启持久化
auto_detlete false  通道关闭后是否删除队列(1)交换器类型:direct(默认),fanout, topic, 和headers
Direct:直接交换器,工作方式类似于单播,Exchange会将消息发送完全匹配ROUTING_KEY的Queue
fanout:广播是式交换器,不管消息的ROUTING_KEY设置为什么,Exchange都会将消息转发给所有绑定的Queue。
topic:主题交换器,工作方式类似于组播,Exchange会将消息转发和ROUTING_KEY匹配模式相同的所有队列,比如,ROUTING_KEY为user.stock的Message会转发给绑定匹配模式为 * .stock,user.stock, * . * 和#.user.stock.#的队列。( * 表是匹配一个任意词组,#表示匹配0个或多个词组)
headers:消息体的header匹配(ignore)

5.声明初始化一条队列

$channel->queue_declare($name, $passive,$durable,$exclusive,$auto_delete);
    name: 队列名称
    passive: false   是否检测同名队列
    durable: false 是否开启队列持久化
    exclusive: false  队列是否可以被其他队列访问
    auto_delete: true 通道关闭后是否删除队列

6.创建要发送的信息 ,可以创建多个消息

$msg = new AMQPMessage($data,$properties)$data  string类型 要发送的消息
$properties array类型 设置的属性,比如设置该消息持久化[‘delivery_mode’=>2]

7.发送消息

$channel->basic_publish($msg,$exchange,$routing_key);$msg object AMQPMessage对象
$exchange string 交换机名字  
$routing_key string 路由键 如果交换机类型

8、关闭信道和链接

$channel->close();$connection->close();

9.路由绑定

$channel->queue_bind($queueName, $exchangeName, $routingKey);$queueName 队列名称
$exchangeName  交换机名称
$routingKey 路由键

10.消费消息

$channel->basic_consume($queue,$consumer_tag,$no_local, $no_ack, $exclusive,$nowait, $callback);$queue队列名称
$callback回调函数
(1)回调函数
 $callback = function($msg){
  echo " [x] Received ", $msg->body, "\n";
  sleep(substr_count($msg->body, '.'));
  echo " [x] Done", "\n";};

11.监听消息,一有消息,立马就处理

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


https://www.kancloud.cn/lengyueguang/linux/2055371

北京半月雨文化科技有限公司.版权所有 京ICP备12026184号-3