一、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许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。