C++一样、消息队列之ActiveMQ的安装、配置与C#样例代码

    最近发出日了,研究一下消息队列ActvieMQ,结合自己的施行及网上的有豪门内容,整理如下,所有手续同链接均是科学的。

1、ActiveMQ

ActiveMQ 是Apache出品,最流行的,能力强大的开源信息总线。ActiveMQ
是一个截然支持JMS1.1暨J2EE 1.4标准的 JMS
Provider实现,尽管JMS规范出台都是老大老的政工了,但是JMS在本之J2EE应用当中还是扮演着特别的身价。

   1、1、特性

  1.  多种语言和商编写客户端。语言:
    Java、C、C++、C#、Ruby、Perl、Python、PHP。应用协议:OpenWire、Stomp
    REST、WS Notification、XMPP、AMQP
  2. 全盘支持JMS1.1和J2EE 1.4正规 (持久化,XA消息,事务)
  3. 对Spring的支撑,ActiveMQ可以好轻内嵌到使用Spring的系统内去,而且也支撑Spring2.0之表征
  4. 由此了常见J2EE服务器(如 Geronimo、JBoss
    4、GlassFish、WebLogic)的测试,其中经过JCA 1.5 resource
    adaptors的布置,可以让ActiveMQ可以自动的配置至外兼容J2EE 1.4
    商业服务器上
  5. 支撑多传递协议:in-VM、TCP、SSL、NIO、UDP、JGroups、JXTA
  6. 支撑通过JDBC和journal提供便捷的音信持久化
  7. 自计划性上管了高性能的集群,客户端-服务器,点对点
  8. 支持Ajax
  9. 支持与Axis的整合
  10. 好挺容易得调用内嵌JMS provider,进行测试

   1、2、环境准备

      我因为windows10【家庭中文版】为列子

  1. windows 10
  2. jdk1.8+ 并于windows下安排好环境变量等,具体可以看
    http://jingyan.baidu.com/article/ff41162596a77912e4823716.html
  3. 下载最新版activemq  http://activemq.apache.org/download.html
    C++ 1

2、安装

    解压下充斥好之装置包,至当地任何磁盘

           C++ 2

      启动activemq服务

          C++ 3

      启动成功后底界面是

          C++ 4

      本条界面是休可知关闭的,因为他表示ActvieMQ是运作的,如果关闭该窗口,后面编写代码的下即便见面出错。切记!!!

     如果起major.minor
version51.0 之类的错,都是java版本安装不当的题目,安装1.6+以上之本子就会化解

           C++ 5

      
启动成功后,http://localhost:8161/admin,默认用户称与密码admin/admin。如果您想改用户名和密码的话,在conf/jetty-realm.properties中改即可。

           C++ 6

        如果需要修改端口可以在jetty文件中改

           C++ 7

        管理员界面如下

          C++ 8

     
ActiviteMQ接收及发送信息基本流程

       
C++ 9

3、发送信息的中心步骤:

      (1)、创建连接使用的工厂类JMS ConnectionFactory

      (2)、使用管理对象JMS ConnectionFactory建立连接Connection,并启动

      (3)、使用连接Connection 建立会话Session

     
(4)、使用会话Session和管理对象Destination创建信息生产者MessageSender

      (5)、使用信息生产者MessageSender发送消息 

4、消息接收者从JMS接受信息的步骤

     (1)、创建连接使用的厂类JMS ConnectionFactory

     (2)、使用管理对象JMS ConnectionFactory建立连接Connection,并启动

     (3)、使用连接Connection 建立会话Session

    
(4)、使用会话Session和管理对象Destination创建信息接收者MessageReceiver

    
(5)、使用信息接收者MessageReceiver接受信息,需要为此setMessageListener将MessageListener接口绑定到MessageReceiver消息接收者必须实现了MessageListener接口,需要定义onMessage事件方法。

 

5、C#信队列写副

    
ActiveMQ官方网站下载最新版本的Apache.NMS,网址:http://activemq.apache.org/nms/download.html,需要下载Apache.NMS和Apache.NMS.ActiveMQ两只bin包

    
http://www.apache.org/dyn/closer.lua/activemq/apache-nms/1.7.0/Apache.NMS.ActiveMQ-1.7.2-bin.zip

        C++ 10

           C++ 11
          C++ 12

       C++ 13

      创建C#色,将即时半个DLL添加到路被。

      写副地址如下,征:如果是安装在地方,这里的地址可以写【localhost】和【127.0.0.1】,如果是安在服务器就直写IP地址,切记,刚起自己就是打错了。并且这里的地方要同C#代码里面的地址保持一致,否则也会错。

       C++ 14

       写副账号,密码如下

         C++ 15

     写代码之前,有一定量沾使说明

     第一:activemq配置文件中的地址与代码中的地方要保持一致。

      C++ 16
      C++ 17

     否则就会见生出特别,如下图:

      C++ 18

     第一独就是是:credentials里面的账号设置要跟次序中的平,否则也会出特别
     C++ 19
      C++ 20

     否则生要下图:
     C++ 21

  好了,开始写代码了。  写副代码如下:

namespace ConsoleApplication21
{
    class Program
    {
        static void Main(string[] args)
        {
            String QueuesNameESF = "queue://test.log";
            Uri _uri = new Uri(String.Concat("activemq:tcp://127.0.0.1:61616"));
            IConnectionFactory factory = new ConnectionFactory(_uri);
            using (IConnection conn = factory.CreateConnection("liulei", "123456"))
            {
                using (ISession session = conn.CreateSession())
                {
                    IDestination destination = SessionUtil.GetDestination(session, QueuesNameESF); 
                    using (IMessageProducer producer = session.CreateProducer(destination))
                    {
                        conn.Start();
                        //可以写入字符串,也可以是一个xml字符串等
                        ITextMessage request = session.CreateTextMessage("messsage");
                        producer.Send(request);

                    }
                }
            }
        }
    }

       写副后,可以翻

     C++ 22

      C++ 23

 

        C++ 24

读取代码如下:

 

using System;
using Apache.NMS;
using Apache.NMS.ActiveMQ;
using Apache.NMS.Util;

namespace ConsoleApplication21
{
    class Program
    {
        static void Main(string[] args)
        {
            String QueuesNameESF = "queue://test.log";
            Uri _uri = new Uri(String.Concat("activemq:tcp://127.0.0.1:61616?wireFormat.maxInactivityDuration=0"));
            IConnectionFactory factory = new ConnectionFactory(_uri);
            using (IConnection conn = factory.CreateConnection("liulei", "123456"))
            {
                using (ISession session = conn.CreateSession())
                {
                    conn.Start();
                    IDestination destination = SessionUtil.GetDestination(session, QueuesNameESF);
                    using (IMessageConsumer consumer = session.CreateConsumer(destination))
                    {
                        ITextMessage message = consumer.Receive() as ITextMessage;
                        Console.Write(message.Text);
                    }
                }
            }
            Console.ReadLine();
        }
    }
}

      C++ 25 

重组多豪门之情节,所有手续都经证实,可以动用。