我对基于消息队列的体系结构非常陌生。
我正计划创建一个微服务，该服务从消息队列中获取输入并将结果发布到另一个队列中。这将部署在dockerized容器中。
所以，我的理解是，我需要编写一个程序，该程序需要在无限循环内继续检查队列中的新请求。可能我需要一个计数信号量以确保消耗不超过容量。并且需要有一个在容器启动时启动无限循环的脚本。
[请帮助我了解最佳做法。纠正我的理解错误的地方。
[有多种选择。这取决于您的要求和用例。
根据您的用例，您可以使用ActiveMQ或Kafka或RabbitMQ等一些发布-订阅消息传递模式（消息代理）。
在消息代理体系结构中，给定的微服务可以充当消息生成器，将消息异步发送到队列或主题，而消费者微服务可以使用队列或主题中的消息。可以使用ActiveMQ或Kafka或RabbitMQ完成微服务之间的通信，这有助于微服务使用队列中的数据并将结果发布到另一个队列。