2. 程式人生 > >ActiveMQ與Spring進行整合

ActiveMQ與Spring進行整合

阿新 • • 發佈：2018-12-23

                                ActiveMQ與Spring進行整合

 

ActiveMQ可以很輕鬆的與Spring進行整合，Spring提供了一系列的介面類。
整合的理由：訊息中介軟體，非同步處理任務的機制，比如非同步消費資料、非同步傳送郵件、非同步做查詢操作等

非同步傳送郵件的例子


       provider系統


Mail.java

package bhz.entity;

public class Mail {

	/** 發件人 **/
	private String from;
	/** 收件人 **/
	private String to;
	/** 主題 **/
	private String subject;
	/** 郵件內容 **/
	private String content;
	
	public Mail(){}
	
	public Mail(String from, String to, String subject, String content) {
		super();
		this.from = from;
		this.to = to;
		this.subject = subject;
		this.content = content;
	}
	
	public String getFrom() {
		return from;
	}
	public void setFrom(String from) {
		this.from = from;
	}
	public String getTo() {
		return to;
	}
	public void setTo(String to) {
		this.to = to;
	}
	public String getSubject() {
		return subject;
	}
	public void setSubject(String subject) {
		this.subject = subject;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	
	

}

MQProducer.java
 


package bhz.mq;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;


import bhz.entity.Mail;

import com.alibaba.fastjson.JSONObject;
import org.springframework.stereotype.Service;


/**
 * <B>系統名稱：</B><BR>
 * <B>模組名稱：</B><BR>
 * <B>中文類名：</B><BR>
 * <B>概要說明：</B><BR>
 * @author bhz（Alienware）
 * @since 2014年7月2日
 */
@Service("mqProducer")
public class MQProducer {
	
	private JmsTemplate jmsTemplate;
	
	public JmsTemplate getJmsTemplate() {
		return jmsTemplate;
	}
	
	@Autowired
	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}

	/**
	 * <B>方法名稱：</B>傳送郵件資訊物件<BR>
	 * <B>概要說明：</B>傳送郵件資訊物件<BR>
	 * @param mail
	 */
	public void sendMessage(final Mail mail) {
		jmsTemplate.send(new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {
				return session.createTextMessage(JSONObject.toJSONString(mail));
			}
		});
	}

}

 
TestProducer.java

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import bhz.entity.Mail;
import bhz.mq.MQProducer;


/**
 * <B>系統名稱：</B><BR>
 * <B>模組名稱：</B><BR>
 * <B>中文類名：</B><BR>
 * <B>概要說明：</B><BR>
 * @author bhz（Alienware）
 * @since 2014年7月2日
 */
@ContextConfiguration(locations = {"classpath:/spring-context.xml" })
@RunWith(SpringJUnit4ClassRunner.class)
public class TestProducer {
	
	@Autowired
	private MQProducer mqProducer;
	
	@Test
	public void send(){
		Mail mail = new Mail();
		mail.setTo("[email protected]");
		mail.setSubject("非同步傳送郵件");
		mail.setContent("Hi,This is a message!");
														
		this.mqProducer.sendMessage(mail);
		System.out.println("傳送成功..");		
		
	}

}

config.properties
 

## ActiveMQ Config
activemq.brokerURL=tcp\://192.168.43.*\:61616
activemq.userName=bhz
activemq.password=bhz
activemq.pool.maxConnections=10
#queueName
activemq.queueName=mailqueue

log4j.properties

log4j.rootLogger=INFO, console, file

log4j.appender.console=org.apache.log4j.ConsoleAppender
log4j.appender.console.layout=org.apache.log4j.PatternLayout
log4j.appender.console.layout.ConversionPattern=%d %p [%c] - %m%n

log4j.appender.file=org.apache.log4j.DailyRollingFileAppender
#log4j.appender.file.File=D:/002_developer/workspace_001/zcmoni.log
log4j.appender.file.layout=org.apache.log4j.PatternLayout
log4j.appender.file.layout.ConversionPattern=%d %p [%c] - %m%n

log4j.logger.org.springframework=WARN

spring-activemq.xml

