My-RPC-Framework 是一款基于 Nacos 实现的 RPC 框架。网络传输实现了基于 Java 原生 Socket 与 Netty 版本，并且实现了多种序列化。
根据实际调用需求，可选择基于 Java 原生 Socket，该步骤基于 BIO 实现。选择基于 Netty 的传输方法，则基于 NIO 实现。Nacos 实现服务的注册和提供服务地址的功能。不同序列化满足不同层面的需求：JSON，Hessian，Kryo 等框架。
.rpc-api —— 调用接口
.rpc-common —— 工具类
.rpc-core —— 传输类
.rpc-client —— 消费端测试
.rpc-server —— 服务端测试
通用接口
public interface HelloService {
String hello(String name);
}
接口实现
public class HelloServiceImpl implements HelloService{
@Override
public String hello(HelloObject object){
logger.info("接受到：{}",object.getMessage());
return "调用返回值，id = " + object.getId();
}
}
Socket 服务端(先开)
public class SocketTestServer {
public static void main(String[] args) {
HelloService helloService = new HelloServiceImpl();
SocketServer socketServer = new SocketServer("127.0.0.1", 9998);
socketServer.setSerializer(new HessianSerializer());
socketServer.publishService(helloService, HelloService.class);
}
}
Socket 消费端（后开）
public class SocketTestClient {
public static void main(String[] args) {
SocketClient client = new SocketClient();
client.setSerializer(new HessianSerializer());
RpcClientProxy proxy = new RpcClientProxy(client);
HelloService helloService = proxy.getProxy(HelloService.class);
HelloObject object = new HelloObject(12, "This is a message");
String res = helloService.hello(object);
System.out.println(res);
}
}
Netty 服务端
public class NettyTestServer {
public static void main(String[] args) {
HelloService helloService = new HelloServiceImpl();
NettyServer server = new NettyServer("127.0.0.1", 9999);
server.setSerializer(new ProtobufSerializer());
server.publishService(helloService, HelloService.class);
}
}
Netty 消费端
public class NettyTestClient {
public static void main(String[] args) {
RpcClient client = new NettyClient();
client.setSerializer(new ProtobufSerializer());
RpcClientProxy rpcClientProxy = new RpcClientProxy(client);
HelloService helloService = rpcClientProxy.getProxy(HelloService.class);
HelloObject object = new HelloObject(12, "This is a message");
String res = helloService.hello(object);
System.out.println(res);
}
}
https://blog.csdn.net/qq_40856284/category_10138756.html https://github.com/CN-GuoZiyang/My-RPC-Framework
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent