RabbitMQ學習之基於spring-rabbitmq的RPC遠程調用

http://blog.csdn.net/zhu_tianwei/article/details/40920985

spring-rabbitmq中實現遠程接口調用，主要在com.rabbitmq.spring.remoting下幾個類：
發布服務端(Server)：RabbitInvokerServiceExporter.java
接口調用客戶端(Client)：RabbitInvokerProxyFactoryBean.java，RabbitInvokerClientInterceptor.java，
RabbitRpcClient.java（對RpcClient的簡單封裝，添加了發送消息時的選項：

mandatory--是否強制發送，immediate--是否立即發送，timeoutMs--超時時間）

實例如下創建自動刪除非持久隊列）：

1.測試服務接口TestService.Java

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc;

/**
 * RPC服務接口
 * @author ztw-pc
 *
 */
public interface TestService {
    String say(String msg);
}

2.測試服務接口實現TestServiceImpl.java

 

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc;

public class TestServiceImpl implements TestService {

    public String say(String msg) {
        return "hello "+msg;
    }
}

 

3..資源配置application.properties

 

#============== rabbitmq config ====================
rabbit.hosts=192.168.36.102
rabbit.username=admin
rabbit.password=admin
rabbit.virtualHost=/
rabbit.exchange=spring-queue-async
rabbit.queue=spring-queue-async
rabbit.routingKey=spring-queue-async

4.服務端配置applicationContext-rabbitmq-rpc-server.xml

 

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       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.5.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd">

     <context:property-placeholder location="classpath:application.properties"/>

     <bean id="rabbitConnectionFactory" class="com.rabbitmq.spring.connection.RabbitConnectionFactory">
        <property name="connectionFactory">
            <bean class="com.rabbitmq.client.ConnectionFactory">
               <property name="username" value="${rabbit.username}"/>
               <property name="password" value="${rabbit.password}"/>
               <property name="virtualHost" value="${rabbit.virtualHost}"/>
            </bean>
        </property>
        <property name="hosts" value="${rabbit.hosts}"/>
    </bean>
     <bean id="rabbitChannelFactory" class="com.rabbitmq.spring.channel.RabbitChannelFactory">
        <property name="connectionFactory" ref="rabbitConnectionFactory"/>
    </bean>

    <bean id="testServiceImpl" class="cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc.TestServiceImpl"/>

    <bean id="testServiceExport" class="com.rabbitmq.spring.remoting.RabbitInvokerServiceExporter">
        <property name="channelFactory" ref="rabbitChannelFactory"/>
        <property name="serviceInterface" value="cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc.TestService"/>
        <property name="service" ref="testServiceImpl"/>
         <property name="exchange" value="${rabbit.exchange}"/>
         <!-- 必須大寫  -->
        <property name="exchangeType" value="TOPIC"/>
        <property name="routingKey" value="${rabbit.routingKey}"/>
        <property name="queueName" value="${rabbit.queue}"/>
        <property name="poolsize" value="5"/>
    </bean>

</beans>

5.客服端配置applicationContext-rabbitmq-rpc-client.xml

 

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       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.5.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd">

     <context:property-placeholder location="classpath:application.properties"/>

     <bean id="rabbitConnectionFactory" class="com.rabbitmq.spring.connection.RabbitConnectionFactory">
        <property name="connectionFactory">
            <bean class="com.rabbitmq.client.ConnectionFactory">
               <property name="username" value="${rabbit.username}"/>
               <property name="password" value="${rabbit.password}"/>
               <property name="virtualHost" value="${rabbit.virtualHost}"/>
            </bean>
        </property>
        <property name="hosts" value="${rabbit.hosts}"/>
    </bean>
     <bean id="rabbitChannelFactory" class="com.rabbitmq.spring.channel.RabbitChannelFactory">
        <property name="connectionFactory" ref="rabbitConnectionFactory"/>
    </bean>

    <bean id="testService" class="com.rabbitmq.spring.remoting.RabbitInvokerProxyFactoryBean">
        <property name="channelFactory" ref="rabbitChannelFactory"/>
        <property name="serviceInterface" value="cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc.TestService"/>
        <property name="exchange" value="${rabbit.exchange}"/>
         <!-- 必須大寫  -->
        <property name="exchangeType" value="TOPIC"/>
        <property name="routingKey" value="${rabbit.routingKey}"/>
        <!--optional-->
        <property name="mandatory" value="true"/>
        <property name="immediate" value="false"/>
        <property name="timeoutMs" value="3000"/>
        <property name="poolSize" value="10"/>
    </bean>

</beans>

6.啟動服務端代碼Server.java

 

 

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Server {

    public static void main(String[] args) {
        new ClassPathXmlApplicationContext("applicationContext-rabbitmq-rpc-server.xml");
    }
}

7.客戶端調用代碼Client.java

 

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.rpc;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Client {

    public static void main(String[] args) {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext-rabbitmq-rpc-client.xml");
        TestService testService = (TestService) context.getBean("testService");
        System.out.println(testService.say(" Tom"));
    }
}

先啟動服務端，再運行客戶端調用。

 

運行結果：hello  Tom

實例代碼：http://download.csdn.net/detail/tianwei7518/8135637