activemq C#客户端使用demo

【核心代码】

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Apache.NMS;
using Apache.NMS.ActiveMQ;

//发布订阅模式，一个生产者多个消费者
namespace NmsProducer2
{
    class Program
    {
        static void Main(string[] args)
        {
            try
            {
                //Create the Connection Factory  
                IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/"); //这里可以写tcp://192.168.1.111:61616的形式连接其他服务器上的ActiveMQ服务器 
                using (IConnection connection = factory.CreateConnection())
                {
                    //Create the Session  
                    using (ISession session = connection.CreateSession())
                    {
                        //Create the Producer for the topic/queue  
                        IMessageProducer prod = session.CreateProducer(
                            new Apache.NMS.ActiveMQ.Commands.ActiveMQTopic("SecondTopic"));

                        //Send Messages  
                        int i = 100000;

                        //while (!Console.KeyAvailable)
                        while(i>0)
                        {
                            ITextMessage msg = prod.CreateTextMessage();
                            msg.Text = "msg"   i.ToString();
                            Console.WriteLine("Sending: "   i.ToString());
                            prod.Send(msg, Apache.NMS.MsgDeliveryMode.NonPersistent, Apache.NMS.MsgPriority.Normal, TimeSpan.MinValue);

                            //System.Threading.Thread.Sleep(1000);
                            i--;
                        }
                    }
                }

                Console.ReadLine();
            }
            catch (System.Exception e)
            {
                Console.WriteLine("{0}", e.Message);
                Console.ReadLine();
            }  
        }
    }
}