600字范文 > QQ企业邮箱+Spring+Javamail+ActiveMQ（发送企业邮件）

QQ企业邮箱+Spring+Javamail+ActiveMQ（发送企业邮件）

时间：2018-08-30 08:16:16

原来有个教程是关于Javamail的，但是那个是自己写Javamail的发送过程，这次不同的是：使用Spring的Mail功能，使用了消息队列。

先看一下设想的场景

不过本文重点不是消息队列，而是使用spring发送邮件。

首先针对于不会Maven和消息队列的小盆友们

依赖jar包：

spring系列jar包

Javamail

先建立一个封装Mail信息的类：很好理解，里面的成员变量代表（收件人，主题，内容）

package com.mq.entity;import java.io.Serializable;public class MailInfo implements Serializable {/*** */private static final long serialVersionUID = -5853264487189248317L;private String to;private String subject;private String content;public MailInfo() {}public MailInfo(String to, String subject, String content) {this.to = to;this.subject = subject;this.content = content;}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;}}

然后呢，在classpath下面整一个属性文件，email.properties

mail.account=用户名mail.pass=密码mail.host=smtp.mail.port=465mail.protocol=smtpmail.debug=truemail.smtp.auth=truemail.smtp.ssl.enable=true

注意：企业邮箱不用什么授权码，就是密码

然后classpath下建立spring配置文件。

然后写一个发送邮件类

package com.mq.mail;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.mail.SimpleMailMessage;import org.springframework.mail.javamail.JavaMailSender;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import org.ponent;import com.mq.entity.MailInfo;@Componentpublic class SendMail {@Autowiredprivate JavaMailSender javaMailSender;@Autowiredprivate SimpleMailMessage simpleMailMessage;@Autowiredprivate ThreadPoolTaskExecutor threadPoolTaskExecutor;public void send(final MailInfo mailInfo){threadPoolTaskExecutor.execute(new Runnable() {@Overridepublic void run() {try {simpleMailMessage.setTo(mailInfo.getTo());simpleMailMessage.setSubject(mailInfo.getSubject());simpleMailMessage.setText(mailInfo.getContent());javaMailSender.send(simpleMailMessage);} catch (Exception e) {e.printStackTrace();}}});}}

最后写一个测试类：

package com.mq.test;import org.springframework.context.support.ClassPathXmlApplicationContext;import com.mq.entity.MailInfo;import com.mq.mail.SendMail;public class TestMail {public static void main(String[] args) {ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("classpath:spring-mail.xml");app.start();MailInfo mailInfo = new MailInfo("XXX@", "这是主题", "这是内容");app.getBean(SendMail.class).send(mailInfo);app.close();}}

结果：

下面是Maven+消息队列的部分

我有两个工程，一个是生产者，一个是消费者。都是Maven的web工程。PS：这两个工程加入了mvc，因为本来想做个好玩的东西的，但是太忙了，先放下了，目前只有利用消息队列发送邮件的部分。这也是为啥依赖这么多的原因。

首先是生产者

Maven依赖：

<properties><spring.version>4.3.9.RELEASE</spring.version></properties><dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>${spring.version}</version><scope>test</scope></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-aop</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</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-jms</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-web</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-aspects</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-expression</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-messaging</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.0</version></dependency><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-pool</artifactId><version>5.15.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.35</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId><version>2.8.9</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.8.9</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-annotations</artifactId><version>2.8.9</version></dependency><dependency><groupId>javax.mail</groupId><artifactId>mail</artifactId><version>1.4.7</version></dependency><dependency><groupId>javax.servlet</groupId><artifactId>jstl</artifactId><version>1.2</version></dependency></dependencies>

建立ActiveMQ的属性文件：activemq.properties

activemq.brokerUrl=tcp://localhost:61616activemq.userName=adminactivemq.password=adminactivemq.pool.maxConnection=10activemq.queueName=foodQueueactivemq.topicName=foodTopic

因为是本地测试，我就在windows系统启动了一个ActiveMQ。

下面建立spring-activemq.xml

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="/schema/beans"xmlns:xsi="/2001/XMLSchema-instance"xmlns:context="/schema/context"xmlns:core="/schema/core"xmlns:jms="/schema/jms"xmlns:mvc="/schema/mvc"xsi:schemaLocation="/schema/beans /schema/beans/spring-beans.xsd/schema/context /schema/context/spring-context-4.3.xsd/schema/core /schema/core/schema/jms /schema/jms/spring-jms-4.3.xsd/schema/mvc /schema/mvc/spring-mvc-4.3.xsd"><context:component-scan base-package="com.mq.service"></context:component-scan><mvc:annotation-driven></mvc:annotation-driven><context:property-placeholder location="classpath:activemq.properties"/><bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"><property name="brokerURL" value="${activemq.brokerUrl}"></property><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="activeMQConnectionFactory"></property><property name="maxConnections" value="${activemq.pool.maxConnection}"></property></bean><bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"><property name="targetConnectionFactory" ref="pooledConnectionFactory"></property></bean><bean id="queueDestination" class="org.mand.ActiveMQQueue"><constructor-arg><value>${activemq.queueName}</value></constructor-arg></bean><bean id="topicDestination" class="org.mand.ActiveMQTopic"><constructor-arg><value>${activemq.topicName}</value></constructor-arg></bean><bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"><property name="connectionFactory" ref="connectionFactory"></property><property name="defaultDestination" ref="queueDestination"></property></bean></beans>

