平、新闻队列之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
    图片 1

2、安装

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

           图片 2

      启动activemq服务

          图片 3

      启动成功后底界面是

          图片 4

      夫界面是勿可知关闭的,因为他表示ActvieMQ是运作的,倘若关闭该窗口,后边编写代码的下尽管会出错。切记!!!

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

           图片 5

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

           图片 6

        固然欲修改端口能够当jetty文件中改

           图片 7

        管理员界面如下

          图片 8

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

       
图片 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

        图片 10

           图片 11
          图片 12

       图片 13

      创建C#色,将这有限个DLL添加到路被。

      写副地址如下,表明:假设是安装于当地,这里的地址可以形容【localhost】和【127.0.0.1】,即使是装于服务器就直写IP地址,切记,刚起自己便打错了。并且这里的地点要与C#代码里面的地点保持一致,否则也会误。

       图片 14

       写副账号,密码如下

         图片 15

     写代码往日,有三三两两碰而证实

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

      图片 16
      图片 17

     否则就是谋面发出特别,如下图:

      图片 18

     第一独就是是:credentials里面的账号设置要跟次序中的一样,否则也会出很
     图片 19
      图片 20

     否则大而下图:
     图片 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);

                    }
                }
            }
        }
    }

       写副后,可以查看

     图片 22

      图片 23

 

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

      图片 25 

整合多大家的内容,所有手续都经过验证,可以利用。

相关文章