0

我有一个任务需要在 ActiveMQ 队列和 .Net 应用程序之间建立连接。我正在为此使用 AMQP.Net Lite 插件。但是我需要在消息进入队列时调用 .Net 应用程序的接收器。是否有任何解决方案不需要.Net应用程序不时通过检查MQ队列以查看是否有任何新消息来停留?任何使用套接字的直接连接?在这种情况下我应该如何进行?

4

1 回答 1

0

亚当-

听起来你想设置一个标准的消费者(或者它可能被称为接收器)。您的用例正是 AMQP API 消费者端的目的。见下文

注意:消息系统在接收消息时通常会部署一个“回调”或“监听器”模型来进行异步处理。从数据处理的角度来看,这仍然会让人感觉“瞬间”。这是一种不同的编程范式,更易于编码,因为它不需要逻辑来打破接收者/消费者模式中的无限循环。

AMQP.NET lite 接收器示例

于 2019-02-22T03:19:47.620 回答