spring.xml

接下来写代码，目录结构如下：（你不需要考虑controller，以及spring-mvc.xml，以及Food）

建立Mail信息类：

View Code

关于那个Food是我测试着玩的哈哈，满足你的好奇心

package com.mq.entity;import java.io.Serializable;import java.util.Date;public class Food implements Serializable {private static final long serialVersionUID = 1L;private String foodName;private double foodPrice;private int foodNumber;private Date orderTime;public Food() {}public Food(String foodName, double foodPrice, int foodNumber, Date orderTime) {super();this.foodName = foodName;this.foodPrice = foodPrice;this.foodNumber = foodNumber;this.orderTime = orderTime;}public String getFoodName() {return foodName;}public void setFoodName(String foodName) {this.foodName = foodName;}public double getFoodPrice() {return foodPrice;}public void setFoodPrice(double foodPrice) {this.foodPrice = foodPrice;}public int getFoodNumber() {return foodNumber;}public void setFoodNumber(int foodNumber) {this.foodNumber = foodNumber;}public Date getOrderTime() {return orderTime;}public void setOrderTime(Date orderTime) {this.orderTime = orderTime;}@Overridepublic String toString() {return "Food [foodName=" + foodName + ", foodPrice=" + foodPrice + ", foodNumber=" + foodNumber + ", orderTime="+ orderTime + "]";}}

View Code

消息服务接口

package com.mq.service;import javax.jms.Destination;import org.springframework.stereotype.Service;import com.mq.entity.Food;import com.mq.entity.MailInfo;@Servicepublic interface HelloService {void sendMessage(Destination destination, Food food);void sendMail(Destination destination, MailInfo mail);}

消息服务实现：

