如何解决php入队:如何订阅主题?
文档描述了how to send a message to a topic,但是没有描述如何抄袭和接收消息。我已经创建了两个文件以进行简单测试以适应该库。 sender.php将消息发送到队列,将另一个消息发送到主题。当我使用sender.php发送消息并且topic.php正在运行时,topic.php没有输出。
我想我还没有理解正确的东西。有人可以告诉我如何订阅主题吗?
sender.php:
<?php
require 'vendor/autoload.php';
use Enqueue\ConnectionFactoryFactory;
$context = (new ConnectionFactoryFactory())->create('redis:')->createContext();
$fooQueue = $context->createQueue('aQueue');
$message = $context->createMessage('Hello QUEUE!');
$context->createProducer()->send($fooQueue,$message);
$fooTopic = $context->createTopic('aTopic');
$message = $context->createMessage('Hello TOPIC!');
$context->createProducer()->send($fooTopic,$message);
topic.php:
<?php
require 'vendor/autoload.php';
$client = new \Enqueue\SimpleClient\SimpleClient('redis:');
$client->bindTopic('aTopic',function (Message $psrMessage) {
var_dump($psrMessage);
});
while (true) {
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。