我需要通过 rails 中的 rabbitmq 实现独立的发布者/订阅者(计划使用amqp
gem),但我需要发布者与一个线程一起工作,订阅者在另一个线程中工作,并且它们彼此不依赖。
我正在使用当前amqp gem
,但它需要在单个eventmachine
代码块内发送和计算消息。所以我的问题是如何避免它并使其完全独立?
我需要通过 rails 中的 rabbitmq 实现独立的发布者/订阅者(计划使用amqp
gem),但我需要发布者与一个线程一起工作,订阅者在另一个线程中工作,并且它们彼此不依赖。
我正在使用当前amqp gem
,但它需要在单个eventmachine
代码块内发送和计算消息。所以我的问题是如何避免它并使其完全独立?
看起来可能的变体是在不同的进程(不是线程)中运行订阅者和消费者
您可以在此部分使用 DDS。不同的进程/应用程序可以使用数据分发服务进行通信。 对象管理组/检查此链接