RabbitMQ是一个消息代理器:它接受和转发消息。你可以把它当作一个邮局:当你把邮件放在信箱里时,你可以肯定邮差先生最终会把邮件送到你的收件人那里。在这个比喻中,RabbitMQ就是这里的邮箱,邮局和邮差。
RabbitMQ和邮局之间的主要区别是,它不处理纸张,而是接受、存储和转发二进制数据——消息。
RabbitMQ,和一般的消息传递,使用专业术语。
生产者的工作就是发送消息。发送消息的程序是生产者
消费者和生产者有着相似的意义. 消费者无非就是等待消息然后处理的程序
请注意,生产者、消费者和代理不必同一主机上;事实上,在大多数应用程序中它们没有这样做。
PHP安装RabbitMQ
PHP amqplib客户端库
添加composer.json
{
"require": {
"php-amqplib/php-amqplib": ">=2.6.1"
}
}
composer install
# 或者 直接运行包引入
composer require php-amqplib/php-amqplib
- #如果报错,可能镜像有问题,则使用阿里云的镜像
- composer config -g repo.packagist composer https://mirrors.aliyun.com/composer/
- (拉取扩展需要开启PHP-SOCK镜像)
seng.php 生产者

receive.php

类似于golang 的管道channel,但是比管道功能更多,他能持久化,而且可以发布,订阅,可以做延时队列
0 条评论