xushaomin/dubbo-jms

dubbo-jms

介绍

基于JMS的requestor，实现了一个rpc协议

与具体的JMS Server无关

使用时需要提供一个jms客户端连接的配置（参见example）

1. Consumer ==> JMS Server ==> Provider Request
2. Consumer <== JMS Server <== Provider Reply

服务提供者者配置

<import resource="jms.xml"/>
<dubbo:application name="dubbo-demo-provider"/>
<dubbo:registry address="multicast://224.5.6.7:1234"/>
<dubbo:protocol name="jms" p:queue="#queue" p:queueConnectionFactory="#queueConnectionFactory" id="jms"/> <!-- jms protocol -->
<bean id="demoService" class="com.alibaba.dubbo.examples.rpc.jms.DemoServiceImpl"/>
<dubbo:service ref="demoService" interface="com.alibaba.dubbo.examples.rpc.jms.DemoService" protocol="jms"/>

服务消费者配置

<import resource="jms.xml"/>
<dubbo:application name="dubbo-demo-consumer"/>
<dubbo:registry address="multicast://224.5.6.7:1234"/>
<dubbo:protocol name="jms" p:queue="#queue" p:queueConnectionFactory="#queueConnectionFactory"/>
<dubbo:reference timeout="2000" interface="com.alibaba.dubbo.examples.rpc.jms.DemoService" id="demoService"/>

jms客户端连接配置

<bean class="org.apache.activemq.ActiveMQConnectionFactory" id="queueConnectionFactory">
	    <property name="brokerURL"><value>tcp://localhost:61616</value></property>
</bean>
<bean class="org.apache.activemq.command.ActiveMQQueue" id="queue" autowire="constructor">
    <constructor-arg value="DUBBO"/>
</bean>