十云官方文档
发布订阅模式 ¶
- Publish/Subscribe（Pub/Sub）
支持情况 ¶
| 驱动 | 是否支持 |
|---|---|
| redis | |
| amqp | |
| mqtt |
生产者 ¶
php
# 快捷方式
queue_producer();
# 常规方式
$drive = 'redis/amqp/mqtt';
// 工厂-驱动
// 工厂-单例
\shiyunQueue\QueueProducer::ConnectionFactory($drive)
\shiyunQueue\QueueProducerFactory::getInstance($drive)
// 1.获取连接
->newConnection()
// 2.创建通道
->createChannel()
// 3.创建队列声明-交换器
->exchangeDeclare('pubsub_logs', 'fanout', false, false, false)
->exchangeDeclare('topic_logs', 'fanout', false, false, false)
// 4.发送消息
->basicPublish()
# 快捷方式
queue_producer();
# 常规方式
$drive = 'redis/amqp/mqtt';
// 工厂-驱动
// 工厂-单例
\shiyunQueue\QueueProducer::ConnectionFactory($drive)
\shiyunQueue\QueueProducerFactory::getInstance($drive)
// 1.获取连接
->newConnection()
// 2.创建通道
->createChannel()
// 3.创建队列声明-交换器
->exchangeDeclare('pubsub_logs', 'fanout', false, false, false)
->exchangeDeclare('topic_logs', 'fanout', false, false, false)
// 4.发送消息
->basicPublish()