RabbitMQ是一个消息代理器:它接受和转发消息。你可以把它当作一个邮局:当你把邮件放在信箱里时,你可以肯定邮差先生最终会把邮件送到你的收件人那里。在这个比喻中,RabbitMQ就是这里的邮箱,邮局和邮差。

RabbitMQ和邮局之间的主要区别是,它不处理纸张,而是接受、存储和转发二进制数据——消息。

RabbitMQ,和一般的消息传递,使用专业术语。

生产者的工作就是发送消息。发送消息的程序是生产者

消费者和生产者有着相似的意义. 消费者无非就是等待消息然后处理的程序

请注意,生产者、消费者和代理不必同一主机上;事实上,在大多数应用程序中它们没有这样做。

PHP安装RabbitMQ

PHP amqplib客户端库

添加composer.json

  1. {
  2.    "require": {
  3.        "php-amqplib/php-amqplib": ">=2.6.1"
  4.    }
  5. }
  1. composer install
  2. # 或者 直接运行包引入
  3. composer require php-amqplib/php-amqplib
  4. #如果报错,可能镜像有问题,则使用阿里云的镜像
  5. composer config -g repo.packagist composer https://mirrors.aliyun.com/composer/
  6. (拉取扩展需要开启PHP-SOCK镜像)

seng.php 生产者

receive.php

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

分类: 未分类

0 条评论

发表评论