Score
0
Watch 782 Star 2.3K Fork 688

GVPfuhai / jbootJavaApache-2.0

Join us
Explore and code with more than 2 million developers,Free private repositories !:)
Sign up
SpringCloud 之外的另一个选择,已经使用在用户量过亿的商业产品上,有超过1000家公司在使用Jboot做极速开发... spread retract

Clone or download
rpc.md 3.09 KB
Copy Edit Web IDE Raw Blame History
fuhai authored 2019-10-15 18:02 . update docs

RPC 远程调用

目录

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

配置

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

例如 :

jboot.rpc.type = dubbo
jboot.rpc.callMode = direct
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 地址和端口号。

更多的配置请查看 config.md

开始使用

一般情况下,RPC 调用需要以下几个步骤:

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

定义接口


public interface BlogService {

    public String findById();
    public List<String> findAll();
}

编写实现类



@RPCBean
public class BlogServiceProvider implements BlogService {

    @Override
    public String findById() {
        return "id from provider";
    }

    @Override
    public List<String> findAll() {
        return Lists.newArrayList("item1","item2");
    }
}

启动 Server 暴露服务


public class DubboServer {

    public static void main(String[] args)  {

        JbootApplication.run(args);
        System.out.println("DubboServer started...");

    }
}

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


@RequestMapping("/dubbo")
public class DubboClient extends JbootController{

    public static void main(String[] args)  {

        //Undertow端口号配置
        JbootApplication.setBootArg("undertow.port", "8888");

        JbootApplication.run(args);
    }


    @RPCInject
    private  BlogService blogService;

    public void index() {
        System.out.println(blogService);
        renderText("blogId : " + blogService.findById());
    }

}

高级功能

在以上的示例中,使用到了两个注解:

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

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

以下分别是 @RPCBean@RPCInject 的定义:

RPCBean :


public @interface RPCBean {

    int port() default 0;
    int timeout() default -1;
    int actives() default -1; 
    String group() default "";
    String version() default "";

    //当一个Service类实现对个接口的时候,
    //可以通过这个排除不暴露某个实现接口
    Class[] exclude() default Void.class;
}

RPCInject :


public @interface RPCInject {

    int port() default 0;
    int timeout() default -1;
    int retries() default -1;
    int actives() default -1;
    String group() default "";
    String version() default "";
    String loadbalance() default "";
    String async() default "";
    String check() default "";
}

Comment ( 0 )

Sign in for post a comment

Java
1
https://gitee.com/fuhai/jboot.git
git@gitee.com:fuhai/jboot.git
fuhai
jboot
jboot
master

Help Search