[.Net/C# 团队]2000人开发交流Qq群:348041382

架构师

 找回密码
 注册[Register]

QQ登录

只需一步,快速开始

查看: 277|回复: 0

[资料] .Net平台下ActiveMQ入门实例

[复制链接]
发表于 2017-1-9 14:41:52 | 显示全部楼层 |阅读模式
1.ActiveMQ简介先分析这么一个场景:当我们在网站上购物时,必须经过,下订单、发票创建、付款处理、订单履行、航运等。但是,当用户下单后,立即跳转到“感谢那您的订单” 页面。不仅如此,若果没有延迟,用户还会受到一封电子邮件。如果我们使用传统方式去实现,一般是对数据库操作一通,然后调用各种接口、各种服务等待各种响应,这样一来下个订单需要很久时间才能看到结果,如果某个环节出了问题,那这个订单结果一时半会是看不到了,对于现代电子商务来说,这是不能容忍的。 那么ActiveMQ久可以很好的解决这个问题:当用户下单后,有一个对ActiveMQ的调用,用来提交订单,然后系统就可以返回结果页面,而整个订单流程不会同步调用,后台JOB可以边聊天边跑。前台订单量很大的情况下每个订单也只需要调用一次,后台一下子处理不了? 慢慢来,没人逼你,订单都在ActiveMQ中排队等待呢,他们可不会烦躁。    这个场景非常适合一种缓存队列,这种队列叫消息队列,很多产品都能实现这个功能,顺便回答下一个潜在的问题:他可比数据库操作快多了。
本文就从基础开始一起学习下,本文系统运行环境:Window7 32位
2.下载ActiveMQ官方网站下载地址:http://activemq.apache.org/
3.运行ActiveMQ解压缩apache-activemq-5.10.0-bin.zip,然后双击apache-activemq-5.10.0inwin32activemq.bat运行ActiveMQ程序。
看见控制台最后一行输出: “access to all MBeans is allowed” 证明启动成功。
启动ActiveMQ以后,可以使用浏览器登陆:http://localhost:8161/admin/验证, 默认用户名是:admin  密码是:admin
(前提是安装好Java环境)
同时下载.net版Dll:Apache.NMS-1.6.0-bin.zip和Apache.NMS.ActiveMQ-1.6.4-bin.zip
都从这里下载:http://archive.apache.org/dist/activemq/apache-nms/1.6.0/
3.第一个ActiveMQ例子先使用C#编写一个消息源,也就是生产者:
界面很简单,一个Lable,一个TextBox,一个Button,然后添加Apache.NMS.dll和Apache.NMS.ActiveMQ.dll引用,在上述另外2个下载包里面找,注意版本号。

  1. public Form1()
  2.         {
  3.             InitializeComponent();
  4.             InitProducer();
  5.         }
  6.         private IConnectionFactory factory;

  7.         public void InitProducer()
  8.         {
  9.             try
  10.             {
  11.                 //初始化工厂,这里默认的URL是不需要修改的
  12.                 factory = new  ConnectionFactory("tcp://localhost:61616");

  13.             }
  14.             catch
  15.             {
  16.                 lbMessage.Text = "初始化失败!!";
  17.             }
  18.         }

  19.         private void btnConfirm_Click(object sender, EventArgs e)
  20.         {
  21.             //通过工厂建立连接
  22.             using (IConnection connection = factory.CreateConnection())
  23.             {
  24.                 //通过连接创建Session会话
  25.                 using (ISession session = connection.CreateSession())
  26.                 {
  27.                     //通过会话创建生产者,方法里面new出来的是MQ中的Queue
  28.                     IMessageProducer prod = session.CreateProducer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"));
  29.                     //创建一个发送的消息对象
  30.                     ITextMessage message = prod.CreateTextMessage();
  31.                     //给这个对象赋实际的消息
  32.                     message.Text = txtMessage.Text;
  33.                     //设置消息对象的属性,这个很重要哦,是Queue的过滤条件,也是P2P消息的唯一指定属性
  34.                     message.Properties.SetString("filter","demo");
  35.                     //生产者把消息发送出去,几个枚举参数MsgDeliveryMode是否长链,MsgPriority消息优先级别,发送最小单位,当然还有其他重载
  36.                     prod.Send(message, MsgDeliveryMode.NonPersistent, MsgPriority.Normal, TimeSpan.MinValue);
  37.                     lbMessage.Text = "发送成功!!";
  38.                     txtMessage.Text = "";
  39.                     txtMessage.Focus();
  40.                 }
  41.             }
  42.         }
复制代码


252031275743741.jpg
可以点击按钮发送一些消息,这些消息就被暂存到ActiveMQ中了,可以登录刚才要密码的那个网页去查看。
252031290908010.png
然后编写接收端,也就是消费者:
同样添加那2个DLL的引用,界面很简单只有一个Lable:

  1. public Form1()
  2.         {
  3.             InitializeComponent();
  4.             InitConsumer();

  5.         }
  6.          public void InitConsumer()
  7.          {
  8.              //创建连接工厂
  9.              IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
  10.              //通过工厂构建连接
  11.              IConnection connection = factory.CreateConnection();
  12.              //这个是连接的客户端名称标识
  13.              connection.ClientId = "firstQueueListener";
  14.              //启动连接,监听的话要主动启动连接
  15.              connection.Start();
  16.              //通过连接创建一个会话
  17.              ISession session = connection.CreateSession();
  18.              //通过会话创建一个消费者,这里就是Queue这种会话类型的监听参数设置
  19.              IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"), "filter='demo'");
  20.              //注册监听事件
  21.              consumer.Listener += new MessageListener(consumer_Listener);
  22.              //connection.Stop();
  23.              //connection.Close();  

  24.          }

  25.          void consumer_Listener(IMessage message)
  26.          {
  27.              ITextMessage msg = (ITextMessage)message;
  28.              //异步调用下,否则无法回归主线程
  29.              tbReceiveMessage.Invoke(new DelegateRevMessage(RevMessage),msg);

  30.          }

  31.          public delegate void DelegateRevMessage(ITextMessage message);

  32.          public void RevMessage(ITextMessage message)
  33.          {
  34.              tbReceiveMessage.Text += string.Format(@"接收到:{0}{1}", message.Text, Environment.NewLine);
  35.          }
复制代码

一启动就会发现,这边已经接收到了这些消息,并且服务器端的已经被删除了。
252031305127009.png 4.总结以上实现了一个p2p方式的消息队列,就是暂时存进去等待处理,处理完了这个消息就没了,保证送达,不会丢失,也不会被掉包。这种模式使用场合有限,而且客户只能有一个,属于快递形式,满足不了订单处理要求,原因很简单:黑名单检查环节获取了这个订单信息,审核环节就获取不到了,下一节我们一起学习“消息群发”,就是大喊一声,订单来了,大家开始忙吧...


备注:文章是转载的,文章message.Properties.SetString("filter","demo"); 这个没必要设置!!!!



上一篇:ActiveMQ持久订阅设置
下一篇:IAppBuilder接口没有UseWebApi方法
码农网,只发表在实践过程中,遇到的技术难题,不误导他人。
您需要登录后才可以回帖 登录 | 注册[Register]

本版积分规则

免责声明:
码农网所发布的一切软件、编程资料或者文章仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版软件,购买注册,得到更好的正版服务。

Mail To:help@itsvse.com

QQ|Archiver|手机版|小黑屋|架构师 ( 鲁ICP备14021824号-2 )

GMT+8, 2017-8-17 15:13

Powered by Discuz! X3.4

© 2001-2014 Comsenz Inc.

快速回复 返回顶部 返回列表