Chinese version click here (中文版)

What i do

Althongh ActiveMQ provide some way (see this) to build a jms-broker cluster, unfortunately, there are a lot of limit with the cluster mode, for example, performance problems and linear expansibility problems. Actually, we have a cheaper way to bring along both performance and expansibility below.

                      +------------+
                 +---->   broker   +---+
                 |    +------------+   |
                 |                     |
+------------+   |    +------------+   |   +------------+
|  Producer  +-------->   broker   +------->  Consumer  |
+------------+   |    +------------+   |   +------------+
                 |                     |
                 |    +------------+   |
                 +---->   broker   +---+
                      +------------+

In this way , brokers are independent that do not know each other. Producer and consumer run over the client-side load-balance machine.

I implement this client-side load-balance machine base on spring-boot's activemq auto configuration. And make it easy to use, which users just only need to configure the broker's address.

Usage (With Spring-Boot Applications)

1. Import maven dependency as below

   <dependency>
       <groupId>com.github.fonoisrev</groupId>
       <artifactId>spring-boot-starter-activemq-clientSideLoadBalance</artifactId>
       <version>1.1.0</version>
   </dependency>

2. Add broker urls into the configuration file (.properties or .yml) as below

   activemq.loadbalance.enabled=true
   activemq.loadbalance.urls[0]=tcp://localhost:61616
   activemq.loadbalance.urls[1]=tcp://localhost:61617
   ...(more urls)

   or

   activemq:
     loadbalance:
       enabled: true
       urls:
         - tcp://localhost:61616
         - tcp://localhost:61617
         ...(more urls)

3. Use Spring framework tools JmsTemplate or JmsMessageTemplate(4.0 and later) to send message. And use @JmsListener to handle messages recieved. See Spring's website for more features.

Usage(With Traditional Spring Applications)

Suppose your application was developed with spring but not intend to move to spring-boot styles. You can follow guides as below.

1. Add maven dependency, same as ahead.

      <dependency>
          <groupId>com.github.fonoisrev</groupId>
          <artifactId>spring-boot-starter-activemq-clientSideLoadBalance</artifactId>
          <version>1.1.0</version>
      </dependency>

2. Define beans in spring's xml configurations.

       <!-- Config SharedMultiConnectionFactory -->
       <bean class="com.github.fonoisrev.jms.connection.SharedMultiConnectionFactory"
             id="sharedMultiConnectionFactory">
           <constructor-arg name="urls">
               <!-- ActiveMQ urls here -->
               <list>
                   <value>tcp://localhost:61616</value>
                   <value>tcp://localhost:61617</value>
                   <!-- ... more urls -->
               </list>
           </constructor-arg>
       </bean>
   
       <!-- this is the LoadBalanceJmsConnectionFactory for client send -->
       <bean class="com.github.fonoisrev.jms.connection.LoadBalanceJmsConnectionFactory" 
             id="loadBalanceJmsConnectionFactory">
           <constructor-arg ref="sharedMultiConnectionFactory"/>
       </bean>
   
       <!-- this is the JmsMessagingTemplate or can replace with JmsTemplate -->
       <bean class="org.springframework.jms.core.JmsMessagingTemplate" 
             id="jmsMessagingTemplate">
           <property name="connectionFactory" ref="loadBalanceJmsConnectionFactory"/>
       </bean>
   
       <!-- define your own MessageListener -->
       <bean class="com.github.fonoisrev.listener.MyMessageListener" id="messageListener"/>
   
       <!-- define MultiJmsMessageListenerContainer(s) -->
       <!-- configuration is same as org.springframework.jms.listener.DefaultMessageListenerContainer -->
       <bean class="com.github.fonoisrev.jms.container.MultiJmsMessageListenerContainer" 
             id="container1">
           <!--must set connectionFactory first-->
           <property name="connectionFactory" ref="sharedMultiConnectionFactory"/>
           <property name="destinationName" value="test"/>
           <property name="messageListener" ref="messageListener"/>
           <property name="concurrency" value="1-2"/>
       </bean>

How To

In short, I hack the Spring-Boot's autoConfiguration about ActiveMQ, do something before configure the org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration. More details are in the spring-boot-starter-activemq-clientSideLoadBalance folder. Or follow with my blog in here.