.Net下对ActiveMQ的使用

mac2022-06-30 156

　　刚来到一个新公司，因为项目需要，要使用ActiveMQ，于是就研究了一下，写下此篇笔记，借鉴了博客园和的相关资料　　

ActiveMQ简介 ActiveMQ是一个开放源码，基于Apache2.0 licenced的，实现了JMS1.1的消息中间件一开始不知道什么叫中间件，于是又研究了一下中间件的概念，如果有不了解的可以看下，会的就直接略过。　　中间件（middleware）是一种独立的系统软件或服务程序, 它在操作系统、网络和数据库之上，应用软件的下层，总的作用是为处于自己上层的应用软件提供运行与开发的环境，帮助用户灵活、高效地开发和集成复杂的应用软件. 　　 中间件的作用：具体地说，中间件屏蔽了底层操作系统的复杂性，使程序开发人员面对一个简单而统一的开发环境，减少程序设计的复杂性，将注意力集中在自己的业务上，不必再为程序在不同系统软件上的移植而重复工作，从而大大减少了技术上的负担。中间件带给应用系统的，不只是开发的简便、开发周期的缩短，也减少了系统的维护、运行和管理的工作量，还减少了计算机总体费用的投入。　　中间件的分类：中间件所包括的范围十分广泛，针对不同的应用需求涌现出多种各具特色的中间件产品。但至今中间件还没有一个比较精确的定义，因此，在不同的角度或不同的层次上，对中间件的分类也会有所不同。由于中间件需要屏蔽分布环境中异构的操作系统和网络协议，它必须能够提供分布环境下的通讯服务，我们将这种通讯服务称之为平台。基于目的和实现机制的不同，我们将平台分为以下主要几类：远程过程调用（Remote Procedure Call）RPC 面向消息的中间件（Message-Oriented Middleware）MOM 对象请求代理（Object Request Brokers）ORB 下面进入主题：　　先从 http://activemq.apache.org/download.html 下载MQ的最新版本 ActiveMQ在.Net下的使用：　　1. 添加对Apache.NMS.dll和Apache.NMS.ActiveMQ.dll的引用　　　　2.编写Producer生产者代码 1 class Program 2 { 3 static void Main(string[] args) 4 { 5 try 6 { 7 //创建连接工厂 8 IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/"); 9 using (IConnection connection = factory.CreateConnection()) 10 { 11 //创建 Session 12 using (ISession session = connection.CreateSession()) 13 { 14 //创建生产者Producer for the topic/queue 15 IMessageProducer prod = session.CreateProducer( 16 new Apache.NMS.ActiveMQ.Commands.ActiveMQTopic("testing")); 17 //发送消息 18 int i = 0; 19 20 while (!Console.KeyAvailable) 21 { 22 ITextMessage msg = prod.CreateTextMessage(); 23 msg.Text = i.ToString(); 24 Console.WriteLine("Sending: " + i.ToString()); 25 prod.Send(msg, Apache.NMS.MsgDeliveryMode.NonPersistent, Apache.NMS.MsgPriority.Normal, TimeSpan.MinValue); 26 27 System.Threading.Thread.Sleep(5000); 28 i++; 29 } 30 } 31 } 32 33 Console.ReadLine(); 34 } 35 catch (System.Exception e) 36 { 37 Console.WriteLine("{0}",e.Message); 38 Console.ReadLine(); 39 } 40 } 41 }

　　3.编写Consumer消费者代码 1 class Program 2 { 3 static void Main(string[] args) 4 { 5 try 6 { 7 //创建连接工厂 8 IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/"); 9 //创建连接 10 using (IConnection connection = factory.CreateConnection()) 11 { 12 connection.ClientId = "testing listener"; 13 connection.Start(); 14 //创建Session 15 using (ISession session = connection.CreateSession()) 16 { 17 //创建Consumer 18 IMessageConsumer consumer = session.CreateDurableConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQTopic("testing"), "testing listener", null, false); 19 //绑定接收消息的事件 20 consumer.Listener += new MessageListener(consumer_Listener); 21 Console.ReadLine(); 22 } 23 connection.Stop(); 24 connection.Close(); 25 } 26 } 27 catch (System.Exception e) 28 { 29 Console.WriteLine(e.Message); 30 } 31 } 32 33 static void consumer_Listener(IMessage message) 34 { 35 try 36 { 37 ITextMessage msg = (ITextMessage)message; 38 Console.WriteLine("Receive: " + msg.Text); 39 } 40 catch (System.Exception e) 41 { 42 Console.WriteLine(e.Message); 43 } 44 } 45 }