最初,我有一个单独的rabbitmq节点,可以很好地处理请求/响应客户端交互。
我现在正在切换到集群,并尝试运行完全相同的请求/响应操作。它以惊人的速度爆炸。
我已经设置了两个主机作为rabbitmq集群的一部分。我遇到了如此多的麻烦,以至于我又回到了使用masstransit 。
这似乎也有麻烦。我最终在我的请求服务上得到了一个重复出现的异常:
--- End of stack trace from previous location where exception was thrown --
at System.Runtime.CompilerServices.TaskAwaiter
我使用rabbitmq在用rails编写的microservices之间进行通信。每个服务都订阅了一个topic。所有服务都是scaled,并根据需要作为多个实例运行。
在订阅期间,bunny将all the messages从队列移动到unacked状态。这使得其他缩放的实例只是空闲的,因为在ready状态中没有消息。
是否有一种方法来限制订阅可以获取的消息数量,以便其他实例可以从队列中获取其余的消息。