.Net平台下ActiveMQ入门实例
1.ActiveMQ简介
先分析这么一个场景：当咱们在网站上购物时，必须通过，下订单、发票建立、付款处理、订单履行、航运等。可是，当用户下单后，当即跳转到“感谢那您的订单” 页面。不只如此，若果没有延迟，用户还会受到一封电子邮件。若是咱们使用传统方式去实现，通常是对数据库操做一通，而后调用各类接口、各类服务等待各类响应，这样一来下个订单须要好久时间才能看到结果，若是某个环节出了问题，那这个订单结果一时半会是看不到了，对于现代电子商务来讲，这是不能容忍的。 那么ActiveMQ久能够很好的解决这个问题：当用户下单后，有一个对ActiveMQ的调用，用来提交订单，而后系统就能够返回结果页面，而整个订单流程不会同步调用，后台JOB能够边聊天边跑。前台订单量很大的状况下每一个订单也只须要调用一次，后台一会儿处理不了？ 慢慢来，没人逼你，订单都在ActiveMQ中排队等待呢，他们可不会烦躁。 这个场景很是适合一种缓存队列，这种队列叫消息队列，不少产品都能实现这个功能，顺便回答下一个潜在的问题：他可比数据库操做快多了。html
本文就从基础开始一块儿学习下，本文系统运行环境：Window7 32位数据库
2.下载ActiveMQ
官方网站下载地址：http://activemq.apache.org/apache
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环境）session
同时下载.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/tcp
3.第一个ActiveMQ例子
先使用C#编写一个消息源，也就是生产者：ide
界面很简单，一个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个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);
}
一启动就会发现，这边已经接收到了这些消息，而且服务器端的已经被删除了。
4.总结
以上实现了一个p2p方式的消息队列，就是暂时存进去等待处理，处理完了这个消息就没了，保证送达，不会丢失，也不会被掉包。这种模式使用场合有限，并且客户只能有一个，属于快递形式，知足不了订单处理要求，缘由很简单：黑名单检查环节获取了这个订单信息，审核环节就获取不到了，下一节咱们一块儿学习“消息群发”，就是大喊一声，订单来了，你们开始忙吧...
http://www.cnblogs.com/madyina/p/4121458.html