Блог

У нас есть два экземпляра activemq, настроенных как кластер, и кластер из четырех экземпляров glassfish, которые должны быть подключены к ОДНОМУ activemq в любой момент времени. Если activemq01 недоступен, все четыре экземпляра glassfish должны выполнить переход на activemq02.

Я несколько раз замечал, что по неизвестной причине один из (случайных) экземпляров glassfish переключается на activemq02, а оставшиеся три экземпляра по-прежнему будут подключены к activemq01, даже если activemq01 не был отключен, и все экземпляры glassfish должны были прослушивать activemq01.

В журналах не указано ничего, что могло бы объяснить такое поведение, все, что я могу видеть, если этот экземпляр glassfish не смог подключиться к activemq01 и произошел сбой при activemq02.

Кто-нибудь сталкивался с такими же или похожими проблемами? Любая помощь / совет приветствуется.

Вот мои конфигурации activemq :

activemq01 :

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsdhttp://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd «>

файл: ${activemq.base}/conf/credentials.properties

 <managementContext>
  <managementContext connectorPort="1093" createConnector="true"/>
</managementContext>

<networkConnectors>
  <networkConnector name="amq-prod" uri="static://(tcp://127.0.0.1:61616,tcp://192.168.0.167:61616)" />
</networkConnectors>


<persistenceAdapter>
  <kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>

<plugins>
  <loggingBrokerPlugin logAll="false" logConnectionEvents="true"/>
</plugins>


<systemUsage>
  <systemUsage>
    <memoryUsage>
      <memoryUsage limit="2048 mb"/>
    </memoryUsage>
    <storeUsage>
      <storeUsage limit="2 gb" name="prod"/>
    </storeUsage>
    <tempUsage>
      <tempUsage limit="2000 mb"/>
    </tempUsage>
  </systemUsage>
</systemUsage>

<transportConnectors>
  <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" updateClusterClients="true" />
</transportConnectors>
  

#

activeMQ02:

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsdhttp://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd «>

файл: ${activemq.base}/conf/credentials.properties

 <managementContext>
  <managementContext connectorPort="1093" createConnector="true"/>
</managementContext>

<networkConnectors>
  <networkConnector name="amq-prod" uri="static://(tcp://127.0.0.1:61616,tcp://192.168.0.166:61616)"  />
</networkConnectors>


<persistenceAdapter>
  <kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
  

 <systemUsage>
  <systemUsage>
    <memoryUsage>
      <memoryUsage limit="2048 mb"/>
    </memoryUsage>
    <storeUsage>
      <storeUsage limit="2 gb" name="prod"/>
    </storeUsage>
    <tempUsage>
      <tempUsage limit="2000 mb"/>
    </tempUsage>
  </systemUsage>
</systemUsage>

<transportConnectors>
  <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" updateClusterClients="true" />
</transportConnectors>
  

версия ActiveMQ — 5.4.1

Должен ли ваш тег networkConnector быть определен следующим образом:

конфигурация acticemq01:

  <networkConnector
         name="amq1-nc" 
         uri="static:(failover:(tcp://192.168.0.167:61616))" 
         networkTTL="2" 
         duplex="true"
         dynamicOnly="true" 
  />
  

конфигурация acticemq02:

  <networkConnector
         name="amq2-nc" 
         uri="static:(failover:(tcp://192.168.0.166:61616))" 
         networkTTL="2" 
         duplex="true"
         dynamicOnly="true" 
  />
  

И в ваших потребителях используйте URL-адрес поставщика JMS, подобный этому:

 failover:(tcp://192.168.0.166:61616,tcp://192.168.0.167:61616)?randomize=falseamp;timeout=5000
  

Приведенный выше URL-адрес для отработки отказа всегда будет подключаться к брокеру acticemq01, если он доступен. Если acticemq01 выйдет из строя, он автоматически переключится на брокера acticemq02. Также тайм-аут = 5000 гарантирует, что потребитель вернет ошибку через 5 секунд при попытке подключиться к любому из двух брокеров.