ActiveMQとRabbitMQを同時に使用する

Question

メッセージブローカーを使った私の経験によると、RabbitMqは負荷が重いほど優れたパフォーマンスを示します。ただし、簡単にするために、ブラウザでAtiveMQを使用する方がよいでしょう。私はそれが同時に両方を使用することが可能かどうかを知りたいですか？
さらに、ブラウザでActiveMQを使用してメッセージを送信し、サーバー側でRabbitMQを使用して同じメッセージを受信する方法はありますか？ 有用なサンプルコードがあれば、私は感謝します。

Answer 1

ActiveMQはAMQP 1.0を話すことができ、RabbitMQはplug-inを使用してAMQP 1.0を話すことができます。 このプロトコルを使用してブリッジを作成できます。

あなたの質問を読んで、私はあなたがActiveMQを必要としないと思う。 ブラウザにメッセージを送信するには、webstomp pluginを使用してください。

Answer 2

ブリッジパターンを実装しようとしています。現在、JMSブリッジは通常、JMSメッセージプロバイダ間でメカニズムを提供するために作成された でしたが、統合パターンはワイヤプロトコルにも使用できます。だから、

あなたはActiveMQの間でメッセージを送信しようとしている場合 - RabbitMQのここでの潜在的なオプションです：

1）ActiveMQの - デファクトJMSサポートは、AMQP、STOMPも 2をサポートされている）のRabbitMQ - デファクトSTOMPサポート、AMQPは、また、MQTTのような他の人気のワイヤプロトコルと一緒にサポート

だから、ブリッジングオプションに来るとき：

A）[1] JMS - [2] STOMP（または）AMQP B）[1] AMQP（または）STOMP - [2] AMQP（または）STOMP

1番目と2番目のブリッジオプションの場合、実装する最も簡単な方法はApache QPIDクライアントを使用する方法です。

最も堅牢な構成では、Spring Integration ChannelまたはCamel Routeとして実装する方がよいでしょう。ここで

は、春の統合でこれをacheiveする方法についての抜粋です：

<beans:bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate"> 
     <beans:property name="environment"> 
      <beans:props> 
       <beans:prop key="java.naming.factory.initial">org.jnp.interfaces.NamingContextFactory</beans:prop> 
       <beans:prop key="java.naming.provider.url">jnp://localhost:1099</beans:prop> 
       <beans:prop key="java.naming.factory.url.pkgs">org.jnp.interfaces:org.jboss.naming</beans:prop> 
      </beans:props> 
     </beans:property> 
    </beans:bean> 

    <beans:bean id="jmsQueueConnectionFactory" 
     class="org.springframework.jndi.JndiObjectFactoryBean"> 
     <beans:property name="jndiTemplate"> 
      <beans:ref bean="jndiTemplate"/> 
     </beans:property> 
     <beans:property name="jndiName"> 
      <beans:value>ConnectionFactory</beans:value> 
     </beans:property> 
    </beans:bean> 

    <!-- Channels and adapters for SI --> 

    <int-jms:message-driven-channel-adapter connection-factory="jmsQueueConnectionFactory" destination-name="myJmsQueue" channel="rabbitChannel"/> 
     <channel id="rabbitChannel"/> 
    <int-amqp:outbound-channel-adapter channel="rabbitChannel" exchange-name="fromJmsExchange" amqp-template="rabbitTemplate"/> 

    <!-- Connectivity to Rabbit --> 

    <rabbit:template id="rabbitTemplate" connection-factory="cf"/> 
    <rabbit:connection-factory id="cf" host="localhost"/> 

    <!-- Rabbit entities, to be created at context startup --> 

    <rabbit:admin connection-factory="cf"/> 
    <rabbit:queue name="fromJMS"/> 
    <rabbit:direct-exchange name="fromJmsExchange"> 
     <rabbit:bindings> 
      <rabbit:binding queue="fromJMS"/> 
     </rabbit:bindings> 
    </rabbit:direct-exchange> 

資料出所：http://integrationsphere.blogspot.co.uk/2012/03/bridging-between-jms-and-rabbitmq-amqp.html