基于RabbitMQ的发布者/订阅者API设计

Question

我正在创建一个API来发布和使用来自RabbitMQ的消息。在我当前的设计中，发布者将发出一个POST请求。我的API会将POST请求路由到Exchange。这样，发布者在发布时就不必知道服务器地址、exchange名称等。

现在消费者部分是我不确定如何继续的地方。

开始时不会排队。当一个新的消费者想要订阅一个主题时，那么我将创建一个队列并将其绑定到交换。我需要一些问题的答案-

1. 一旦我为使用者创建了一个队列，那么让使用者从该队列中获取消息的下一步是什么？
2. 我使使用者从队列中请求一批消息（例如50条消息）。然后，一旦我收到来自消费者的ack，我将从队列中发送接下来的50条消息。如果我没有收到ack，我将把50条消息重新请求到队列中。就打开和关闭使用者与我的API之间的连接而言，这不是很昂贵吗？

如果有更好的方法，那么请建议

Answer 1

总的来说，您将RMQ放在REST API后面的想法是一个好主意。你不想直接把RMQ暴露在世人面前。

具体问题：

一旦我为使用者创建了一个队列，下一步是什么让使用者从那个队列中获取消息呢？

不要为每批消息打开和关闭连接。

您的应用程序实例（“消费者”应用程序）应该有一个单独的连接。只要您需要，该连接就会一直打开--只要您需要，就可以通过对RabbitMQ的多次调用。

我通常会在应用程序启动后立即打开RMQ连接，直到应用程序关闭。