摘要：本文以一個非常簡單的業(yè)務場景為例，即系統(tǒng)給用戶發(fā)送通知郵件，來講一講如何構建簡單的消息通信。實現(xiàn)生產(chǎn)者和消費者在這里生產(chǎn)者負責生成包含郵件收件人和內容等信息的消息并存入隊列，而消費者則負責從這些信息中國生成郵件并發(fā)送出去。

對于WEB系統(tǒng)，向用戶發(fā)送郵件、短信、站內信等幾乎是必備的基礎功能，但這些任務相對于所見即所得的立即響應式的請求對實時性的要求并不高，同時任務處理的量還很大。在復雜多系統(tǒng)的情形下，還要考慮多個子系統(tǒng)的通信問題。無論是從實際業(yè)務需求還是從軟件工程的設計角度出發(fā)，消息通信都有必要成為一個獨立的模塊。本文以一個非常簡單的業(yè)務場景為例，即系統(tǒng)給用戶發(fā)送通知郵件，來講一講如何構建簡單的消息通信。

在上一次的博客中我們講述了消息隊列，消息隊列是消息通信系統(tǒng)的重要組成部分。J2EE為運行在jvm虛擬機上的程序間的通信早就制定了一套標準，也就是我們提到的JMS標準。但JMS并不涉及到具體實現(xiàn)，我們在本文中采用應用最為廣泛的ActiveMQ為例。

首先我們需要在pom.xml中引入相關依賴。

        
            org.springframework
            spring-jms
            ${spring.version}
        
        
            org.apache.activemq
            activemq-core
            5.7.0
        

然后我們要在ApplicationContext.xml文件中作出相關配置。

    JMS簡單應用配置
    
    
        
    
    
    
        
        
    
    
    
        
    
    
    
        
    
    
    
        
    
    
    
        
        
        
    
    
    
        
        
        
        
    
    
    
        
        
        
    
    
    

對于上文我們將一一解釋：

ConnectionFactory：用于產(chǎn)生到JMS服務器的鏈接

targetConnectionFactory：真正可以產(chǎn)生Connection的ConnectionFactory，由對應的 JMS服務廠商提供，在這里是ActiveMQ

JmsTemplate：實現(xiàn)消息發(fā)送的工具，由Spring提供

Destination：用來表示目的地的接口在ActiveMQ中實現(xiàn)了兩種類型的Destination，一個是點對點的ActiveMQQueue，另一個就是支持訂閱/發(fā)布模式的ActiveMQTopic。，沒有任何方法定義，只是用來做一個標識而已。

在這里生產(chǎn)者負責生成包含郵件收件人和內容等信息的消息并存入隊列，而消費者則負責從這些信息中國生成郵件并發(fā)送出去。

生產(chǎn)者代碼

public class NotifyMessageProducer {

    private JmsTemplate jmsTemplate;
    private Destination notifyQueue;
    private Destination notifyTopic;

    public void sendQueue(final User user) {
        sendMessage(user, notifyQueue);
    }

    public void sendTopic(final User user) {
        sendMessage(user, notifyTopic);
    }

    /**
     * 使用jmsTemplate最簡便的封裝convertAndSend()發(fā)送Map類型的消息.
     */
    private void sendMessage(User user, Destination destination) {
        Map map = new HashMap();
        map.put("userName", user.getName());
        map.put("email", user.getEmail());

        jmsTemplate.convertAndSend(destination, map);
    }

    public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }

    public void setNotifyQueue(Destination notifyQueue) {
        this.notifyQueue = notifyQueue;
    }

    public void setNotifyTopic(Destination nodifyTopic) {
        this.notifyTopic = nodifyTopic;
    }
}

消費者代碼

public class NotifyMessageListener implements MessageListener {

    private static Logger logger = LoggerFactory.getLogger(NotifyMessageListener.class);

    @Autowired(required = false)
    private MailService simpleMailService;

    /**
     * MessageListener回調函數(shù).
     */
    @Override
    public void onMessage(Message message) {
        try {
            MapMessage mapMessage = (MapMessage) message;
            // 打印消息詳情
            logger.info("UserName:{}, Email:{}", mapMessage.getString("userName"), mapMessage.getString("email"));

            // 發(fā)送郵件
            if (simpleMailService != null) {
                simpleMailService.sendNotificationMail(mapMessage.getString("userName"));
            }
        } catch (Exception e) {
            logger.error("處理消息時發(fā)生異常.", e);
        }
    }
}

郵件模型

public class ApplicationEmail implements Serializable {  
    
    public String getAddress() {
        return address;
    }
    public void setAddress(String address) {
        this.address = address;
    }
    public String getCc() {
        return cc;
    }
    public void setCc(String cc) {
        this.cc = cc;
    }
    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;
    }
    
    /**收件人**/  
    private String address;    
     /**抄送給**/   
    private String cc;    
     /**郵件主題**/  
    private String subject;   
      /**郵件內容**/  
    private String content;    
     /**附件**/   
    //private MultipartFile[] attachment = new MultipartFile[0];    
      
}  

郵件幫助類（此處采用了java mail依賴包）

public class MailService {
    private static Logger logger = LoggerFactory.getLogger(MailService.class);

    private JavaMailSender mailSender;
    private String textTemplate;

    /**
     * 發(fā)送純文本的用戶修改通知郵件.
     */
    public void sendNotificationMail(String userName) {
        SimpleMailMessage msg = new SimpleMailMessage();
        msg.setFrom("suemi94@qq.com");
        msg.setTo("suemi994@gmail.com");
        msg.setSubject("用戶修改通知");

        // 將用戶名與當期日期格式化到郵件內容的字符串模板
        String content = String.format(textTemplate, userName, new Date());
        msg.setText(content);

        try {
            mailSender.send(msg);
            if (logger.isInfoEnabled()) {
                logger.info("純文本郵件已發(fā)送至{}", StringUtils.join(msg.getTo(), ","));
            }
        } catch (Exception e) {
            logger.error("發(fā)送郵件失敗", e);
        }
    }
    
    /**
     * 同步發(fā)送郵件
     * 
     * @param email
     * @throws MessagingException
     * @throws IOException
     */
    public void sendMailBySynchronizationMode(ApplicationEmail email) throws MessagingException, IOException { 
         Session session=Session.getDefaultInstance(new Properties());
         MimeMessage mime= new MimeMessage(session);
         MimeMessageHelper helper = new MimeMessageHelper(mime, true, "utf-8");    
         helper.setFrom("suemi94@qq.com");//發(fā)件人    
         helper.setTo(InternetAddress.parse(email.getAddress()));//收件人    
         helper.setReplyTo("suemi94@qq.com");//回復到   
         helper.setSubject(email.getSubject());//郵件主題    
         helper.setText(email.getContent(), true);//true表示設定html格式  
         
         mailSender.send(mime);
    }
    
   
    /**
     * Spring的MailSender.
     */
    public void setMailSender(JavaMailSender mailSender) {
        this.mailSender = mailSender;
    }

    /**
     * 郵件內容的字符串模板.
     */
    public void setTextTemplate(String textTemplate) {
        this.textTemplate = textTemplate;
    }
}