<?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:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
            http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context-4.3.xsd"
	>

	<!-- 讀入配置屬性檔案 -->
	<context:property-placeholder location="classpath:config.properties" />
	<!-- 第三方MQ工廠: ConnectionFactory -->
	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<!-- ActiveMQ Address -->
        <property name="brokerURL" value="${activemq.brokerURL}" />
        <property name="userName" value="${activemq.userName}"></property>
        <property name="password" value="${activemq.password}"></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="${activemq.pool.maxConnections}" />
	</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="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
	    <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->  
	    <property name="connectionFactory" ref="connectionFactory"/>  
	    <property name="defaultDestinationName" value="${activemq.queueName}"></property>
	</bean> 

</beans>

spring-context.xml

<?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:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
           http://www.springframework.org/schema/context  
           http://www.springframework.org/schema/context/spring-context-4.3.xsd"
	default-autowire="byName" default-lazy-init="false">

	
	<!-- 註解配置 -->
	<context:annotation-config />

	<!-- 掃描包起始位置 -->
	<context:component-scan base-package="bhz.mq" />

	<import resource="classpath:spring-activemq.xml" />
</beans>

pom.xml
 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>activemqdemo</groupId>
    <artifactId>provider</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!-- 設定公共屬性，可以被引用 ${attribute} -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <junit.version>4.12</junit.version>
        <spring.version>4.3.21.RELEASE</spring.version>
        <httpclient.version>4.3.1</httpclient.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-oxm</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.11.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-pool</artifactId>
            <version>5.11.1</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>0.2.9</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.7.1</version>
        </dependency>
        <dependency>
            <groupId>org.codehaus.jackson</groupId>
            <artifactId>jackson-mapper-asl</artifactId>
            <version>1.9.11</version>
        </dependency>
        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
            <version>1.2.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.3.1</version>
        </dependency>
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>2.4</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient-cache</artifactId>
            <version>${httpclient.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>${httpclient.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpcore</artifactId>
            <version>${httpclient.version}</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.1.26</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.9</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>jul-to-slf4j</artifactId>
            <version>1.7.6</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>jcl-over-slf4j</artifactId>
            <version>1.7.6</version>
        </dependency>
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>jstl</artifactId>
            <version>1.2</version>
        </dependency>
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>servlet-api</artifactId>
            <version>3.0-alpha-1</version>
            <scope>provided</scope>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>${junit.version}</version>
            <scope>test</scope>
        </dependency>
       

    </dependencies>

</project>


consumer系統
 

 

Mail.java

package bhz.entity;

public class Mail {

	/** 發件人 **/
	private String from;
	/** 收件人 **/
	private String to;
	/** 主題 **/
	private String subject;
	/** 郵件內容 **/
	private String content;
	
	public Mail(){}
	
	public Mail(String from, String to, String subject, String content) {
		super();
		this.from = from;
		this.to = to;
		this.subject = subject;
		this.content = content;
	}
	
	public String getFrom() {
		return from;
	}
	public void setFrom(String from) {
		this.from = from;
	}
	public String getTo() {
		return to;
	}
	public void setTo(String to) {
		this.to = to;
	}
	public String getSubject() {
		return subject;
	}
	public void setSubject(String subject) {
		this.subject = subject;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
	
	

}


MailQueueMessageListener.java


package bhz.mq;

import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.listener.SessionAwareMessageListener;
import org.springframework.stereotype.Component;

import bhz.entity.Mail;
import bhz.service.MailService;

import com.alibaba.fastjson.JSONObject;

/**
 * <B>系統名稱：</B><BR>
 * <B>模組名稱：</B><BR>
 * <B>中文類名：</B><BR>
 * <B>概要說明：</B><BR>
 * @author bhz（Alienware）
 * @since 2014年7月2日
 */
@Component
public class MailQueueMessageListener implements SessionAwareMessageListener<Message> {

	@Autowired
	private JmsTemplate jmsTemplate;
	@Autowired
	private Destination mailQueue;
	@Autowired
	private MailService mailService;

	public synchronized void onMessage(Message message, Session session) {
		try {
			TextMessage msg = (TextMessage) message;
			final String ms = msg.getText();
			System.out.println("收到訊息：" + ms);
			//轉換成相應的物件
			Mail mail = JSONObject.parseObject(ms, Mail.class);
			if (mail == null) {
				return;
			}
			try {
				//執行傳送業務
				mailService.mailSend(mail);
				
			} catch (Exception e) {
				// 傳送異常，重新放回佇列
//				jmsTemplate.send(mailQueue, new MessageCreator() {
//					@Override
//					public Message createMessage(Session session) throws JMSException {
//						return session.createTextMessage(ms);
//					}
//				});
				e.printStackTrace();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}


MailService.java

package bhz.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.mail.MailException;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service;

import bhz.entity.Mail;

@Service("mailService")
public class MailService {

	@Autowired
	private JavaMailSender mailSender;
	@Autowired
	private SimpleMailMessage simpleMailMessage;
	@Autowired
	private ThreadPoolTaskExecutor threadPool;

	/**
	 * <B>方法名稱：</B>傳送郵件<BR>
	 * <B>概要說明：</B>傳送郵件<BR>
	 * @param mail
	 */
	public void mailSend(final Mail mail) {
		threadPool.execute(new Runnable() {
			public void run() {
				try {
					System.out.println(simpleMailMessage.getFrom());
					System.out.println(mail.getTo());
					System.out.println(mail.getContent());
//					simpleMailMessage.setFrom(simpleMailMessage.getFrom());
//					simpleMailMessage.setTo(mail.getTo());
//					simpleMailMessage.setSubject(mail.getSubject());
//					simpleMailMessage.setText(mail.getContent());
//					mailSender.send(simpleMailMessage);
				} catch (MailException e) {
					e.printStackTrace();
					throw e;
				}
			}
		});
	}
}

TestConsumer.java

import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * <B>系統名稱：</B><BR>
 * <B>模組名稱：</B><BR>
 * <B>中文類名：</B><BR>
 * <B>概要說明：</B><BR>
 * @author bhz（Alienware）
 * @since 2014年7月2日
 */
public class TestConsumer {

	public static void main(String[] args) {
		try {
			ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "spring-context.xml" });
			context.start();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}


config.properties

## ActiveMQ Config
activemq.brokerURL=tcp\://192.168.43.*\:61616
activemq.userName=bhz
activemq.password=bhz
activemq.pool.maxConnections=10
#queueName
activemq.queueName=mailqueue

## SMTP Configuration
mail.host=smtp.163.com
##mail.port=21
mail.username=***@163.com
mail.password=
mail.smtp.auth=true
mail.smtp.timeout=30000
mail.default.from=***@163.com



spring-activemq.xml

<?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:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
            http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context-4.3.xsd"
	>

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

	<!-- 第三方MQ工廠: ConnectionFactory -->
	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
		<!-- ActiveMQ服務地址 -->
		<property name="brokerURL" value="${activemq.brokerURL}" />
		<property name="userName" value="${activemq.userName}"></property>
		<property name="password" value="${activemq.password}"></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="${activemq.pool.maxConnections}" />
	</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="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
		<!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->
		<property name="connectionFactory" ref="connectionFactory"/>
		<property name="defaultDestinationName" value="${activemq.queueName}"></property>
	</bean>

	<!--這個是目的地:mailQueue -->
	<bean id="mailQueue" class="org.apache.activemq.command.ActiveMQQueue">
		<constructor-arg>
			<value>${activemq.queueName}</value>
		</constructor-arg>
	</bean>

	<!-- 配置自定義監聽：MessageListener -->
	<bean id="mailQueueMessageListener" class="bhz.mq.MailQueueMessageListener"></bean>

	<!-- 將連線工廠、目標對了、自定義監聽注入jms模板 -->
	<bean id="sessionAwareListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
		<property name="connectionFactory" ref="connectionFactory" />
		<property name="destination" ref="mailQueue" />
		<property name="messageListener" ref="mailQueueMessageListener" />
	</bean>
</beans>


spring-context.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans  
           http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
           http://www.springframework.org/schema/aop
           http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
           http://www.springframework.org/schema/context  
           http://www.springframework.org/schema/context/spring-context-4.3.xsd"
	default-autowire="byName" default-lazy-init="false">

	
	<!-- 註解配置 -->
	<context:annotation-config />

	<!-- 掃描包起始位置 -->
	<context:component-scan base-package="bhz" />
	<!-- proxy-target-class預設"false",更改為"ture"使用CGLib動態代理 -->
	<aop:aspectj-autoproxy proxy-target-class="true" />
	<import resource="classpath:spring-activemq.xml" />
	<import resource="classpath:spring-mail.xml" />
</beans>


spring-mail.xml

<?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:context="http://www.springframework.org/schema/context"

	xsi:schemaLocation="http://www.springframework.org/schema/beans
	 http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
	   http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd"
	   >
	<!-- 讀入配置屬性檔案 -->
	<context:property-placeholder location="classpath:config.properties" />


	<!-- Spring提供的傳送電子郵件的高階抽象類 -->
	<bean id="mailSender" class="org.springframework.mail.javamail.JavaMailSenderImpl">
		<property name="host" value="${mail.host}" />
		<property name="username" value="${mail.username}" />
		<property name="password" value="${mail.password}" />
		<property name="defaultEncoding" value="UTF-8"></property>
		<property name="javaMailProperties">
			<props>
				<prop key="mail.smtp.auth">${mail.smtp.auth}</prop>
				<prop key="mail.smtp.timeout">${mail.smtp.timeout}</prop>
			</props>
		</property>
	</bean>

	<bean id="simpleMailMessage" class="org.springframework.mail.SimpleMailMessage">
		<property name="from">
			<value>${mail.default.from}</value>
		</property>
	</bean>
	
	<!-- 配置執行緒池 -->
	<bean id="threadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
		<!-- 執行緒池維護執行緒的最少數量 -->
		<property name="corePoolSize" value="5" />
		<!-- 執行緒池維護執行緒所允許的空閒時間 -->
		<property name="keepAliveSeconds" value="30000" />
		<!-- 執行緒池維護執行緒的最大數量 -->
		<property name="maxPoolSize" value="50" />
		<!-- 執行緒池所使用的緩衝佇列 -->
		<property name="queueCapacity" value="100" />
	</bean>

</beans>


pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>activemqdemo</groupId>
    <artifactId>consumer</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!-- 設定公共屬性，可以被引用 ${attribute} -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <junit.version>4.12</junit.version>
        <spring.version>4.3.21.RELEASE</spring.version>
        <httpclient.version>4.3.1</httpclient.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>${spring.version}</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-oxm</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.11.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-pool</artifactId>
            <version>5.11.1</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>0.2.9</version>
        </dependency>
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.7.1</version>
        </dependency>
        <dependency>
            <groupId>org.codehaus.jackson</groupId>
            <artifactId>jackson-mapper-asl</artifactId>
            <version>1.9.11</version>
        </dependency>
        <dependency>
            <groupId>commons-fileupload</groupId>
            <artifactId>commons-fileupload</artifactId>
            <version>1.2.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-lang3</artifactId>
            <version>3.3.1</version>
        </dependency>
        <dependency>
            <groupId>commons-io</groupId>
            <artifactId>commons-io</artifactId>
            <version>2.4</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient-cache</artifactId>
            <version>${httpclient.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>${httpclient.version}</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpcore</artifactId>
            <version>${httpclient.version}</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.1.26</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.9</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>jul-to-slf4j</artifactId>
            <version>1.7.6</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>jcl-over-slf4j</artifactId>
            <version>1.7.6</version>
        </dependency>
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>jstl</artifactId>
            <version>1.2</version>
        </dependency>
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>servlet-api</artifactId>
            <version>3.0-alpha-1</version>
            <scope>provided</scope>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>${junit.version}</version>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>javax.mail</groupId>
            <artifactId>mail</artifactId>
            <version>1.4.4</version>
        </dependency>

    </dependencies>

</project>

 

相關推薦

ActiveMQ與Spring進行整合

                                ActiveMQ與Spring進行整合   Activ

activemq 學習系列(五) activemq 與 spring boot 整合

-a pool autowire mapping pri control ESS fin tid activemq 與 spring boot 整合 1、添加依賴 <dependency> <groupId>

讓Struts2與Spring進行整合原因及原理

Struts2與Spring進行整合的根本目的就是要讓 Spring為Struts2的Action注入所需的資源物件，它們整合的原理則是隻要匯入了struts2的spring外掛包，不需要進行任何額外的配置，Struts2的Action例項物件將由struts2的spr

04.ActiveMQ與Spring JMS整合

1.SpringJMS核心介面介紹 1.JmsTemplate JmsTemplate: 是Spring自身提供，只需向Spring容器內註冊這個類即可，就可以使用JmsTemplate類物件方便的操作JMS，下面介紹他常用的方法。     注意：JmsTemplate類是執行緒安全的，可以在整個應

ActiveMQ與Spring的整合之非同步傳送電子郵件

1、ActiveMQ與Spring整合,訊息生產方的程式碼       1.1    專案的目錄       1.2   config.properties  ## ActiveMQ Config activemq.brokerURL=tcp\://192.168.2.

ActiveMQ與spring整合

arc 整合 schema emp jar dep mqc and cti 第一步：引用相關的jar包 <dependency> <groupId>org.springframework</groupId

javaEE ActiveMQ，ActiveMQ與Spring整合

需要先安裝ActiveMQ服務,並啟動。 生產者： applicationContext.xml（Spring配置檔案,配置工廠,配置生產者）： <?xml version="1.0" encoding="UTF-8"?> <beans xml

jms之activeMQ與spring整合進階-實現一種負載均衡

="http://www.springframework.org/schema/beans            http://www.springframework.org/schema/beans/spring-beans-2.5.xsd            http://www.springframe

activeMQ訊息中介軟體的與spring的整合

activemq是基於jetty服務容器的，可在原始碼中發現。 1.maven依賴jar <!-- ActiveMQ --> <dependency> <groupId>org.apache.activemq</group

activeMQ開發筆記，activeMQy與Spring框架整合

MQ開發其實很簡單： 本文以最新版本的ActiveMQ為例子，介紹了安裝和開發第一個MQ程式。 準備環境，JDK8，activeMQ 5.14.3，WIN7測試環境，Spring 4.3.4 首先是安裝 : 安裝MQ非常簡單，下載連結：https://activemq

ActiveMQ與Spring整合:(3)訊息監聽器

        JMS監聽器有三種訊息監聽器實現：MessageListener，SessionAwareMessageListener，MessageListenerAdapter。訊息接受者只需要實現這些介面就可以非同步接收訊息。 1、實現MessageListener

cas4.2.7與shiro進行整合

exce cor lec ces nco Coding schema enc pattern 準備工作 　　cas單點登錄開始前準備，請參考cas4.2.7實現單點登錄。 與shiro進行整合 　　註：準備工作的基礎上，對cas客戶端進行如下改進。 　　引入相關ja

MyBatis與Spring的整合

mybatis 目錄 user 準備工作 事務管理 項目 pac 映射文件 pla 1.Spring整合MyBatis的準備工作 在項目中加入Spring、MyBatis及整合相關的JAR文件 建立開發目錄結構，創建實體類 創建數據訪問接口（UserMapper） 配置S

WebService--CXF與Spring的整合（jaxws:endpoint形式配置）

tid archetype 全路徑 systems hide onf -o hot conf 一、CXF與Spring整合（jaxws:endpoint形式配置） 工具要點：idea、maven 1.新建一個maven項目 <?xml version="1.0"

activeMQ入門+spring boot整合activeMQ

應用 col print ret listener listen request system pub 最近想要學習MOM（消息中間件：Message Oriented Middleware），就從比較基礎的activeMQ學起，rabbitMQ、zeroMQ、rocket

Elastic-Job原始碼解析(一)之與Spring完美整合

看過小編寫SpringFramework原始碼解析的同學應該對Spring支援自定義標籤還有點印象吧，沒有的話我們回顧下，然後看看Elastic-Job是如何巧妙的利用自定義標籤生成Job任務的吧。請注意這裡用了一個巧妙關鍵字。我們看它如何巧妙的吧。 Spring自定義

FastDFS與spring boot整合

在專案Pom當中加入依賴 Maven依賴為 com.github.tobato fastdfs-client 1.26.3 將Fdfs配置引入專案 將FastDFS-Client客戶端引入本地化專案的方式非常簡單，在SpringBoot專案/src/[com.xxx.

JMeter 如何與 MySQL 進行整合測試

做效能測試定位瓶頸的時候，定位到是因為某些 SQL 語句的查詢慢所影響的，此時我們提出優化方案，肯定希望驗證下優化後的 SQL，此時需要藉助 JMeter 的 JDBC 請求，那麼我們就需要學習 JMeter 如何與 MySQL 進行整合測試。 環境準備 除了 JMeter 外，還需要

JavaEE MyBatis與Spring的整合——基於mapper介面方式開發（教材學習筆記）

在MyBatis與Spring的整合開發中雖然可以通過傳統的DAO開發方式，但是採用DAO方式會產生大量的重複程式碼，因此學習另外一種程式設計方式就很重要了，即Mapper介面程式設計（本章程式碼是基於上一篇部落格的點這裡） 一、基於MapperFactoryBean的整合 Mapper

springboot與junit進行整合

springboot與junit進行整合 引入junit的起步依賴 <!--測試的起步依賴--> <dependency> <groupId>org.springframework.boot</groupId>