Java消息中间件----ActiveMQ入门①

 

 

 

 

 

 

 

 

一 首先到ActiveMQ下载安装包

Active官网地址http://activemq.apache.org/activemq-5150-release.html

如图所示，有两个下载的连接，咱们下载第一个，用于Windows平台。

下载好了之后，选择好安装的位置，我这里是安装在了E:\software place\activeMq\apache-activemq-5.15.0

进入到对应的bin文件夹下，例如个人是E:\software place\activeMq\apache-activemq-5.15.0\bin\win64

而后启动activemq.bat

在浏览器输入127.0.0.1：8161能够进入activeMQ界面

咱们使用的是bat文件方式打开，这样子咱们整个使用过程当中bat文件不能关闭的，咱们还能够用服务方式启动

在bin目录下选择InstallService.bat以管理员命令启动

而后命令行cmd下输入services.msc打开服务窗口能够看到activeMQ服务出现了。

将服务启动后，就能够在进程里看见运行的服务，能够设置为开机自动启动。

 

二 Java关于activeMQ的实现

先来看看JMS在java中的实现接口

利用这些接口，能够用java代码是实现消息的发送接受，实现消息生产者与消费者

首先须要导入activeMQ的相关包

<dependencies>  
       <dependency>  
           <groupId>org.apache.activemq</groupId>  
           <artifactId>activemq-all</artifactId>  
          <version>5.9.0</version>  
       </dependency>  
   </dependencies>  

① 先来实现消息生产者

package com.myself.jms.queue;

import org.apache.activemq.ActiveMQConnectionFactory;


import javax.jms.*;

/**
 * Created by Administrator on 2017/7/15.
 */
public class AppProducer {
    private static final String url="tcp://192.168.1.101:61616";
    private static final String queueName="queue-test";
    public static void main(String[] args)throws JMSException {
        //1，建立ConnectionFacytory
        ConnectionFactory  connectionFactory = new ActiveMQConnectionFactory(url);

        //2,建立链接Connection
        Connection connection = connectionFactory.createConnection();

        //3，启动连接
        connection.start();

        //4建立会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        //5,建立一个目标
        Destination destination = session.createQueue(queueName);

       //6,建立一个生产者
        MessageProducer producer = session.createProducer(destination);

        for(int i=0;i<100;i++){
            //7,建立消息
            TextMessage testMessage= session.createTextMessage("Text"+i);
            //8发布消息
            producer.send(testMessage);
            System.out.println("发送消息"+testMessage.getText());
        }
        //9，关闭链接
        connection.close();
    }
}

　　运行后能够看到发送了100条消息

也能够在activeMQ的网页中队列里有100条信息

 有了生产者，也得须要消息消费者消费掉所产生的信息，产生的东西老是须要有人来处理的，不然就是一种资源的浪费了。

② 信息消费者的实现

package com.myself.jms.queue;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.transport.udp.DatagramEndpoint;


import javax.jms.*;
import javax.xml.soap.Text;

/**
 * Created by Administrator on 2017/7/15.
 */
public class AppConsumer {
    private static final String url="tcp://192.168.1.101:61616";
    private static final String queueName="queue-test";
    public static void main(String[] args)throws JMSException {
        //1，建立ConnectionFacytory
        ConnectionFactory  connectionFactory = new ActiveMQConnectionFactory(url);

        //2,建立链接Connection
        Connection connection = connectionFactory.createConnection();

        //3，启动连接
        connection.start();

        //4建立会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        //5,建立一个目标
        Destination destination = session.createQueue(queueName);

        //6 建立一个消费者
         MessageConsumer consumer = session.createConsumer(destination);

        //7建立一个监听器
        consumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println("接受到信息"+textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });

        //8，关闭链接
        connection.close();
    }
}

　　运行后消息确实接受到了

在activeMQ的网页中，能够看到出队列数目100，

 

 今天Active的初步入门就到这里吧， 我们下次在继续新的话题。