ActiveMQ第三弹:在Spring中使用内置的Message Broker-白红宇

在上个例子中我们演示了如何使用Spring JMS来向ActiveMQ发送消息和接收消息。但是这个例子需要先从控制台使用ActiveMQ提供的命令行功能启动一个Message Broker,然后才能运行示例。这个Message Broker就相当于一个server，无论是发送方还是接收方都可以连接到这个Server进行消息的处理。在某些情况下，让Message Broker和consumer启动在同一个JVM里面，通信效率肯定会高不少。

ActiveMQ提供了很多方式来创建内置的broker。这篇文章主要介绍使用Spring及XBean来创建一个内置的broker。

首先需要在项目中引入xbean-spring依赖项。

pom.xml

                               
              org.apache.xbean
              xbean-spring
              3.16

然后在Spring配置文件中加入以下代码:

注意在Spring配置文件中还要加入Namespace的定义。

                               
             .........

完整的Spring配置如下。

embedBroker.xml

                               
                application.properties

在中我新加了一个Main方法来进行测试。可以运行EmbedBrokerApp中的Main方法来进行测试。

如果客户端和broker在相同的JVM进程中，客户端连接时可以使用broker url为“vm://localhost:61616”,进程外连接则需要使用”tcp://localhost:61616”。如果有多个broker的话可以给每个broker起个名字。

1234567891011

客户端连接时候可以直接使用broker名称连接，比如使用”vm://broker1”来使用第一个broker。

本章中的完整源码可从完整代码可从下载。