RPC 远程调用

目录

  • 配置
  • 开始使用
  • 高级功能

配置

在 Jboot 中，默认实现了对 Dubbo、motan、zbus 的 RPC 调用支持。在使用 RPC 远程调用之前，需要做一些基本的配置。

例如 ：

  1. jboot.rpc.type = dubbo
  2. jboot.rpc.callMode = direct
  3. jboot.rpc.directUrl = 127.0.0.1:8000
  • jboot.rpc.type ： RPC 的类型，不配置默认为 Dubbo
  • jboot.rpc.callMode ： RPC 的调用方式
    • direct ： 直联模式
    • registry ： 注册中心模式（服务注册和服务发现）
  • jboot.rpc.directUrl ： 当 callMode 为 direct 直联模式时，需要配置直联模式的服务器 IP 地址和端口号。

更多的配置请查看

开始使用

一般情况下，RPC 调用需要以下几个步骤：

  • 1、定义接口
  • 2、编写实现类
  • 3、启动 Server 暴露服务
  • 4、启动客户端、通过 RPC 调用 Server 提供的服务

定义接口

  2. public interface BlogService {
  4.     public String findById();
  5.     public List<String> findAll();
  6. }

编写实现类

  3. @RPCBean
  4. public class BlogServiceProvider implements BlogService {
  6.     @Override
  7.     public String findById() {
  8.         return "id from provider";
  9.     }
  11.     @Override
  12.     public List<String> findAll() {
  13.         return Lists.newArrayList("item1","item2");
  14.     }
  15. }

启动 Server 暴露服务

  2. public class DubboServer {
  4.     public static void main(String[] args)  {
  6.         JbootApplication.run(args);
  7.         System.out.println("DubboServer started...");
  9.     }
  10. }

启动客户端、通过 RPC 调用 Server 提供的服务

  2. @RequestMapping("/dubbo")
  3. public class DubboClient extends JbootController{
  5.     public static void main(String[] args)  {
  7.         //Undertow端口号配置
  8.         JbootApplication.setBootArg("undertow.port", "8888");
  10.         JbootApplication.run(args);
  11.     }
  14.     @RPCInject
  15.     private  BlogService blogService;
  17.     public void index() {
  18.         System.out.println(blogService);
  19.         renderText("blogId : " + blogService.findById());
  20.     }
  22. }

高级功能

在以上的示例中，使用到了两个注解：

  • @RPCBean，标示当前服务于RPC服务
  • @RPCInject，RPC注入赋值

虽然以上示例中，@RPCBean 和 @RPCInject 没有添加任何的参数，但实际是他们提供了非常丰富的配置。

以下分别是 @RPCBean 和 @RPCInject 的定义：

RPCBean ：

  2. public @interface RPCBean {
  4.     int port() default 0;
  5.     int timeout() default -1;
  6.     int actives() default -1; 
  7.     String group() default "";
  8.     String version() default "";
  10.     //当一个Service类实现对个接口的时候，
  11.     //可以通过这个排除不暴露某个实现接口
  12.     Class[] exclude() default Void.class;
  13. }

RPCInject ：

  2. public @interface RPCInject {
  4.     int port() default 0;
  5.     int timeout() default -1;
  6.     int retries() default -1;
  7.     int actives() default -1;
  8.     String group() default "";
  9.     String version() default "";
  10.     String loadbalance() default "";
  11.     String async() default "";
  12.     String check() default "";
  13. }