• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

C#ACtiveMQ收发数据C#ACtiveMQ收发数据

原作者: [db:作者] 来自: [db:来源] 收藏 邀请
 

1.下载ActiveMQ

官方网站下载地址：http://activemq.apache.org/

2.运行ActiveMQ

解压缩apache-activemq-5.10.0-bin.zip，然后双击apache-activemq-5.10.0\bin\win32\activemq.bat运行ActiveMQ程序。

启动ActiveMQ以后，可以使用浏览器登陆：http://localhost:8161/admin/验证， 默认用户名是：admin  密码是：admin

（前提是配置好好JDK环境，能打开console代表MQ运行成功）

 

 

 

 

 

 

 

同时下载.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/ 

  1. 引用ActiveMQ类库：

　　　　(1)Apache.NMS.dll路径：\Apache.NMS.ActiveMQ-1.7.2-bin\lib\Apache.NMS\net-3.5

　　　　(2)Apache.NMS.ActiveMQ.dll路径：\Apache.NMS.ActiveMQ-1.7.2-bin\build\net-3.5\debug

3.MQ例子（生产者）

     public Form1()
        {
            InitializeComponent();
            InitProducer();
        }
     private IConnectionFactory factory;
     public void InitProducer()
        {
            try
            {
                //初始化工厂
                factory = new ConnectionFactory("tcp://localhost:61616");
            }
            catch
            {
                lbMessage.Text = "初始化失败";
            }
        }
    private void button1_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();
                    XmlDocument Doc = new XmlDocument();
                    Doc.LoadXml("<?xml version='1.0' encoding='UTF-8'?><flightroute><flight><flightinfo><acid>CCA1501</acid><runway>13L</runway><gate>N115</gate><cockpitdirection>180</cockpitdirection><deparr>DEP</deparr></flightinfo></flight</flightroute>");
                    message.Text = Doc.InnerXml; //给这个消息对象赋实际的消息
                    //设置消息对象的属性，是Queue的过滤条件也是P2P的唯一指定属性
                    message.Properties.SetString("filter","demo");
                    prod.Send(message, MsgDeliveryMode.NonPersistent, MsgPriority.Normal, TimeSpan.MinValue);
                    lbMessage.Text = "发送成功！";
                    Text.Text = "";
                    Text.Focus();
                }
            }
        }  

可以点击按钮发送一些东西

 
 
 
 
 
 
 
 
 
 
 
 
接收端代码（consumer）
 public Form2()
        {
            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();
            //通过会话创建一个消费者
            IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"),"filter = 'demo'");
            //注册监听事件
            consumer.Listener += new MessageListener(consumer_Listener);
        }
        void consumer_Listener(IMessage message)
        {
            ITextMessage msg = (ITextMessage)message;
            ReceiveMessage.Invoke(new DelegateRevMessage(RevMessage), msg);
        }
        public delegate void DelegateRevMessage(ITextMessage message);
 
        public void RevMessage(ITextMessage message)
        {
            ReceiveMessage.Text += string.Format(@"接收到:{0}{1}", message.Text, Environment.NewLine);
        }        
                  
 
 
 
 
 
 
 
 
 
 
        发送的消息如果没接收就被存在Queue里

 

 
 

1.下载ActiveMQ

官方网站下载地址：http://activemq.apache.org/

2.运行ActiveMQ

解压缩apache-activemq-5.10.0-bin.zip，然后双击apache-activemq-5.10.0\bin\win32\activemq.bat运行ActiveMQ程序。

启动ActiveMQ以后，可以使用浏览器登陆：http://localhost:8161/admin/验证， 默认用户名是：admin  密码是：admin

（前提是配置好好JDK环境，能打开console代表MQ运行成功）

 

 

 

 

 

 

 

同时下载.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/ 

  1. 引用ActiveMQ类库：

　　　　(1)Apache.NMS.dll路径：\Apache.NMS.ActiveMQ-1.7.2-bin\lib\Apache.NMS\net-3.5

　　　　(2)Apache.NMS.ActiveMQ.dll路径：\Apache.NMS.ActiveMQ-1.7.2-bin\build\net-3.5\debug

3.MQ例子（生产者）

     public Form1()
        {
            InitializeComponent();
            InitProducer();
        }
     private IConnectionFactory factory;
     public void InitProducer()
        {
            try
            {
                //初始化工厂
                factory = new ConnectionFactory("tcp://localhost:61616");
            }
            catch
            {
                lbMessage.Text = "初始化失败";
            }
        }
    private void button1_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();
                    XmlDocument Doc = new XmlDocument();
                    Doc.LoadXml("<?xml version='1.0' encoding='UTF-8'?><flightroute><flight><flightinfo><acid>CCA1501</acid><runway>13L</runway><gate>N115</gate><cockpitdirection>180</cockpitdirection><deparr>DEP</deparr></flightinfo></flight</flightroute>");
                    message.Text = Doc.InnerXml; //给这个消息对象赋实际的消息
                    //设置消息对象的属性，是Queue的过滤条件也是P2P的唯一指定属性
                    message.Properties.SetString("filter","demo");
                    prod.Send(message, MsgDeliveryMode.NonPersistent, MsgPriority.Normal, TimeSpan.MinValue);
                    lbMessage.Text = "发送成功！";
                    Text.Text = "";
                    Text.Focus();
                }
            }
        }  

可以点击按钮发送一些东西

 
 
 
 
 
 
 
 
 
 
 
 
接收端代码（consumer）
 public Form2()
        {
            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();
            //通过会话创建一个消费者
            IMessageConsumer consumer = session.CreateConsumer(new Apache.NMS.ActiveMQ.Commands.ActiveMQQueue("firstQueue"),"filter = 'demo'");
            //注册监听事件
            consumer.Listener += new MessageListener(consumer_Listener);
        }
        void consumer_Listener(IMessage message)
        {
            ITextMessage msg = (ITextMessage)message;
            ReceiveMessage.Invoke(new DelegateRevMessage(RevMessage), msg);
        }
        public delegate void DelegateRevMessage(ITextMessage message);
 
        public void RevMessage(ITextMessage message)
        {
            ReceiveMessage.Text += string.Format(@"接收到:{0}{1}", message.Text, Environment.NewLine);
        }        
                  
 
 
 
 
 
 
 
 
 
 
        发送的消息如果没接收就被存在Queue里

 

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
C#System.IO.FileStream读取被其他程序打开的文件提示“文件正由另一进程使用，因此该 ...发布时间：2022-07-13
下一篇：
C#DataTable中执行DataTable.Select(&quot;条件&quot;)转发布时间：2022-07-13
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap