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 

结合多豪门之情节,所有手续都经认证,可以采用。

相关文章