hello!this is mail test。
" }` 请参见图示。 [.png)](http://spring4all.com/uploads/article/20170612/1f25387d2b511464b767b57756fbbcbc.PNG) 来看看 RabbitMQ 的管理后台吧，它会出现一个未处理的消息。（地址：[http://localhost:15672/#/queues）](http://localhost:15672/#/queues）) [.png)](http://spring4all.com/uploads/article/20170612/992bb72cf48b90a9eb32b1f98117c923.PNG) 注意的是，千万别向我的邮箱发测试消息哟，不然我的邮箱会邮件爆炸的/(ㄒoㄒ)/~~。 **构建消息消费者** [.png)](http://spring4all.com/uploads/article/20170612/af5e91f7193cd855fea6e7aae6d679ab.PNG) 完成消息生产者之后，我们再来构建一个消息消费者的工程。同样地，我们使用 Java Config 的方式配置消息消费者。 `@Configuration@ComponentScan(basePackages = {"com.lianggzone.rabbitmq"}) @PropertySource(value = {"classpath:application.properties"}) public class RabbitMQConfig { @Autowired private Environment env; @Bean public ConnectionFactory connectionFactory() throws Exception { ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setHost(env.getProperty("mq.host").trim()); connectionFactory.setPort(Integer.parseInt(env.getProperty("mq.port").trim())); connectionFactory.setVirtualHost(env.getProperty("mq.vhost").trim()); connectionFactory.setUsername(env.getProperty("mq.username").trim()); connectionFactory.setPassword(env.getProperty("mq.password").trim()); return connectionFactory; } @Bean public CachingConnectionFactory cachingConnectionFactory() throws Exception { return new CachingConnectionFactory(connectionFactory()); } @Bean public RabbitTemplate rabbitTemplate() throws Exception { RabbitTemplate rabbitTemplate = new RabbitTemplate(cachingConnectionFactory()); rabbitTemplate.setChannelTransacted(true); return rabbitTemplate; } @Bean public AmqpAdmin amqpAdmin() throws Exception { return new RabbitAdmin(cachingConnectionFactory()); } @Bean public SimpleMessageListenerContainer listenerContainer( @Qualifier("mailMessageListenerAdapter") MailMessageListenerAdapter mailMessageListenerAdapter) throws Exception { String queueName = env.getProperty("mq.queue").trim(); SimpleMessageListenerContainer simpleMessageListenerContainer = new SimpleMessageListenerContainer(cachingConnectionFactory()); simpleMessageListenerContainer.setQueueNames(queueName); simpleMessageListenerContainer.setMessageListener(mailMessageListenerAdapter); // 设置手动 ACK simpleMessageListenerContainer.setAcknowledgeMode(AcknowledgeMode.MANUAL); return simpleMessageListenerContainer; } }` 聪明的你，应该发现了其中的不同。这个代码中多了一个 listenerContainer() 方法。是的，它是一个监听器容器，用来监听消息队列进行消息处理的。注意的是，我们这里设置手动 ACK 的方式。默认的情况下，它采用自动应答，这种方式中消息队列会发送消息后立即从消息队列中删除该消息。此时，我们通过手动 ACK 方式，如果消费者因宕机或链接失败等原因没有发送 ACK，RabbitMQ 会将消息重新发送给其他监听在队列的下一个消费者，保证消息的可靠性。 当然，我们也定义 application.properties 配置文件。 `mq.host=localhost mq.username=guest mq.password=guest mq.port=5672 mq.vhost=/ mq.queue=email_queue` 此外，我们创建了一个 MailMessageListenerAdapter 类来消费消息。 `@Component("mailMessageListenerAdapter") public class MailMessageListenerAdapter extends MessageListenerAdapter { @Resource private JavaMailSender mailSender; @Value("${mail.username}") private String mailUsername; @Override public void onMessage(Message message, Channel channel) throws Exception { try { // 解析RabbitMQ消息体 String messageBody = new String(message.getBody()); MailMessageModel mailMessageModel = JSONObject.toJavaObject(JSONObject.parseObject(messageBody), MailMessageModel.class); // 发送邮件 String to = mailMessageModel.getTo(); String subject = mailMessageModel.getSubject(); String text = mailMessageModel.getText(); sendHtmlMail(to, subject, text); // 手动ACK channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); }catch (Exception e){ e.printStackTrace(); } } /** * 发送邮件 * @param to * @param subject * @param text * @throws Exception */ private void sendHtmlMail(String to, String subject, String text) throws Exception { MimeMessage mimeMessage = mailSender.createMimeMessage(); MimeMessageHelper mimeMessageHelper = new MimeMessageHelper(mimeMessage); mimeMessageHelper.setFrom(mailUsername); mimeMessageHelper.setTo(to); mimeMessageHelper.setSubject(subject); mimeMessageHelper.setText(text, true); // 发送邮件 mailSender.send(mimeMessage); } }` 在 onMessage() 方法中，我们完成了三件事情： 从 RabbitMQ 的消息队列中解析消息体。根据消息体的内容，发送邮件给目标的邮箱。手动应答 ACK，让消息队列删除该消息。 这里，JSONObject.toJavaObject() 方法使用 fastjson 将 json 字符串转换成实体对象 MailMessageModel。注意的是，@Data 是 lombok 类库的一个注解。 `@Datapublic class MailMessageModel { @JSONField(name = "from") private String from; @JSONField(name = "to") private String to; @JSONField(name = "subject") private String subject; @JSONField(name = "text") private String text; @Override public String toString() { StringBuffer sb = new StringBuffer(); sb.append("Email{from:").append(this.from).append(", "); sb.append("to:").append(this.to).append(", "); sb.append("subject:").append(this.subject).append(", "); sb.append("text:").append(this.text).append("}"); return sb.toString(); } }` Spring 对 Java Mail 有很好的支持。其中，邮件包括几种类型：简单文本的邮件、 HTML 文本的邮件、 内嵌图片的邮件、 包含附件的邮件。这里，我们封装了一个简单的 sendHtmlMail() 进行邮件发送。 对了，我们还少了一个邮件的配置类。 `@Configuration@PropertySource(value = {"classpath:mail.properties"}) @ComponentScan(basePackages = {"com.lianggzone.rabbitmq"}) public class EmailConfig { @Autowired private Environment env; @Bean(name = "mailSender") public JavaMailSender mailSender() { // 创建邮件发送器, 主要提供了邮件发送接口、透明创建Java Mail的MimeMessage、及邮件发送的配置 JavaMailSenderImpl mailSender = new JavaMailSenderImpl(); // 如果为普通邮箱, 非ssl认证等 mailSender.setHost(env.getProperty("mail.host").trim()); mailSender.setPort(Integer.parseInt(env.getProperty("mail.port").trim())); mailSender.setUsername(env.getProperty("mail.username").trim()); mailSender.setPassword(env.getProperty("mail.password").trim()); mailSender.setDefaultEncoding("utf-8"); // 配置邮件服务器 Properties props = new Properties(); // 让服务器进行认证,认证用户名和密码是否正确 props.put("mail.smtp.auth", "true"); props.put("mail.smtp.timeout", "25000"); mailSender.setJavaMailProperties(props); return mailSender; } }` 这些配置信息，我们在配置文件 mail.properties 中维护。 `mail.host=smtp.163.com mail.port=25 mail.username=用户名 mail.password=密码` 最后，我们写一个 main 方法，将 Spring Boot 服务运行起来吧。 至此，我们也完成了一个消息消费者的工程，它将不断地从消息队列中处理邮件消息。 **源代码** 相关示例完整代码： [https://github.com/lianggzone/rabbitmq-server](https://github.com/lianggzone/rabbitmq-server) (完) 本文作者： 梁桂钊 原文链接： [http://blog.720ui.com/2017/rabbitmq_action_email/](http://blog.720ui.com/2017/rabbitmq_action_email/) 版权归作者所有，转载请注明出处 [** **4**](#) [**](#)[** 收藏](#) [** 分享]() *2017-06-12*[](http://spring4all.com/people/anoy) [.jpg)](http://spring4all.com/people/xiaobaxi) [.jpg)](http://spring4all.com/people/jimzhang) [.jpg)](http://spring4all.com/people/Tonyli)