A-A+

zbus实现RPC

2017年04月18日 技术 暂无评论 阅读 5,651 次

之前有一篇文章介绍了如何使用ActiveMQ实现RPC，其实使用zbus实现RPC大同小异，因为它们对于业务代码都是无侵入式的，所以区别只在于引用的Jar包和配置文件的不同。

1. 公共包

公共的实体类：

  1. public class User  implements Serializable {
  3.     private String id;
  5.     private String userName;
  7.     public String getUserName() {
  8.         return userName;
  9.     }
  11.     public void setUserName(String userName) {
  12.         this.userName = userName;
  13.     }
  15.     public String getId() {
  16.         return id;
  17.     }
  19.     public void setId(String id) {
  20.         this.id = id;
  21.     }
  22. }

接口服务：

  1. public interface ITestService {
  3.     public String getTestString();
  5.     public User getFirstUser();
  7.     public User getUser(String id);
  8. }

2. 服务端

Maven配置文件：

  1. <!--zubs start-->
  2. <dependency>
  3.     <groupId>org.zbus</groupId>
  4.     <artifactId>zbus</artifactId>
  5.     <version>7.2.0</version>
  6. </dependency>
  7. <!--zubs end-->

Spring配置文件：

  1. <!-- 向 Spring 容器注册注解 -->
  2. <context:component-scan base-package="com.xnck.test.zbus.rpcserver"/>
  4. <!-- 暴露的的接口实现示例 -->
  5. <bean id="testRpcService" class="com.xnck.test.zbus.rpcserver.rpcservice.impl.TestRpcService"></bean>
  7. <bean id="serviceProcessor" class="org.zbus.rpc.RpcProcessor">
  8.     <constructor-arg>
  9.         <list>
  10.             <!-- 放入你需要的暴露的的接口 -->
  11.             <ref bean="testRpcService"/>
  12.         </list>
  13.     </constructor-arg>
  14. </bean>
  16. <bean id="broker" class="org.zbus.broker.SingleBroker">
  17.     <constructor-arg>
  18.         <bean class="org.zbus.broker.BrokerConfig">
  19.             <property name="brokerAddress" value="127.0.0.1:15555" />
  20.             <property name="maxTotal" value="20"/>
  21.             <!-- 这里可以增加连接池参数配置，不配置使用默认值（参考commons-pool2） -->
  22.         </bean>
  23.     </constructor-arg>
  24. </bean>
  26. <!-- 默认调用了start方法，由Spring容器直接带起来注册到zbus总线上 -->
  27. <bean id="myrpcService" class="org.zbus.rpc.mq.Service"  init-method="start">
  28.     <constructor-arg>
  29.         <bean class="org.zbus.rpc.mq.ServiceConfig">
  30.             <!-- 支持多总线注册 -->
  31.             <constructor-arg>
  32.                 <list>
  33.                     <ref bean="broker"/>
  34.                 </list>
  35.             </constructor-arg>
  36.             <property name="mq" value="testRpc"/>
  37.             <property name="consumerCount" value="1"/>
  38.             <property name="messageProcessor" ref="serviceProcessor"/>
  39.             <property name="registerToken" value="123456"/>
  40.             <property name="accessToken" value="111111"/>
  41.             <property name="verbose" value="true" />
  42.         </bean>
  43.     </constructor-arg>
  44. </bean>

实现接口服务：

  1. public class TestRpcService implements ITestRpcService{
  3.     @Autowired
  4.     public ITestService testService;
  7.     public String test() {
  8.         String msg = testService.getTestString();
  9.         return msg;
  10.     }
  12.     public User firstUser(){
  13.         User user = testService.getFirstUser();
  14.         return user;
  15.     }
  17.     public User getUser(String id){
  18.         User user = testService.getUser(id);
  19.         return user;
  20.     }
  21. }

启动服务端：

  1. public static void main(String[] args) {
  2.         ApplicationContext context = new ClassPathXmlApplicationContext("file:" + PathUtil.getRootPath() + "spring-common.xml");
  3.     }

3. 客户端

Maven配置文件：

  1. <!--zubs start-->
  2. <dependency>
  3.   <groupId>org.zbus</groupId>
  4.   <artifactId>zbus</artifactId>
  5.   <version>7.2.0</version>
  6. </dependency>
  7. <!--zubs end-->

Spring配置文件：

  1. <!--rpc start-->
  2. <bean id="broker" class="org.zbus.broker.SingleBroker">
  3.     <constructor-arg>
  4.         <bean class="org.zbus.broker.BrokerConfig">
  5.             <property name="brokerAddress" value="127.0.0.1:15555" />
  6.         </bean>
  7.     </constructor-arg>
  8. </bean>
  10. <bean id="myrpc" class="org.zbus.rpc.RpcFactory">
  11.     <constructor-arg>
  12.         <bean class="org.zbus.rpc.mq.MqInvoker">
  13.             <constructor-arg ref="broker"/>
  14.             <constructor-arg value="testRpc"/>
  15.             <constructor-arg value="111111"/>
  16.         </bean>
  17.     </constructor-arg>
  18. </bean>
  21. <bean id="testRpcService" factory-bean="myrpc" factory-method="getService">
  22.     <constructor-arg type="java.lang.Class" value="com.xnck.test.zbus.rpcclient.rpcservice.ITestRpcService"/>
  23. </bean>
  24. <!--rpc end-->

调用RPC服务：

  1. @Service
  2. public class TestService implements ITestService{
  4.     @Resource(name = "testRpcService")
  5.     public ITestRpcService testRpcService;
  7.     public String getTest() {
  8.         String msg = testRpcService.test();
  9.         return msg;
  10.     }
  12.     public User getUser(String id){
  13.         User user = testRpcService.getUser(id);
  14.         return user;
  15.     }
  16. }
标签：

给我留言

Copyright © 字痕随行 保留所有权利.   Theme  Ality

用户登录

分享到：