• 欢迎来到本博客,希望可以y一起学习与分享

RabbitMQ与PHP

PHP benz 7个月前 (03-04) 9次浏览 0个评论 扫描二维码
文章目录[隐藏]

php使用AMQP

RabbitMQ是基于AMQP协议开发的,PHP使用RabbitMQ要先安装AMQP的支持,第一个是PHP的官方扩展:php_amqp;第二个是扩展包php-amqplib/php-amqplib。

amqp扩展

使用命令安装:

最后在php.ini中添加extension=amqp即可。

在php 中使用Rabbitmq实现实现消息发送和接收

1,建立一个send.php文件用来发送消息

2,建立一个 receive.php 文件用来接收消息

代码如下:

测试:

打开两个终端,先运行接收者脚本监听消息发送:

php receive.php

在另一个终端中运行消息发送脚本:

php send.php

php-amqplib

使用命令安装即可:

php-amqplib文档

注意:php-amqplib是基于socket的,php需要开启socket扩展。

使用参考文章:RabbitMQ+PHP 教程一(Hello World)
或者下载文档文件下载

对比

amqp扩展是基于c语言开发的,php-amqplib是基于PHP语言开发的,性能上PHP官方扩展amqp比php-amqplib要好。

参数解析


queue: 队列名称

durable: 是否持久化, 队列的声明默认是存放到内存中的,如果rabbitmq重启会丢失,如果想重启之后还存在就要使队列持久化,保存到Erlang自带的Mnesia数据库中,当rabbitmq重启之后会读取该数据库

exclusive:是否排外的,有两个作用,
一:当连接关闭时connection.close()该队列是否会自动删除;
二:该队列是否是私有的private,如果不是排外的,可以使用两个消费者都访问同一个队列,没有任何问题,如果是排外的,会对当前队列加锁,其他通道channel是不能访问的,如果强制访问会报异常:

一般等于true的话用于一个队列只能有一个消费者来消费的场景

autoDelete:是否自动删除,当最后一个消费者断开连接之后队列是否自动被删除,可以通过RabbitMQ Management,查看某个队列的消费者数量,当consumers = 0时队列就会自动删除

arguments
队列中的消息什么时候会自动被删除?

Message TTL(x-message-ttl):设置队列中的所有消息的生存周期(统一为整个队列的所有消息设置生命周期), 也可以在发布消息的时候单独为某个消息指定剩余生存时间,单位毫秒, 类似于redis中的ttl,生存时间到了,消息会被从队里中删除,注意是消息被删除,而不是队列被删除, 特性Features=TTL, 单独为某条消息设置过期时间AMQP.BasicProperties.Builder properties = new AMQP.BasicProperties().builder().expiration(“6000”);
channel.basicPublish(EXCHANGE_NAME, “”, properties.build(), message.getBytes(“UTF-8”));

Auto Expire(x-expires): 当队列在指定的时间没有被访问(consume, basicGet, queueDeclare…)就会被删除,Features=Exp

Max Length(x-max-length): 限定队列的消息的最大值长度,超过指定长度将会把最早的几条删除掉, 类似于mongodb中的固定集合,例如保存最新的100条消息, Feature=Lim

Max Length Bytes(x-max-length-bytes): 限定队列最大占用的空间大小, 一般受限于内存、磁盘的大小, Features=Lim B

Dead letter exchange(x-dead-letter-exchange): 当队列消息长度大于最大长度、或者过期的等,将从队列中删除的消息推送到指定的交换机中去而不是丢弃掉,Features=DLX

Dead letter routing key(x-dead-letter-routing-key):将删除的消息推送到指定交换机的指定路由键的队列中去, Feature=DLK

Maximum priority(x-max-priority):优先级队列,声明队列时先定义最大优先级值(定义最大值一般不要太大),在发布消息的时候指定该消息的优先级, 优先级更高(数值更大的)的消息先被消费,

Lazy mode(x-queue-mode=lazy): Lazy Queues: 先将消息保存到磁盘上,不放在内存中,当消费者开始消费的时候才加载到内存中

Master locator(x-queue-master-locator)


文章 RabbitMQ与PHP 转载需要注明出处
喜欢 (0)

您必须 登录 才能发表评论!