msa-rpc4j-use

Introduction

msa-rpc4j是一款轻量级rpc nio通讯框架，底层通讯采用了netty nio通讯框架，rpc调用速度更快，序列化采用protostuff，序列化速度性能更优，为了保持高可用，采用zookeeper作为 服务注册中心，所以msa-rpc4j是一款具有高性能、高可用的通讯框架。

Quick Start

服务端

step1:引入msa-rpc4j-server

maven:

<dependency>
  <groupId>com.github.microcmpt</groupId>
  <artifactId>msa-rpc-server</artifactId>
  <version>1.0.1</version>
</dependency>

gradle:

compile group: 'com.github.microcmpt', name: 'msa-rpc-server', version: '1.0.1'

step2:定义一个服务端接口HelloRpc4jService

public interface HelloRpc4jService {
    /**
     * Hello string.
     *
     * @param str the str
     * @return the string
     */
    String hello(String str);
}

step3:实现服务端业务逻辑HelloRpc4jServiceImpl类

@RpcService(value = HelloRpc4jService.class)
public class HelloRpc4jServiceImpl implements HelloRpc4jService {
    /**
     * Hello string.
     *
     * @param str the str
     * @return the string
     */
    public String hello(String str) {
        return "Hello, " + str;
    }
}

消费端

step1:引入msa-rpc-client

maven:

<dependency>
  <groupId>com.github.microcmpt</groupId>
  <artifactId>msa-rpc-client</artifactId>
  <version>1.0.1</version>
</dependency>

gradle:

compile group: 'com.github.microcmpt', name: 'msa-rpc-client', version: '1.0.1'

step2:配置RpcClientFactory

ZkServiceDiscovery discovery = new ZkServiceDiscovery();
discovery.setZkAddress("localhost:2181");
RpcClient client = new RpcClient(discovery);
RpcClientFactory factory = new RpcClientFactory(new DefaultInvocationProxy(rpcClient));

step3:通过RpcClientFactory实例创建HelloRpc4jService代理类

HelloRpc4jService client = factory.newClient(HelloRpc4jService.class);
String resp = client.hello("rpc4j");
System.out.println("返回结果:" + resp);

Annotation

@RpcService

@RpcService用于标记该服务为暴露出去的API服务，服务端启动时自动注册到注册中心