ActiveMQ与Spring的整合之异步发送电子邮件

桃扇骨 2022-07-15 10:07 218阅读 0赞

1、ActiveMQ与Spring整合,**消息生产方的代码**

1.1    项目的目录

![20161112140433433][]

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">
 
 	
 	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
 		
 		<property name="brokerURL" value="${activemq.brokerURL}" />
 		<property name="userName" value="${activemq.userName}"></property>
 		<property name="password" value="${activemq.password}"></property>
 	</bean>
 
 	
 	<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
 		<property name="connectionFactory" ref="targetConnectionFactory" />
 		<property name="maxConnections" value="${activemq.pool.maxConnections}" />
 	</bean>
 
 	
 	<bean id="connectionFactory"
 		class="org.springframework.jms.connection.SingleConnectionFactory">
 		
 		<property name="targetConnectionFactory" ref="pooledConnectionFactory" />
 	</bean>
 	
 	
 	
 	
 	<bean id="mailQueue" class="org.apache.activemq.command.ActiveMQTopic">
 		<constructor-arg>
 			<value>${activemq.queueName}</value>
 		</constructor-arg>
 	</bean>
 	
 	
 	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
 		
 		<property name="connectionFactory" ref="connectionFactory" />
 		<property name="defaultDestination" ref="mailQueue"></property>
 	</bean>
 
 </beans>

1.4   spring-context.xml

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;
 	}
 
 	/**
 	 * 方法名称：发送邮件信息对象 
 	 * 概要说明：发送邮件信息对象 
 	 * 
 	 * @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>
 	
 	
 	<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    项目的目录

![20161112141044910][]

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">
 
 
 	
 	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
 		
 		<property name="brokerURL" value="${activemq.brokerURL}" />
 		<property name="userName" value="${activemq.userName}"></property>
 		<property name="password" value="${activemq.password}"></property>
 	</bean>
 
 	
 	<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
 		<property name="connectionFactory" ref="targetConnectionFactory" />
 		<property name="maxConnections" value="${activemq.pool.maxConnections}" />
 	</bean>
 
 	
 	<bean id="connectionFactory"
 		class="org.springframework.jms.connection.SingleConnectionFactory">
 		
 		<property name="targetConnectionFactory" ref="pooledConnectionFactory" />
 	</bean>
 
 	
 
 	
 	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
 		
 		<property name="connectionFactory" ref="connectionFactory" />
 		<property name="defaultDestinationName" value="${activemq.queueName}"></property>
 	</bean>
 
 	
 
 	<bean id="mailQueue" class="org.apache.activemq.command.ActiveMQTopic">
 		<constructor-arg>
 			<value>${activemq.queueName}</value>
 		</constructor-arg>
 	</bean>
 
 	
 	<bean id="mailQueueMessageListener" class="bhz.mq.MailQueueMessageListener"></bean>
 
 	
 	<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   **发送邮箱的配置**

2.8    spring-context.xml

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;
 
 	/**
 	 * 方法名称：发送邮件 
 	 * 概要说明：发送邮件 
 	 * 
 	 * @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、[代码下载][Link 1]

[20161112140433433]: /images/20220715/60bcc3fddac84993957409be5caa04aa.png
[20161112141044910]: /images/20220715/d94cc10b92fc4d478d5ab3cf327c12ec.png
[Link 1]: http://download.csdn.net/detail/zbw18297786698/9680936