文档章节

.Net平台下ActiveMQ入门实例

短短的歼击机
 短短的歼击机
发布于 2015/08/24 22:12
字数 1315
阅读 146
收藏 3

#程序员薪资揭榜#你做程序员几年了?月薪多少?发量还在么?>>>

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.0\bin\win32\activemq.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个下载包里面找,注意版本号。

 

public Form1()
        {
            InitializeComponent();
            InitProducer();
        }
        private IConnectionFactory factory;

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

            }
            catch
            {
                lbMessage.Text = "初始化失败!!";
            }
        }

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

无标题

可以点击按钮发送一些消息,这些消息就被暂存到ActiveMQ中了,可以登录刚才要密码的那个网页去查看。

无标题2

然后编写接收端,也就是消费者:

同样添加那2个DLL的引用,界面很简单只有一个Lable:

 

public Form1()
        {
            InitializeComponent();
            InitConsumer();

        }
         public void InitConsumer()
         {
             //创建连接工厂
             IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616");
             //通过工厂构建连接
             IConnection connection = factory.CreateConnection();
             //这个是连接的客户端名称标识
             connection.ClientId = "firstQueueListener";
             //启动连接,监听的话要主动启动连接
             connection.Start();
             //通过连接创建一个会话
             ISession session = connection.CreateSession();
             //通过会话创建一个消费者,这里就是Queue这种会话类型的监听参数设置
             IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"), "filter='demo'");
             //注册监听事件
             consumer.Listener += new MessageListener(consumer_Listener);
             //connection.Stop();
             //connection.Close();  
 
         }
 
         void consumer_Listener(IMessage message)
         {
             ITextMessage msg = (ITextMessage)message;
             //异步调用下,否则无法回归主线程
             tbReceiveMessage.Invoke(new DelegateRevMessage(RevMessage),msg);
 
         }
 
         public delegate void DelegateRevMessage(ITextMessage message);
 
         public void RevMessage(ITextMessage message)
         {
             tbReceiveMessage.Text += string.Format(@"接收到:{0}{1}", message.Text, Environment.NewLine);
         }

 

一启动就会发现,这边已经接收到了这些消息,并且服务器端的已经被删除了。

无标题3 4.总结

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

本文转载自:http://www.cnblogs.com/madyina/p/4121458.html

短短的歼击机

短短的歼击机

粉丝 85
博文 268
码字总数 269797
作品 0
武汉
高级程序员
私信 提问
加载中

评论(0)

Java消息中间件----ActiveMQ入门①

一 首先到ActiveMQ下载安装包 Active官网地址http://activemq.apache.org/activemq-5150-release.html 如图所示,有两个下载的链接,我们下载第一个,用于Windows平台。 下载好了以后,选择好...

osc_6ak2b06j
2018/04/10
2
0
分布式消息中间件(二)ActiveMQ

一、概述 Apache出品,最流行的,能力强劲的开源消息总线。 1.JMS规范 Java消息服务(Java Message Service,即JMS)应用程序接口是一个Java平台中关于面向消息中间件(MOM)的API,用于应用...

osc_sm6rxbzs
2019/09/21
6
0
消息中间件--ActiveMQ&JMS消息服务

消息中间件 ### ---------- 消息中间件 1. 消息中间件的概述 2. 消息中间件的应用场景   * 异步处理   * 应用解耦   * 流量削峰   * 消息通信 ---------- ### JMS消息服务 ### ----...

osc_9ajwkns1
2018/04/22
7
0
ActiveMQ专题1: 入门实例

序 AMQ入门实例 下载导入源码: 下载地址: http://activemq.apache.org/activemq-5155-release.html (可以同时下载安装包和源码,我这里为了和项目中使用的保持一致,下载的是5.8.0版本) ...

槟城码农
2018/08/29
0
0
ActiveMQ学习总结------入门篇01

注:*这篇博文文章主要介绍ActiveMQ是什么原理性的内容和如何安装和简易操作 一、 ActiveMQ 简介 1 ActiveMQ是什么呢?看起来好碉堡的东西哇! ActiveMQ 是 Apache 出品,最流行的,能力强劲...

osc_0vxxme2b
04/16
5
0

没有更多内容

加载失败,请刷新页面

加载更多

python设置搜索路径,以及外层文件调用时路径变动问题

通过sys.path设置路径 import syssys.path.append("待加入的搜索路径") 修改python环境变量 编辑 ~/.profile 文件:export PYTHONPATH= $PYTHONPATH:搜索路径临时修改方法:直接在命令...

hc321
8分钟前
5
0
一个开源的跨平台音乐播放与音乐下载器

跨平台的音乐播放器 目前国内的linux平台上的音乐播放器不多,除了网易云比较多人使用的。 当然Listen1也是一个不错的选择,真正的跨平台,包括Android/Mac/Win/Linux以及Chrome插件,目前尚...

氷泠
14分钟前
8
0
联盟之畔,算力之颠——超算产业峰会,邀你共享

2020年5月30日,在成都首座万豪酒店,一场关于【算力之巅 超算产业峰会】正在如火如荼进行着,Tokenlnsight联合多位算力界代表人物参与此次峰会,一起探讨挖矿与财富机遇的话题,星际联盟也很...

IPFS星际联盟
18分钟前
5
0
Oracle学习(五) --- 视图、序列、同义词、索引

1、视图 1.1、什么是视图 视图就是一个虚拟表,实体表的映射。 什么时候使用视图 在开发中,有一些表结构是不希望过多的人去接触,就把实体表映射为一个视图。(表结构简化) 在项目过程中,程...

庭前云落
29分钟前
12
0
设置JavaScript函数的默认参数值 - Set a default parameter value for a JavaScript function

问题: I would like a JavaScript function to have optional arguments which I set a default on, which get used if the value isn't defined (and ignored if the value is passed). 我......

javail
32分钟前
23
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部