基本條件

搭建之前有一定java 開發基礎

下載ActiveMq

1、最新下載地址版本：http://activemq.apache.org/download.html
2、解壓即可。
3、啟動ActiveMq 服務。windows下雙擊D:\ACTIVEMQ\apache-activemq-5.15.6\bin\win64 下的activemq 指令碼 。也可以 在該目錄 通過linux命令 ./activemq start
4、如圖所示就是啟動成功

maven 整合mq 的jar

<!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-all -->
		<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-all</artifactId>
			<version>5.15.0</version>
		</dependency>
		<!-- https://mvnrepository.com/artifact/org.apache.xbean/xbean-spring -->
		<dependency>
			<groupId>org.apache.xbean</groupId>
			<artifactId>xbean-spring</artifactId>
			<version>3.7</version>
		</dependency>
		<!-- https://mvnrepository.com/artifact/log4j/log4j -->
		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>1.2.17</version>
		</dependency>
 

Java 程式碼以及註釋

1、常量工具類

package com.dairujie.utils;

import org.apache.activemq.ActiveMQConnection;
/**
 * 
 * @ClassName:  ConstantUtil   
 * @Description:TODO(常量工具類)   
 * @author: drj 
 * @date:   2018年10月13日 下午5:10:51   
 *     
 * @Copyright: 2018 
 *
 */
public class ConstantUtil {
	public static final String BROKER_URL = ActiveMQConnection.DEFAULT_BROKER_URL;
	public static final String TITLE = "DRJ";
}
2、傳送類

    package com.dairujie.send;
    
    import javax.jms.Connection;
    import javax.jms.ConnectionFactory;
    import javax.jms.Destination;
    import javax.jms.JMSException;
    import javax.jms.MessageProducer;
    import javax.jms.Session;
    import javax.jms.TextMessage;
    
    import org.apache.activemq.ActiveMQConnectionFactory;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import com.dairujie.utils.ConstantUtil;
    
    /**
     * 
     * @ClassName: MqSender
     * @Description:TODO(訊息傳送者)
     * @author: drj
     * @date: 2018年10月7日 下午4:16:03
     * 
     * @Copyright: 2018
     *
     */
    public class MqSender {
    	private final static Logger logger = (Logger) LoggerFactory.getLogger(MqSender.class);
    
    	public static void main(String[] args) {
    		// 初始化連線工廠       
    		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ConstantUtil.BROKER_URL);// 獲得連線     
    		Connection conn = null;
    		Session session = null;
    		MessageProducer producer = null;
    		try {
    			conn = connectionFactory.createConnection();
    			conn.start();
    			// 建立Session，此方法第一個引數表示會話是否在事務中執行，true的話 第二個引數無效。第二個引數設定會話的應答模式
    			//  AUTO_ACKNOWLEDGE 當客戶成功從recrive 返回時 自動確認客戶收到訊息。
    			// CLIENT_ACKNOWLEDGE    message.acknowledge(); 可以將全部消費的資訊提交  
    			session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
    			// 建立佇列     
    			Destination dest = session.createQueue(ConstantUtil.TITLE);
    			// 通過session可以建立訊息的生產者       
    			producer = session.createProducer(dest);
    			for (int i = 0; i < 5; i++) {// 初始化一個mq訊息           
    				TextMessage message = session.createTextMessage("HELLO WOLRD" + i);
    				// 傳送訊息           
    				producer.send(message);
    			}
    
    			// 關閉mq連線       
    		} catch (JMSException e) {
    			logger.error("ERROR IS " + e);
    		} finally {
    			if (session != null) {
    				try {
    					//session.commit();//createSession(true, Session.AUTO_ACKNOWLEDGE);第一個引數是true需要提交
    					session.close();
    				} catch (JMSException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    
    			}
    			if (producer != null) {
    				try {
    					producer.close();
    				} catch (JMSException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    			if (conn != null) {
    				try {
    					conn.close();
    				} catch (JMSException e) {
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			}
    		}
    	}
    }
 

3、消費類

package com.dairujie.send;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.dairujie.utils.ConstantUtil;

/**
 * 
 * @ClassName: MqSender
 * @Description:TODO(訊息傳送者)
 * @author: drj
 * @date: 2018年10月7日 下午4:16:03
 * 
 * @Copyright: 2018
 *
 */
public class MqSender {
	private final static Logger logger = (Logger) LoggerFactory.getLogger(MqSender.class);

	public static void main(String[] args) {
		// 初始化連線工廠       
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ConstantUtil.BROKER_URL);// 獲得連線     
		Connection conn = null;
		Session session = null;
		MessageProducer producer = null;
		try {
			conn = connectionFactory.createConnection();
			conn.start();
			// 建立Session，此方法第一個引數表示會話是否在事務中執行，true的話 第二個引數無效。第二個引數設定會話的應答模式
			//  AUTO_ACKNOWLEDGE 當客戶成功從recrive 返回時 自動確認客戶收到訊息。
			// CLIENT_ACKNOWLEDGE    message.acknowledge(); 可以將全部消費的資訊提交  
			session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
			// 建立佇列     
			Destination dest = session.createQueue(ConstantUtil.TITLE);
			// 通過session可以建立訊息的生產者       
			producer = session.createProducer(dest);
			for (int i = 0; i < 5; i++) {// 初始化一個mq訊息           
				TextMessage message = session.createTextMessage("HELLO WOLRD" + i);
				// 傳送訊息           
				producer.send(message);
			}

			// 關閉mq連線       
		} catch (JMSException e) {
			logger.error("ERROR IS " + e);
		} finally {
			if (session != null) {
				try {
					//session.commit();//createSession(true, Session.AUTO_ACKNOWLEDGE);第一個引數是true需要提交
					session.close();
				} catch (JMSException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

			}
			if (producer != null) {
				try {
					producer.close();
				} catch (JMSException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			if (conn != null) {
				try {
					conn.close();
				} catch (JMSException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}
	}
}
 

執行截圖