5

我刚从 ActiveMQ 开始，遇到了几个问题。

我应该使用 ActiveMQ 发送消息

我现在做了什么：

public class ActiveMQSender
{
    private readonly Uri connectionUri;
    private readonly IConnectionFactory connectionFactory;

    private readonly string destinationName;

    public ActiveMQSender()
    {
        this.connectionUri = new Uri("activemq:tcp://localhost:61616");
        this.connectionFactory = new NMSConnectionFactory(this.connectionUri);
        this.destinationName = "queue://testQ";
    }

    public void Send(string msg)
    {
        using (var connection = this.connectionFactory.CreateConnection())
        using (var session = connection.CreateSession())
        {
            var destination = SessionUtil.GetDestination(session, this.destinationName);

            using (var producer = session.CreateProducer(destination))
            {
                connection.Start();
                var message = session.CreateTextMessage(msg);
                producer.Send(message);
            }
        }
    }
}

只有一个此类的实例将作为构造函数参数注入。

我担心连接、会话和生产者创建的开销，因为消息会频繁发送（通常每 10 秒发送一条消息）我应该重用连接、会话或生产者实例，我应该如何应对连接失败？在这种情况下，常见的模式是什么？

4

2 回答 2

2

NMS.ActiveMQ 像 java 客户端一样提供故障转移传输，如果连接丢失，它将自动尝试重新连接到代理。您可以使用它来最小化您的故障处理代码。对 AMQ 中的故障转移传输主题进行一些 Google 搜索。

重新创建连接和相关资源不是轻量级操作，因此最好的办法是缓存它们并在需要该连接时重复使用它们。结合故障转移，您可以可靠地反复重用同一个 MessageProducer。

NMS 的模型与 JMS 非常相似，因此对 JMS 进行一些阅读应该会有所启发。

于 2012-12-13T23:48:07.923 回答
1

大概您为此使用NMS？作为一个建议，您可能需要考虑使用阻塞队列来限制消息，然后批量发送 n 条消息的块......然后您可以保留您的代码并发布批次，同时在处理您的连接、会话和生产者时你已经完成了你正在做的......

至于连接失败 - 您应该能够将异常侦听器连接到您的会话，以便您收到任何问题的通知。

于 2012-12-13T15:31:11.030 回答