2

2 つのブローカーで構成される ActiveMQ ネットワークを作成しようとしています。関連ガイド (http://activemq.apache.org/networks-of-brokers.html) で説明されているように、構成を行いました。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://activemq.org/config/1.0">

  <broker brokerName="receiver" persistent="false" useJmx="false">  
    <networkConnectors>
      <networkConnector uri="static:(tcp://host2:61616)"/>
    </networkConnectors>

    <persistenceAdapter>
      <memoryPersistenceAdapter/>
    </persistenceAdapter>

   <transportConnectors>
      <transportConnector uri="tcp://host1:61616"/>
    </transportConnectors>
  </broker>
</beans>

上記の XML 構成では、ネットワーク ブローカーの 1 つが host1 で実行され、もう 1 つが host2 で実行されていると想定しています。host2 で実行されているブローカーは反対の値になります。JMS は開始に失敗し、ログ ファイルに例外は生成されません。表示される唯一のメッセージは次のとおりです。

INFO  | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@3df78040: startup date [Tue Nov 22 20:54:53 CET 2011]; root of context hierarchy | org.apache.activemq.xbean.XBeanBrokerFactory$1 | main

2 つ以上の ActiveMQ ブローカーのネットワークを設定できた人はいますか?

4

2 に答える 2

1

ブローカーの静的ネットワークを使用している場合は、ブローカーのネットワークを形成するブローカーのすべての IP を指定する必要があります。

 <networkConnector name="HA Queue" uri="static:(tcp://host1:61616,tcp://host2:61616)"/>

また、次の方法でトランスポート コネクタを指定してみてください。

    <transportConnectors>
       <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" />
    </transportConnectors>
于 2011-11-24T06:39:02.147 に答える
1

これは、ActiveMQ で行う非常に一般的なことです。${ACTIVEMQ_HOME}/conf ディレクトリ (activemq-static-network-broker1.xml および activemq-static-network-broker2.xml) で、ブローカーのネットワークのベースとなるサンプル構成を取得できます。

構成の名前空間が間違っていることがわかります。それは読むべきです：

<beans
  xmlns="http://www.springframework.org/schema/beans"
  xmlns:amq="http://activemq.apache.org/schema/core"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
    http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd">

  <broker xmlns="http://activemq.apache.org/schema/core" brokerName="static-broker1">
    <!-- other stuff goes here -->
  </broker>

</beans>

注意すべき重要なことは、これが AMQ ブローカー (http://activemq.apache.org/) を定義する XBean 構成を持つ Spring 構成 (http://www.springframework.org/schema/beans) であることです。スキーマ/コア)。

また、srodriguez が言ったことを繰り返します。transportConnector のホスト名として 0.0.0.0 を使用します。

于 2011-11-25T14:43:29.150 に答える