activemqspring客户端-创新互联

一、dependency

    5.15.4
    4.8
    5.0.7.RELEASE



    
        org.apache.activemq
        activemq-client
        ${activemq.version}
    
    
        org.apache.activemq
        activemq-spring
        ${activemq.version}
    
    
        org.apache.activemq
        activemq-pool
        ${activemq.version}
    
    
        org.apache.activemq
        activemq-broker
        ${activemq.version}
    

    
        org.apache.xbean
        xbean-spring
        ${xbean-spring.version}
    
    
        org.springframework
        spring-jms
        ${spring-jms.version}
    


    
        org.springframework
        spring-core
    
    
        org.springframework
        spring-beans
    
    
        org.springframework
        spring-context
    
    
        org.springframework
        spring-context-support
    

    
        org.apache.commons
        commons-pool2
    

    
        org.slf4j
        slf4j-log4j12
    
    
        org.apache.logging.log4j
        log4j-core
    

二、activemq.properties

active.config.brokerURL=failover:(tcp://localhost:61617,tcp://localhost:61618,tcp://localhost:61619)
active.config.username=admin
active.config.password=admin123

active.destination.queue.name=queue.test01
active.destination.topic.name=topic.test01

三、spring-activemq-producer.xml

   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xmlns:context="http://www.springframework.org/schema/context"
   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
   http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

  

  
  
    
    
    
    
    
    
    
    
    
    
  
  
  
  
    
      ${active.config.brokerURL}
    
    
      ${active.config.username}
    
    
      ${active.config.password}
    
    
  

  
  
    
  

  
  
    
  

  
  
    
  
  
    
  

  
  
    
    
  

  
  
    
    
  

四、spring-activemq-consumer.xml

   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xmlns:context="http://www.springframework.org/schema/context"
   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
   http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

  

  
  
    
      ${active.config.brokerURL}
    
    
      ${active.config.username}
    
    
      ${active.config.password}
    
  

  
  
    
  

  
  
    
  

  
  
    
  
  
    
  

  
  
  
  
    
  

  
  
    
    
    
  

  
  
    
    
    
  

五、相关业务实现类

producer相关类:

import org.springframework.jms.core.JmsTemplate;

import javax.jms.Destination;

public abstract class AbstractActivemqProducer {
  private JmsTemplate jmsTemplate;
  private Destination destination;

  public AbstractActivemqProducer(JmsTemplate jmsTemplate, Destination destination) {
    this.jmsTemplate = jmsTemplate;
    this.destination = destination;
  }

  public void send(String msg){
    jmsTemplate.convertAndSend(destination, msg);
  }
}

public class QueueActivemqProducer extends AbstractActivemqProducer {

  public QueueActivemqProducer(JmsTemplate jmsTemplate, Destination destination) {
    super(jmsTemplate, destination);
  }
}

public class TopicActivemqProducer extends AbstractActivemqProducer {

  public TopicActivemqProducer(JmsTemplate jmsTemplate, Destination destination) {
    super(jmsTemplate, destination);
  }
}

customer相关类:

public class CustomerMsgListener implements MessageListener {

    private BusinessHandler businessHandler;

    public CustomerMsgListener(BusinessHandler businessHandler) {
        this.businessHandler = businessHandler;
    }

    @Override
    public void onMessage(Message message) {
        try {
            if (message instanceof TextMessage) {
                businessHandler.handle(((TextMessage) message).getText() );
            }
            if (message instanceof MapMessage) {
                MapMessage mapMessage = (MapMessage) message;
                businessHandler.handle(mapMessage.getString("key01") );
                businessHandler.handle(mapMessage.getString("key02") );
            }
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

public interface BusinessHandler {

    void handle(String msg);
}

public class QueueHandler implements BusinessHandler {
    @Override
    public void handle(String msg) {
        System.out.println("msg = [" + msg + "]");
    }

}

六、测试

public class XmlActivemqTest {

    public static void main(String[] args) {
        customerXml();
    }

    public static void producerXml(){
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath*:spring-activemq-producer.xml");
        AbstractActivemqProducer queueActivemqProducer = context.getBean(QueueActivemqProducer.class);
        queueActivemqProducer.send("this is a test");
    }


    public static void customerXml(){
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath*:spring-activemq-customer.xml");
    }
}

参考地址：

http://activemq.apache.org/spring-support.html

http://docs.spring.io/spring/docs/2.5.x/reference/jms.html#jms-mdp

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。