package com.mq.service.impl;import javax.jms.Destination;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 org.springframework.stereotype.Service;import com.alibaba.fastjson.JSONObject;import com.mq.entity.Food;import com.mq.entity.MailInfo;import com.mq.service.HelloService;@Servicepublic class HelloServiceImpl implements HelloService {@Autowiredprivate JmsTemplate jmsTemplate;@Overridepublic void sendMessage(Destination destination, Food food){jmsTemplate.send(destination, new MessageCreator() {@Overridepublic Message createMessage(Session session) throws JMSException {return session.createTextMessage(JSONObject.toJSONString(food));//return session.createObjectMessage(new Food("蛋糕", 66.5, 1, new Date())); }});}@Overridepublic void sendMail(Destination destination, MailInfo mail) {jmsTemplate.send(destination, new MessageCreator() {@Overridepublic Message createMessage(Session session) throws JMSException {return session.createTextMessage(JSONObject.toJSONString(mail));}});}}

最后是测试类，这里使用了springTest。

package com.mq.test;import javax.jms.Destination;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import com.mq.entity.MailInfo;import com.mq.service.HelloService;@ContextConfiguration(locations={"classpath:spring.xml"})@RunWith(SpringJUnit4ClassRunner.class)public class MyTest {//@Autowired与@Resource都可以用来装配bean. 都可以写在字段上,或写在setter方法上。//使用@Autowired的话，想使用名称装配可以结合@Qualifier注解进行使用//@Resource（这个注解属于J2EE的），默认安照名称进行装配，名称可以通过name属性进行指定， //如果没有指定name属性，当注解写在字段上时，默认取字段名进行按照名称查找，如果注解写在setter方法上默认取属性名进行装配。@Autowiredprivate HelloService helloService;@Autowired@Qualifier("queueDestination")private Destination destination;@Testpublic void test(){//helloService.sendMessage(destination, new Food("蛋糕", 66.5, 1, new Date()));for (int i = 0; i < 1; i++) {helloService.sendMail(destination, new MailInfo("XXX@", "Spring java mail"+i, "生产者-消息队列-消费者-spring-mail"));}}}

下面是消费者：

依赖和生产者一样的，这里不重复了。activemq.properties也一样。

邮箱属性文件：

mail.account=用户名mail.pass=密码mail.host=smtp.mail.port=465mail.protocol=smtpmail.debug=truemail.smtp.auth=truemail.smtp.ssl.enable=true

spring-activemq.xml：

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="/schema/beans"xmlns:xsi="/2001/XMLSchema-instance"xmlns:context="/schema/context"xmlns:core="/schema/core"xmlns:jms="/schema/jms"xmlns:mvc="/schema/mvc"xsi:schemaLocation="/schema/beans /schema/beans/spring-beans.xsd/schema/context /schema/context/spring-context-4.3.xsd/schema/core /schema/core/schema/jms /schema/jms/spring-jms-4.3.xsd/schema/mvc /schema/mvc/spring-mvc-4.3.xsd"><mvc:annotation-driven></mvc:annotation-driven><bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"><property name="brokerURL" value="${activemq.brokerUrl}"></property><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="activeMQConnectionFactory"></property><property name="maxConnections" value="${activemq.pool.maxConnection}"></property></bean><bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"><property name="targetConnectionFactory" ref="pooledConnectionFactory"></property></bean><bean id="queueDestination" class="org.mand.ActiveMQQueue"><constructor-arg><value>${activemq.queueName}</value></constructor-arg></bean><bean id="topicDestination" class="org.mand.ActiveMQTopic"><constructor-arg><value>${activemq.topicName}</value></constructor-arg></bean><bean id="mqListener" class="com.mq.listener.ActiveMQListener"></bean><bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="connectionFactory"></property><property name="destination" ref="queueDestination"></property><property name="messageListener" ref="mqListener"></property></bean></beans>

spring-mail.xml：

spring.xml

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="/schema/beans"xmlns:xsi="/2001/XMLSchema-instance"xmlns:aop="/schema/aop"xmlns:context="/schema/context"xmlns:core="/schema/core"xmlns:tx="/schema/tx"xsi:schemaLocation="/schema/beans /schema/beans/spring-beans.xsd/schema/aop /schema/aop/spring-aop-4.3.xsd/schema/context /schema/context/spring-context-4.3.xsd/schema/core /schema/core/schema/tx /schema/tx/spring-tx-4.3.xsd"><context:component-scan base-package="com.mq.entity,com.mq.mail"></context:component-scan><context:property-placeholder location="classpath:activemq.properties,classpath:email.properties"/><import resource="spring-activemq.xml"/><import resource="spring-mail.xml"/></beans>

下面是工程结构：entity不说了，是一样的。

ActiveMQ监听器：

package com.mq.listener;import javax.jms.JMSException;import javax.jms.Message;import javax.jms.MessageListener;import javax.jms.TextMessage;import org.springframework.beans.factory.annotation.Autowired;import com.alibaba.fastjson.JSONObject;import com.mq.entity.MailInfo;import com.mq.mail.SendMail;public class ActiveMQListener implements MessageListener {@Autowiredprivate SendMail sendMail;@Overridepublic void onMessage(Message message) {TextMessage text = (TextMessage) message;try {MailInfo mail = JSONObject.parseObject(text.getText(), MailInfo.class);if(mail != null){System.out.println(mail.getTo() + "," + mail.getSubject() + "," + mail.getContent());System.out.println("发送邮件...");sendMail.send(mail);}} catch (JMSException e) {// TODO Auto-generated catch block e.printStackTrace();}// try {// System.out.println(text.getText());// Food food = JSONObject.parseObject(text.getText(), Food.class);// System.out.println("============收到消息===========");// System.out.println(food);// } catch (JMSException e) {// e.printStackTrace();// } }}

SendMail：

最后测试：

package com.mq.test;import javax.jms.Destination;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;@ContextConfiguration(locations={"classpath:spring.xml"})@RunWith(SpringJUnit4ClassRunner.class)public class MyTest {//@Autowired与@Resource都可以用来装配bean. 都可以写在字段上,或写在setter方法上。//使用@Autowired的话，想使用名称装配可以结合@Qualifier注解进行使用//@Resource（这个注解属于J2EE的），默认安照名称进行装配，名称可以通过name属性进行指定， //如果没有指定name属性，当注解写在字段上时，默认取字段名进行按照名称查找，如果注解写在setter方法上默认取属性名进行装配。@Autowired@Qualifier("queueDestination")private Destination destination;@Testpublic void test(){try {Thread.sleep(Integer.MAX_VALUE);} catch (InterruptedException e) {// TODO Auto-generated catch block e.printStackTrace();}//在单元测试里，如果test方法先于我们要执行的任务结束，会导致任务出错，所以我们这里睡眠了MAX秒，就为了给我们的任务争取时间 }}

先启动ActiveMQ，然后执行生产者的test方法，

然后执行消费者的test方法。

结果：

你运行的时候记得修改收件人哦，别给我发哦。

本内容不代表本网观点和政治立场，如有侵犯你的权益请联系我们处理。

网友评论

网友评论仅供其表达个人看法，并不表明网站立场。