RPC 远程调用

jboot.rpc.type = dubbo
jboot.rpc.callMode = direct
jboot.rpc.directUrl = 127.0.0.1:8000

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");
    }
}

public class DubboServer {

    public static void main(String[] args)  {

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

    }
}

@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());
    }

}

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;
}

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 "";
}