我们正在使用activemq用于微服务消息代理。我的查询是关于如何为消费者服务构建故障转移机制。如果消费者服务中断,如何继续进行。对于这种情况,我们可以像hystrix或任何其他故障转移/断路器机制那样做一些事情。
简短的回答是'是'。有关如何实施的详细信息取决于您的用例。推荐架构:
选项A:多线程消费者2.从虚拟主题中用作订阅者的队列中读取的多个竞争消费者
选项B:单线程HA消费者2.使用独占消费者从虚拟主题中读取队列的多个竞争消费者,以确保只有一个线程正在处理数据而其他消费者处于热备份状态