ActiveMQ与Spring的整合之异步发送电子邮件
2016-11-12 14:20
302 查看
1、ActiveMQ与Spring整合,消息生产方的代码
1.1 项目的目录
1.2 config.properties
1.3 spring-activemq.xml
1.4 spring-context.xml
1.5 log4j.properties
1.6 Mail.java的代码
1.8 TestProducer.java的代码
1.9 pom.xml的文件
2、ActiveMQ与Spring整合,消息消费方的代码
2.1 项目的目录
2.2 Mail.java 见上面
2.3 MailQueueMessageListener.java 实现异步发送消息的监听器，很重要
2.4 log4j.properties 见上面
2.5 config.properties 加入了邮箱相关的配置（用的是163邮箱）
2.6 spring-activemq.xml 与上面的区别，主要在于加入了监听器，用于异步消费消息
2.7 spring-mail.xml 发送邮箱的配置
2.8 spring-context.xml
2.9 MailService.java
2.10 TestConsumer.java
3、代码下载
1.1 项目的目录
1.2 config.properties
## ActiveMQ Config activemq.brokerURL=tcp\://192.168.2.104\:61616 activemq.userName=zhangsan activemq.password=123 activemq.pool.maxConnections=10 #queueName activemq.queueName=mailqueue
1.3 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: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"> <!-- 第三方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> <!--这个是目的地:mailQueue --> <!-- 使用Queue方式 --> <!-- <bean id="mailQueue" class="org.apache.activemq.command.ActiveMQQueue"/> --> <!-- 使用Topic方式 --> <bean id="mailQueue" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg> <value>${activemq.queueName}</value> </constructor-arg> </bean> <!-- Spring提供的JMS工具类，它可以进行消息发送、接收等 --> <!-- 队列模板 --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 --> <property name="connectionFactory" ref="connectionFactory" /> <property name="defaultDestination" ref="mailQueue"></property> </bean> </beans>
1.4 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: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"> <!-- 读入配置属性文件 --> <context:property-placeholder location="classpath:config.properties" /> <!-- 注释配置 --> <context:annotation-config /> <!-- 扫描包起始位置 --> <context:component-scan base-package="bhz" /> <import resource="classpath:spring-activemq.xml" /> </beans>
1.5 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
1.6 Mail.java的代码
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;
}
} 1.7 MQProducer.java的代码 @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));
}
});
}
}1.8 TestProducer.java的代码
@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("921722376@qq.com");
mail.setSubject("异步发送邮件");
mail.setContent("Hi,This is a message!");
this.mqProducer.sendMessage(mail);
System.out.println("发送成功..");
}
}1.9 pom.xml的文件
<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>activemq</groupId> <artifactId>activemq-provider</artifactId> <version>0.0.1-SNAPSHOT</version> <!-- 设置公共属性，可以被引用 ${attribute} --> <!-- 设置公共属性，可以被引用 ${attribute} --> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <junit.version>4.11</junit.version> <spring.version>3.2.3.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.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.2.8</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>1.1.1</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>4.3.2</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.10</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.5</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>2.5</version> <scope>provided</scope> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.21</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> </dependencies> <build> <finalName>activemq-provider</finalName> <plugins> <plugin> <artifactId>maven-compiler-plugin</artifactId> <configuration> <source>1.7</source> <target>1.7</target> <encoding>utf8</encoding> </configuration> </plugin> </plugins> </build> </project>
2、ActiveMQ与Spring整合,消息消费方的代码
2.1 项目的目录
2.2 Mail.java 见上面
2.3 MailQueueMessageListener.java 实现异步发送消息的监听器，很重要
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;
@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();
}
}
}2.4 log4j.properties 见上面
2.5 config.properties 加入了邮箱相关的配置（用的是163邮箱）
## ActiveMQ Configuration activemq.brokerURL=tcp\://192.168.2.104\:61616 activemq.userName=zhangsan activemq.password=123 activemq.pool.maxConnections=10 #queueName activemq.queueName=mailqueue ## SMTP Configuration mail.host=smtp.163.com ##mail.port=21 mail.username= 填写自己的163邮箱地址 mail.password= 填写自己的163邮箱密码 mail.smtp.auth=true mail.smtp.timeout=30000 mail.default.from=填写自己的163邮箱地址
2.6 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: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"> <!-- 第三方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/"/> --> <bean id="mailQueue" class="org.apache.activemq.command.ActiveMQTopic"> <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>
2.7 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: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" xmlns:cache="http://www.springframework.org/schema/cache" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-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/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.2.xsd"> <!-- 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>
2.8 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: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"> <!-- 读入配置属性文件 --> <context:property-placeholder location="classpath:config.properties" /> <!-- 注释配置 --> <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>
2.9 MailService.java
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 {
simpleMailMessage.setFrom(simpleMailMessage.getFrom());
simpleMailMessage.setTo(mail.getTo());
simpleMailMessage.setSubject(mail.getSubject());
simpleMailMessage.setText(mail.getContent());
// mailSender.send(simpleMailMessage);
//mailSender.send(simpleMailMessage);
//MimeMessage
mailSender.send(simpleMailMessage);
} catch (MailException e) {
e.printStackTrace();
throw e;
}
}
});
}
}2.10 TestConsumer.java
import org.springframework.context.support.ClassPathXmlApplicationContext;
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();
}
}
}3、代码下载
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- （转） RabbitMQ学习之spring整合发送异步消息
- 利用Spring与ActiveMQ整合发送、接收消息实例(Queue与Topic模式)
- （转）RabbitMQ学习之spring整合发送异步消息(注解实现)
- Spring整合activemq发送消息（发布/订阅）
- 学习淘淘商城第六十课（Spring与Activemq的整合及用JmsTemplate发送消息）
- ActiveMq与spring的整合--发送和接收消息
- RabbitMQ学习(十一)之spring整合发送异步消息
- spring整合ActiveMQ订阅模式(对象消息发送)
- Spring与ActiveMQ整合（多线程并发发送与接收消息）
- RabbitMQ学习之spring整合发送异步消息
- RabbitMQ入门-10-3（整合spring-发送异步消息注解实现）
- spring整合activemq发送MQ消息[Topic模式]实例，activemqmq
- RabbitMQ学习之spring整合发送异步消息(注解实现)
- spring整合activemq发送消息[queue类型]实例
- Spring ActiveMQ 整合（二）: 重发机制（消息发送失败后的重新发送）
- 关于做activemq整合spring时候的异步操作的bug
- ActiveMQ 整合 Spring 发送和接收消息
- spring整合ActiveMQ实现邮件发送
- Spring与ActiveMQ整合及用JmsTemplate发送消息
- 消息中间件之ActiveMQ整合Spring实现邮箱发送（四）