标签：发送 nbsp blog 消费者 源码 部分 最新 host 版本
刚来到一个新公司，因为项目需要，要使用activemq，于是就研究了一下，写下此篇笔记，借鉴了马开东博客和csdn的相关资料
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 }
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 }
相关参数说明
连接工厂是客户用来创建连接的对象。
iconnection 封装了客户与服务之间一个虚拟的连接
此文来自: 马开东博客 转载请注明出处 网址： http://www.makaidong.com
。session是生产和消费消息的一个单线程上下文。会话用于创建消息生产者（producer）、消息消费者（consumer）和消息 （message）等。会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操作中。
目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。定义了两种消息传递域：点对点（ptp）消息传递域和发布/订阅消息传递域。
在点对点消息传递域中，目的地被成为队列（queue）；在发布/订阅消息传递域中，目的地被成为主题（topic）。
消息生产者是由会话创建的一个对象，用于把消息发送到一个目的地。
消息消费者是由会话创建的一个对象，它用于接收发送到目的地的消息。消息的消费可以采用以下两种方法之一：
同步消费。通过调用消费者的receive方法从目的地中显式提取消息。receive方法可以一直阻塞到消息到达。
异步消费。客户可以为消费者注册一个消息监听器，以定义在消息到达时所采取的动作。
* (7)消息 itextmessage
标签：发送 nbsp blog 消费者 源码 部分 最新 host 版本
原文地址：http://www.cnblogs.com/jiangxu1989/p/6515508.html
