如何将消息代理(Nats)与laravel集成在一起?

当前,我有一个在laravel上运行的项目,我想使用nat作为我们的消息代理。我尝试使用https://github.com/flownative/nats,但我的问题是应该在哪里放置pub subs代码?

$nats->publish('foo','Hello World');

// Simple asynchronous subscriber
$nats->subscribe('foo',function($message) {
    printf("\nReceived a message: %s\n",$message->getBody());
}); 

我尝试使用PHP artisan队列,但是由于必须通过调用dispatch方法来触发,所以它不起作用。如果是这样,我应该在哪里调用调度方法?预先感谢。

masycq 回答:如何将消息代理(Nats)与laravel集成在一起?

Laravel 中没有支持 NATS 的社区包(从我所见),我认为使用 NATS PHP 包不会解决您尝试构建为 Pub/Sub 的基础设施,因为您必须包装在 Larval 的自定义队列驱动程序中安装 NATS php 包。

我强烈建议将 SNS/SQS 用于 Pub/Sub 基础架构,幸运的是我已经为此制作了一个包。它非常易于使用,如果需要,您可以在其中定义订阅者类和发布者,而且它确实支持标准和 FIFO SQS/SNS。

检查一下:https://github.com/amranidev/micro-bus

本文链接:https://www.f2er.com/3169438.html

大家都在问