Docker安装ActiveMQ镜像以及通过Java生产消费activemq示例

拉取镜像

docker pull docker.io/webcenter/activemq

启动容器

docker run -d --name myactivemq -p 61616:61616 -p 8162:8161 docker.io/webcenter/activemq:latest

这样就代表启动成功了

浏览器访问

http://localhost:8162/

admin admin

开启验证

修改配置文件/opt/activemq/conf/activemq.xml

/opt/activemq/conf# vi activemq.xml

<plugins>

     <simpleAuthenticationPlugin>

        <users>

            <authenticationUser username="guest" password="guest" groups="guests"/>

            <authenticationUser username="user" password="user" groups="users"/>

            <authenticationUser username="admin" password="admin" groups="admins"/>

            <authenticationUser username="artemis" password="artemis" groups="admins"/>

        </users>

     </simpleAuthenticationPlugin>

</plugins>

修改完重启镜像即可

通过java代码生产，消费activemq

生产者

package com.activemq.demo;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class ActiveMQProducer {

    private static final String DEFAULT_BROKER_HOST = "tcp://localhost:61616";

    public static void main(String[] args) throws JMSException {

// 创建连接工厂

        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(DEFAULT_BROKER_HOST);

// 获取 connection

        final Connection connection = connectionFactory.createConnection("admin", "admin");

// 启动

        connection.start();

// 创建会话 session，参数第一个是事务，第二个是签收

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 创建目的地，queue 或者 topic

        Queue queue = session.createQueue("testq1804");

创建消息的生产者

        MessageProducer producer = session.createProducer(queue);

// 创建消息

        for (int i = 0; i < 100000; i++) {

//        while(true){

            String message = "{\"id\":"+System.currentTimeMillis()+", \"name\":\""+i+"\"}"; //System.currentTimeMillis() + "这是一条消息" + new Date();

            TextMessage textMessage = session.createTextMessage(message);

            System.out.println(message);

// 发送消息给 mq

            producer.send(textMessage);

            try {

                Thread.sleep(500l);

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

    }

}

消费者

package com.activemq.demo;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.Connection;

import javax.jms.JMSException;

import javax.jms.Message;

import javax.jms.MessageConsumer;

import javax.jms.MessageListener;

import javax.jms.Queue;

import javax.jms.Session;

import javax.jms.TextMessage;

public class ActiveMQConsumer {

    public static void main(String[] args) throws Exception {

        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

// 获取 connection

        final Connection connection = connectionFactory.createConnection("user", "user");

// 启动

        connection.start();

// 创建会话 session，参数第一个是事务，第二个是签收

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// 创建目的地，queue 或者 topic

        Queue queue = session.createQueue("testq1804"); // test_topic_m1

            MessageConsumer consumer = session.createConsumer(queue);

        consumer.setMessageListener(new MessageListener() {

            @Override

            public void onMessage(Message message) {

                try {

                    System.out.println("接收到消息：" + ((TextMessage)message).getText());

                } catch (JMSException e) {

                    e.printStackTrace();

                }

            }

        });

    }

}