C#实现同Active MQ通讯的方法

当我们需要将C#应用程序与Active MQ进行通信时，可以使用Active MQ的C#客户端来实现。以下是C#实现同Active MQ通讯的方法。

准备工作

1. 下载Active MQ

在Active MQ官网上下载Active MQ，解压到本地，然后启动Active MQ。

2. 下载Active MQ的C#客户端

下载Active MQ的C#客户端，解压到本地。

3. 准备Visual Studio环境

在Visual Studio 中创建一个新的C#控制台应用程序。

4. 将ActiveMQ的C#客户端添加到项目中

将ActiveMQ的C#客户端添加到项目中，将其作为引用程序。

实现方法

1. 连接Active MQ

using Apache.NMS;
using Apache.NMS.ActiveMQ;

IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
using (IConnection connection = factory.CreateConnection(username, password))
{
    connection.Start();
    using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
    {
        //...
    }
}

2. 生产者将消息发送到Active MQ

using Apache.NMS;
using Apache.NMS.ActiveMQ;

IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
using (IConnection connection = factory.CreateConnection(username, password))
{
    connection.Start();
    using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
    {
        IDestination destination = session.GetQueue("TestQueue");
        using (IMessageProducer producer = session.CreateProducer(destination))
        {
            ITextMessage message = producer.CreateTextMessage("Hello World");
            producer.Send(message);
        }
    }
}

3. 消费者接收Active MQ中的消息

using Apache.NMS;
using Apache.NMS.ActiveMQ;

IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
using (IConnection connection = factory.CreateConnection(username, password))
{
    connection.Start();
    using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
    {
        IDestination destination = session.GetQueue("TestQueue");
        using (IMessageConsumer consumer = session.CreateConsumer(destination))
        {
            IMessage message = consumer.Receive(TimeSpan.FromSeconds(1));
            if (message is ITextMessage textMessage)
            {
                Console.WriteLine(textMessage.Text);
            }
        }
    }
}

示例说明

示例1：发送并在控制台打印Active MQ中的文本消息

using Apache.NMS;
using Apache.NMS.ActiveMQ;

class Program
{
    static void Main(string[] args)
    {
        IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
        using (IConnection connection = factory.CreateConnection(username, password))
        {
            connection.Start();
            using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
            {
                IDestination destination = session.GetQueue("TestQueue");
                using (IMessageProducer producer = session.CreateProducer(destination))
                {
                    ITextMessage message = producer.CreateTextMessage("Hello World");
                    producer.Send(message);
                    Console.WriteLine("Message sent.");
                }

                using (IMessageConsumer consumer = session.CreateConsumer(destination))
                {
                    IMessage message = consumer.Receive(TimeSpan.FromSeconds(1));
                    if (message is ITextMessage textMessage)
                    {
                        Console.WriteLine($"Received message: {textMessage.Text}");
                    }
                }
            }
        }

        Console.ReadLine();
    }
}

示例2：连接到Active MQ Broker并创建一个新的主题

using Apache.NMS;
using Apache.NMS.ActiveMQ;

class Program
{
    static void Main(string[] args)
    {
        IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
        using (IConnection connection = factory.CreateConnection(username, password))
        {
            connection.Start();
            using (ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
            {
                ITopic topic = session.CreateTopic("TestTopic");
                Console.WriteLine($"Topic created.");
            }
        }

        Console.ReadLine();
    }
}

希望这些示例可以帮助你了解如何使用C#与Active MQ进行通信。