ActiveMQ--HelloWorld

<dependency>

        <groupId>org.apache.activemq</groupId>

        <artifactId>activemq-all</artifactId>

        <version>5.15.3</version>

    </dependency>

package com.lhy.mq.helloworld;

import java.util.concurrent.TimeUnit;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.Destination;

import javax.jms.Message;

import javax.jms.MessageConsumer;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

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

        //第一步：建立ConnectionFactory工厂对象。需要填入用户名、密码、连接地址，均使用默认即可，默认端口为"tcp://localhost:61616"

                ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(

                        ActiveMQConnectionFactory.DEFAULT_USER,

                        ActiveMQConnectionFactory.DEFAULT_PASSWORD,

                        "tcp://localhost:61616");

                //第二步：通过ConnectionFactory工厂对象，创建Connection连接，并调用Connection的start方法开启连接，Connection默认是关闭的

                Connection connection = connectionFactory.createConnection();

                connection.start();

                //第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1 为是否启用事物，参数配置2为签收模式，一般设置自动签收

                Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

                //第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，

                //在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。

                //在程序中可以使用多个Queue和Topic

                Destination destination = session.createQueue("NB-Java");

                //第五步：通过Session对象创建MessageConsumer

                MessageConsumer consumer = session.createConsumer(destination);

                while(true){

                    //阻塞状态

                    TextMessage message = (TextMessage) consumer.receive();

                    System.err.println("消费数据："+message.getText());

                }

    }

}

package com.lhy.mq.helloworld;

import java.util.concurrent.TimeUnit;

import javax.jms.Connection;

import javax.jms.ConnectionFactory;

import javax.jms.DeliveryMode;

import javax.jms.Destination;

import javax.jms.JMSException;

import javax.jms.MessageProducer;

import javax.jms.Queue;

import javax.jms.Session;

import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {

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

        //第一步：建立ConnectionFactory工厂对象。需要填入用户名、密码、连接地址，均使用默认即可，默认端口为"tcp://localhost:61616"

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(

                ActiveMQConnectionFactory.DEFAULT_USER,

                ActiveMQConnectionFactory.DEFAULT_PASSWORD,

                "tcp://127.0.0.1:61616");

        //第二步：通过ConnectionFactory工厂对象，创建Connection连接，并调用Connection的start方法开启连接，Connection默认是关闭的

        Connection connection = connectionFactory.createConnection();

        connection.start();

        //第三步：通过Connection对象创建Session会话（上下文环境对象），用于接收消息，参数配置1 为是否启用事物，参数配置2为签收模式，一般设置自动签收

        Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);

        //第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，

        //在PTP模式中，Destination被称作Queue即队列；在Pub/Sub模式，Destination被称作Topic即主题。

        //在程序中可以使用多个Queue和Topic

        Destination destination = session.createQueue("NB-Java"); //队列名称

        //第五步：需要通过Session对象创建消息的发送和接收对象（生产者和消费者） MessageProducer/MessageConsumer

        //可以在创建生产者时指定 Destination目的地，这样发送的消息就都发到这，也可以在send消息的时候指定更灵活

        MessageProducer producer = session.createProducer(null);//

        // 第六步：可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性（DeliveryMode）

        //producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

        // 第七步：使用JMS规范的TextMessage形式创建数据（通过Session对象），调用MessageProducer的send方法发送数据。

        //同理客户端使用receive方式接收数据，最后关闭Connection连接

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

            TextMessage message = session.createTextMessage("我是消息内容  - "+i);

            //message.setText(string);

            //第一个参数   目标地址

            //第二个参数   具体的数据信息

            //第三个参数   传送数据的模式

            //第四个参数   优先级

            //第五个参数    消息的过期时间

//            producer.send(destination, message, deliveryMode, priority, timeToLive);

            producer.send(destination, message);

            TimeUnit.SECONDS.sleep(1); 

            System.err.println("生产者发送消息："+message.getText());

        }

        if(connection != null){

            connection.close();

        }

    }

}

<plugins>

           <simpleAuthenticationPlugin>

                 <users>

                      <authenticationUser username="lhy" password="123456" groups="users,admins"/>

                 </users>

           </simpleAuthenticationPlugin>

</plugins>

 <persistenceAdapter>

            <!--持久化策略，默认是卡哈DB-->

            <!--<kahaDB directory="${activemq.data}/kahadb"/>-->

            <!--改为mysql，my-ds 是下边配置数据源bead的id-->

            <jdbcPersistenceAdapter dataSource="#my-ds"/>

        </persistenceAdapter>

 <bean id="my-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">

                <property name="driverClassName" value="com.mysql.jdbc.Driver" />

                <property name="url" value="jdbc:mysql://127.0.0.1:3306/activemq?characterEncoding=utf-8" />

                <property name="username" value="root" />

                <property name="password" value="root" />

                <property name="initialSize" value="5" />

                <property name="maxTotal" value="100" />

                <property name="maxIdle" value="30" />

                <property name="maxWaitMillis" value="10000" />

                <property name="minIdle" value="1" />

    </bean>