Oraclespringjms,Spring集成ActiveMQ

准备工作解压缩下载的文件到你希望安装的目录

进入bin目录运行activemq.bat以启动ActiveMQ服务&＃xff0c;启动后默认

broker URL : tcp://localhost:61616

Admin URL&＃xff1a;http://localhost:8161/admin

打开Admin URL可以查看Queue、Topic等信息

关于ActiveMQ相关依赖包就交给Gradle工具&＃xff0c;请参看demo配置

JMS框架基本角色和编程模块JMS Message Producers : 消息生产者&＃xff0c;向消息队列提供消息

JMS Provider(Broker) : JMS提供商&＃xff0c;如ActiveMQ&＃xff0c;提供JMS Queues/Topics服务

JMS Message listener/Consumer &＃xff1a;接收并使用消息

JMS Provider有如数据库&＃xff0c;Producers/Consumers发送/接收消息前需要先连接到Provider&＃xff0c;与建立数据库连接相似&＃xff0c;JMS ConnectionFactory负责创建JMS Connection&＃xff0c;JMS Connection创建JMS SessionJMS ConnectionFactory &＃xff1a; Producers/Consumers用于创建一个到Provider的连接

JMS Connection &＃xff1a;封装一个到Provider的连接

JMS Session : 消息发送接收上下文

在JMS Provider上可以定义多个Queue和Topic&＃xff0c;Producers发送消息到哪个Queue/Topic&＃xff0c;称具体的那个Queue/Topic为Destination.JMS Destination : 一对一的Queue或者一对多的Topic

关于JMS编程模型可以参考以下文章&＃xff1a;

Spring集成配置Queue消息发送者(JMS Message Producers) :

ConnectionFactory &＃xff1a; 用于连接Provider&＃xff0c;支持连接池配置

JmsTemplate : Spring封装类&＃xff0c;可用于创造消息、发送消息、接收消息等

p:brokerURL&＃61;"tcp://localhost:61616" />

连接池配置示例&＃xff1a;

tcp://localhost:61616

Queue消息接收者(JMS Message listener) :

ConnectionFactory &＃xff1a; 用于连接Provider&＃xff0c;支持连接池配置

Listener : 接收消息

jms:listener-container 简化了配置工作&＃xff0c;destination只需要给queue/topic名称&＃xff0c;不需要额外定义

p:brokerURL&＃61;"tcp://localhost:61616" />

connection-factory&＃61;"connectionFactory" acknowledge&＃61;"auto">

method&＃61;"onMessage" />

Topic消息发送者(JMS Message Producers) :

ConnectionFactory &＃xff1a; 用于连接Provider&＃xff0c;支持连接池配置

JmsTemplate : Spring封装类&＃xff0c;可用于创造消息、发送消息、接收消息等

JmsTemplate 的pubSubDomain属性值为true表示destination为Topic类型&＃xff0c;默认false表示destination为Queue类型。

p:brokerURL&＃61;"tcp://localhost:61616" />

Topic消息接收者(JMS Message listener) :

ConnectionFactory &＃xff1a; 用于连接Provider&＃xff0c;支持连接池配置

Listener : 接收消息

Topic类型的消息&＃xff0c;所有订阅者都可以接收到&＃xff0c;本文Demo定义了两个接收者。

jms:listener-container 的destination-type属性默认值为queue&＃xff0c;如果是Topic需要显示指定。

p:brokerURL&＃61;"tcp://localhost:61616" />

destination-type&＃61;"topic" connection-factory&＃61;"connectionFactory"

acknowledge&＃61;"auto">

method&＃61;"onMessage" />

public class SimpleMessageSender implements MessageSender {

&＃64;Autowired

private JmsTemplate jmsTemplate;

&＃64;Override

public void sendMessage(final String message) {

jmsTemplate.send(new MessageCreator() {

public Message createMessage(Session session) throws JMSException {

return session.createTextMessage(message);

}

});

}

}Listener类实现代码&＃64;Component("messageListener")

public class SimpleMessageListener implements MessageListener {

private static final Logger logger &＃61; LoggerFactory.getLogger(SimpleMessageListener.class);

public void onMessage(Message message) {

TextMessage textMessage &＃61; (TextMessage) message;

try {

logger.info("Message received: " &＃43; textMessage.getText());

} catch (JMSException ex) {

logger.error("JMS error", ex);

}

}

}

应用跑起来后&＃xff0c;ActiveMQ接收到连接后&＃xff0c;如果请求的Queue/Topic不存在它会自动创建&＃xff0c;我们也可以通过ActiveMQ Admin界面给Listener发消息。