English 中文(简体)
.NET中的RabbitMQ订阅者通知
原标题:RabbitMQ subscriber notification in .NET
  • 时间:2010-10-14 18:31:07
  •  标签:
  • rabbitmq

我们现在正在使用带有WCF激活功能的MSMQ,它使我们能够不拉队列来读取消息。它喜欢向应用程序推送消息。

正如我们正在考虑从MSMQ到RabbitMQ的移植,通过消息队列来完成我们所需要的。

关于RabbitMQ.net客户端支持从订阅队列接收消息通知,我什么都不能说?

RabbitMQ中有没有像MSMQ一样可以向订阅者推送通知的.net

或者我们需要运行不断检查消息的服务?

问题回答

在AMQP(和RabbitMQ)中,有两种检索消息的方法:basic.getbasic.consume

Basic.get用于轮询服务器以获取消息。如果存在,则会将其返回给客户端。如果不是,则返回一个get empty(.NET方法返回null)。

Basic.consume设置队列的使用者。消息到达时,代理将消息推送给消费者。您可以派生DefaultBasicConsumer,它为您提供自己的自定义消费者,或者您可以使用订阅消息模式,它为您提供了一个阻塞nextDelivery()。

有关更多信息,请查看上面链接的API指南和.NET客户端用户指南。此外,询问RabbitMQ相关问题的好地方是rabbitmqdiscuss邮件列表。

我想你是在追求像EventingBasicConsumer这样的东西。另请参阅这个问题/答案

这是WAS(Windows激活服务)提供的一项功能。目前,WAS拥有用于net.pipe、net.msmq和net.tcp(及其端口共享服务)的侦听器适配器。我想您需要一个特定的AMQP侦听器适配器。

这可能会有所帮助http://msdn.microsoft.com/en-us/library/ms789006.aspx





相关问题
what the default max length of rabbit queue

For any given queue, the maximum length (of either type) can be defined using a policy (this option is highly recommended) or by clients using the queue s optional arguments. In the case where both ...

Retrieve messages from RabbitMQ queue(s)

I m looking to implement RabbitMQ into my PHP application, and am using the php-amqp extension. My only question is this, how do I easily query to return the contents of the queue in PHP? php-amqp ...

How to use listen on basic.return in python client of AMQP

I d like to make sure that my message was delivered to a queue. To do so I m adding the mandatory param to the basic_publish. What else should I do to receive the basic.return message if my message ...

Is AMQP production ready?

I d like to use AMQP to join two services one written in C# and other written in python. I m expecting quite large volume of messages per second. Is there any AMQP Broker that is production ready? ...

Multiple consumer one queue

Is it possible to make multiple consumers to share one single queue in RabbitMQ? I am currently using this php library to work with RabbitMQ, from what I observe, although I have 2 identical instances ...

Why use AMQP/ZeroMQ/RabbitMQ

as opposed to writing your own library. We re working on a project here that will be a self-dividing server pool, if one section grows too heavy, the manager would divide it and put it on another ...

How to wait for messages on multiple queues using py-amqplib

I m using py-amqplib to access RabbitMQ in Python. The application receives requests to listen on certain MQ topics from time to time. The first time it receives such a request it creates an AMQP ...

热门标签