maven引用

    		    
     
      org.apache.activemq
     		    
     
      activemq-pool
     		    
     
      5.9.0
     		
    		
    		    
     
      org.apache.activemq
     		    
     
      activemq-all
     		    
     
      5.9.0
     		
    				
                  
     
      org.springframework
                   
     
      spring-jms
                   
     
      4.3.3.RELEASE
               
    

提供者配置文件（含订阅者配置文件）

    
    	
     
      JMS配置
     	
     	
     		
      			
       				
        				
        				
        			
       		
      		
      	
     	
     	
     		
      		
      	
     		
     	
                       
               
                 
                
               
          
       		
               
                
            
       	    
       	
     		
      		
              
        		
      		
      				
      	
     		
             
          
     	
     
    

provider

package com.cloud.cloudmanage.mq.produce;import java.io.Serializable;import javax.annotation.Resource;import javax.jms.Destination;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jms.core.JmsTemplate;import org.springframework.stereotype.Component;@Component("updateDecisionFileProduce")public class UpdateDecisionFileProduce {	@Autowired(required = false)	@Resource(name = "jmsTemplatePubSub")	private JmsTemplate jmsTemplate;	public JmsTemplate getJmsTemplate() {		return jmsTemplate;	}	public void setJmsTemplate(JmsTemplate jmsTemplate) {		this.jmsTemplate = jmsTemplate;	}	@Autowired(required = false)	@Resource(name="updateDecisionFile")	private Destination notifyQueue;	public void send(final Serializable ob) {		sendMessage(ob, notifyQueue);	}	/**	 * 使用jmsTemplate最简便的封装convertAndSend()发送Map类型的消息.	 */	private void sendMessage(Serializable msg, Destination destination) {		jmsTemplate.convertAndSend(destination, msg);	}}

订阅者代码：

package com.cloud.welkin.engine.mq.consumer;import javax.jms.Message;import javax.jms.MessageListener;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.stereotype.Component;@Component("updateDecisionFileMessageListener")public class UpdateDecisionFileMessageListener implements MessageListener {	private static Logger logger = LoggerFactory.getLogger(UpdateDecisionFileMessageListener.class);	@Override	public void onMessage(Message message) {				try {			//todo  在这里写逻辑		} catch (Exception e) {			logger.error("{}",e);		}			}}

总结：

spring JmsTemplate 整合消息队列，不管是发布订阅或者点对点，其实程序中的生产者、消费者（订阅者）代码并无太大区别，区别的是程序配置。