# My-Rpc-FrameWork

**Repository Path**: bookerg/my-rpc-framework

## Basic Information

- **Project Name**: My-Rpc-FrameWork
- **Description**: No description available
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 0
- **Created**: 2022-03-18
- **Last Updated**: 2022-03-19

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# My-Rpc-FrameWork

#### 介绍
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