定义接口及实现

• 对接口没有任何要求，只要是java接口就行

  public interface RpcDemoIntf {
    public String sayStr(String name);
    public void sayInt(int id);
  }
  

• 实现类需要加上@RpcService，像下面这样，同时必须有一个无参构造函数

  @RpcService
  public class RpcDemoImpl implements RpcDemoIntf {
    private static Logger                                            log        = LoggerFactory.getLogger(RpcDemoImpl.class);
    private static final java.util.concurrent.atomic.AtomicInteger    reqno    = new AtomicInteger();
  
    @Override
    public String sayStr(String name) {
        log.info("tio rpc success " + name + ", no:" + reqno.incrementAndGet());
        return "tio rpc success ";
    }
  
    @Override
    public void sayInt(int id) {
        log.info("收到id：" + id + ", no:" + reqno.incrementAndGet());
    }
  }
  

注册服务

• 注册服务前，先要启动t-io集群的客户端，然后调用注解扫描程序，即可完成注册

  // 注册RPC服务
  RpcApi.scan(new String[] { RpcDemoImpl.class.getPackage().getName() }, this.getClientTioConfig());
  

调用服务

• 也是一行代码的事

  RpcDemoIntf rpcDemo = RpcApi.getBean(RpcDemoIntf.class, clientTioConfig);
  rpcDemo.sayStr("tan yao wu");