Ajax一、音信队列之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
    Ajax 1

2、安装

    解压下载好的安装包,至地面任何磁盘

           Ajax 2

      启动activemq服务

          Ajax 3

      运转成功后的界面是

          Ajax 4

      这些界面是不能够关闭的,因为他表示ActvieMQ是运转的,假若关闭该窗口,后边编写代码的时候就会出错。切记!!!

     假使出现major.minor
version51.0 之类的荒唐,都以java版本安装不当的标题,安装1.6+以上的版本就能化解

           Ajax 5

      
运行成功后,http://localhost:8161/admin,暗中认同用户名和密码admin/admin。如果你想修改用户名和密码的话,在conf/jetty-realm.properties中修改即可。

           Ajax 6

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

           Ajax 7

        管理员界面如下

          Ajax 8

     
ActiviteMQ接收和殡葬新闻基本流程

       
Ajax 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

        Ajax 10

           Ajax 11
          Ajax 12

       Ajax 13

      创建C#品类,将那七个DLL添加到品种中。

      写入地址如下,声明:若是是设置在地点,那里的地址可以写【localhost】和【127.0.0.1】,如果是安装在服务器就直接写IP地址,切记,刚发轫自小编就搞错了。并且那里的地址要和C#代码里面的地址保持一致,否则也会错误。

       Ajax 14

       写入账号,密码如下

         Ajax 15

     写代码从前,有两点要验证

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

      Ajax 16
      Ajax 17

     否则就会发生非常,如下图:

      Ajax 18

     第三个就是:credentials里面的账号设置要和次序里面的一样,否则也会发生非常
     Ajax 19
      Ajax 20

     否则极度如下图:
     Ajax 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);

                    }
                }
            }
        }
    }

       写入后,可以查看

     Ajax 22

      Ajax 23

 

        Ajax 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();
        }
    }
}

      Ajax 25 

组合很多豪门的内容,所有手续都经过验证,可以使用。

相关文章