1.activemq上傳、解壓安裝

解壓安裝

2.移動activemq到指定目錄 

3.配置activemq埠

ActiveMQ 需要用到兩個埠

一個是訊息通訊的埠（預設為 61616）

 一個是管理控制檯埠（預設為 8161）可在conf/jetty.xml 中修改，如下

指定jetty埠

指定通訊埠

4.在防火牆中開啟相應埠

5.啟動activemq

在瀏覽器開啟訪問

以admin/admin登入

登入成功

6.安全配置（訊息安全）

 ActiveMQ 如果不加入安全機制的話，任何人只要知道訊息服務的具體地址(包括 ip，埠，訊息地址 [佇列或者主題地址 ]， )，都可以肆無忌憚的傳送、接收訊息。關於

ActiveMQ 的訊息安全配置策略有多種，我們以簡單授權配置為例：在conf/activemq.xml 檔案中在broker 標籤最後加入以下內容即可：

定義了一個yixq 使用者，密碼為yxq123456，角色為users,admins

設定 admin 的使用者名稱和密碼:

確保 authenticate 的值為true（預設）

控制檯的登入使用者名稱密碼儲存在 conf/jetty-realm.properties 檔案中,內容如下

注意:使用者名稱和密碼的格式是
使用者名稱 :

重啟，再登入就是新設定的密碼登入

7.加入環境變數:

8.設定開機啟動：

# vi /etc/rc.local

加入:

su - yxq -c '/home/yxq/app/activemq/bin/activemq start'

MQ 訊息生產者也與訊息消費者的 Demo 樣例講解

訊息提供方:

package com.edu.demo.mqtest;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.edu.demo.mqtest.MQProducer;
import com.edu.demo.mqtest.params.MailParam;

public class MQProducerTest {
	private static final Log log = LogFactory.getLog(MQProducerTest.class);

	public static void main(String[] args) {
		try {
			ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/spring-context.xml");
			context.start();

			MQProducer mqProducer = (MQProducer) context.getBean("mqProducer");
			// 郵件傳送
			MailParam mail = new MailParam();
			mail.setTo("
 
[email protected]");
			mail.setSubject("ActiveMQ測試");
			mail.setContent("通過ActiveMQ非同步傳送郵件！");

			mqProducer.sendMessage(mail);

			context.stop();
		} catch (Exception e) {
			log.error("==>MQ context start error:", e);
			System.exit(0);
		} finally {
			log.info("===>System.exit");
			System.exit(0);
		}
	}
}

package com.edu.demo.mqtest;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.edu.demo.mqtest.MQProducer;
import com.edu.demo.mqtest.params.MailParam;

public class MQProducerTest {
	private static final Log log = LogFactory.getLog(MQProducerTest.class);

	public static void main(String[] args) {
		try {
			ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/spring-context.xml");
			context.start();

			MQProducer mqProducer = (MQProducer) context.getBean("mqProducer");
			// 郵件傳送
			MailParam mail = new MailParam();
			mail.setTo("[email protected]");
			mail.setSubject("ActiveMQ測試");
			mail.setContent("通過ActiveMQ非同步傳送郵件！");

			mqProducer.sendMessage(mail);

			context.stop();
		} catch (Exception e) {
			log.error("==>MQ context start error:", e);
			System.exit(0);
		} finally {
			log.info("===>System.exit");
			System.exit(0);
		}
	}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd  
           http://www.springframework.org/schema/aop   
           http://www.springframework.org/schema/aop/spring-aop-3.2.xsd  
           http://www.springframework.org/schema/tx  
           http://www.springframework.org/schema/tx/spring-tx-3.2.xsd  
           http://www.springframework.org/schema/context  
           http://www.springframework.org/schema/context/spring-context-3.2.xsd"
	default-autowire="byName" default-lazy-init="false">	
	
	<!-- 採用註釋的方式配置bean -->
	<context:annotation-config />

	<!-- 配置要掃描的包 -->
	<context:component-scan base-package="com.edu.demo" />

	<!-- 讀入配置屬性檔案 -->
	<context:property-placeholder location="classpath:mq.properties" />

	<!-- proxy-target-class預設"false",更改為"ture"使用CGLib動態代理 -->
	<aop:aspectj-autoproxy proxy-target-class="true" />	
	
	<import resource="spring-mq.xml" />
</beans>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-3.2.xsd  
           http://www.springframework.org/schema/aop   
           http://www.springframework.org/schema/aop/spring-aop-3.2.xsd  
           http://www.springframework.org/schema/tx  
           http://www.springframework.org/schema/tx/spring-tx-3.2.xsd  
           http://www.springframework.org/schema/context  
           http://www.springframework.org/schema/context/spring-context-3.2.xsd"
	default-autowire="byName" default-lazy-init="false">	
	
	<!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 -->
	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<!-- ActiveMQ服務地址 -->
        <property name="brokerURL" value="tcp://192.168.1.121:61616" />
        <property name="userName" value="yixq"></property>
        <property name="password" value="yxq123456"></property> 
	</bean>

    <!-- 
    	ActiveMQ為我們提供了一個PooledConnectionFactory，通過往裡面注入一個ActiveMQConnectionFactory
    	可以用來將Connection、Session和MessageProducer池化，這樣可以大大的減少我們的資源消耗。
    	要依賴於 activemq-pool包
     -->
	<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
		<property name="connectionFactory" ref="targetConnectionFactory" />
		<property name="maxConnections" value="10" />
	</bean>

	<!-- Spring用於管理真正的ConnectionFactory的ConnectionFactory -->
	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
		<!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->
		<property name="targetConnectionFactory" ref="pooledConnectionFactory" />
	</bean>
	
	<!-- Spring提供的JMS工具類，它可以進行訊息傳送、接收等 -->
	
	<!-- 佇列模板 -->
	<bean id="activeMqJmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
	    <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->  
	    <property name="connectionFactory" ref="connectionFactory"/>  
	    <property name="defaultDestinationName" value="com.edu.mqtest.v1"></property>
	</bean> 

</beans>

pom.xml配置

package com.edu.demo.mqtest;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.edu.demo.mqtest.MQProducer;
import com.edu.demo.mqtest.params.MailParam;

public class MQProducerTest {
	private static final Log log = LogFactory.getLog(MQProducerTest.class);

	public static void main(String[] args) {
		try {
			ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/spring-context.xml");
			context.start();

			MQProducer mqProducer = (MQProducer) context.getBean("mqProducer");
			// 郵件傳送
			MailParam mail = new MailParam();
			mail.setTo("[email protected]");
			mail.setSubject("ActiveMQ測試");
			mail.setContent("通過ActiveMQ非同步傳送郵件！");

			mqProducer.sendMessage(mail);

			context.stop();
		} catch (Exception e) {
			log.error("==>MQ context start error:", e);
			System.exit(0);
		} finally {
			log.info("===>System.exit");
			System.exit(0);
		}
	}
}