基本架构

1. client-ui: 客户端
2. crpc-server: 服务端
3. crpc-common: 公共模块

crpc-client: 客户端

问题汇总

2024-03-06 负载均衡索引超长导出方法执行异常

1. 正确处理索引超长问题
2. 添加异常处理及重试机制

crpc-common：公共模块

一、ObjectResolution 对象解析器

主要时通过反射将对象解析为 json 格式，在 CRPC 客户端服务测试时使用

方法：

String json = ObjectResolution.getObjectResolution(Class<?> tClass);

实例

@Data
public class P {
    private String name;
    private int age;
    private P father;
    private List<P> friend;
    private F f;
    private List<F> flist;
}

@Data
public class F {
    private String name;
    private int age;
}

解析结果

{
  "name":"0",
  "age":"0",
  "father":{},
  "friend":[
    {},
  ],
  "f":{
    "name":"0",
    "age":"0",
  },
  "flist":[
    {
      "name":"0",
      "age":"0",
    },
  ]
}

问题

1. 两个对象相互调用时，会导致无限递归，需要处理

思路1：使用全路径记录对象是否已经使用过，但是这样会导致解析结果变少

二、CrpcConfigUtils Application.yml 解析

解析 application.yml 获取 CRPC 配置信息

三、UniqueIdGenerator 唯一 ID 生成器

最多支持 32 个节点 （0 - 31） 每个节点每毫秒最多生成 4096 个 ID

方法

方法	说明
void setWorkerId(long workerId)	设置机器码（0-31）
String generateUniqueIdLong()	生成 Long 类型 10 进制 ID
String generateUniqueIdHex()	生成 String 类型 16 进制 ID
String generateUniqueIdBinary()	生成 String 类型 2 进制 ID
String generateUniqueId()	生成 String 类型 10 进制 ID

四、balance 负载均衡

确定唯一服务的标识 ip + port
权重负载均衡 weight
区域负载均衡 area

接口：LoadBalancing
方法：String loadBalancing(); 获取服务标识
实现类（1）：RandomLoadbalancing 随机负载均衡
实现类（2）：WeightLoadBalancing 基于权重的负载均衡

五、CrpcRegisterCenter 服务注册中心

CrpcRegisterCenter 方法

方法	说明
static void connect(String... connectStrings)	连接注册中心
static void close()	关闭注册中心
static String createTemporaryOrder(String path, byte[] data)	创建临时节点
static void update(String path, byte[] data)	更新节点
static byte[] get(String path)	获取节点信息
static boolean checkExists(String path)	检查节点是否存在
static void delete(String path)	删除节点

Stat CreateMode Void 等应改为自定义信息，不然后期不好拓展
CuratorListener 监听节点变化

六、NetWork

1. NettyServer Netty服务
2. RpcRequest & RpcResponse CRPC 请求和响应

七、ServerMap & ServerInvoke

1. ServerMap Bean 存储
2. ServerInvoke Bean 调用

八、RPC 服务注册

@Component("CenterService")
@ServerRegister(className = "CenterService", 
        version = "V1")
public class CenterService {

}

九、RPC 服务调用（Java）

@ServerRegister(serverName = "CrpcServer", 
        className = "CenterService", 
        version = "V1")
public interface CenterService {
}

CenterService centerService = ServiceAgent
        .createService(CenterService.class);

八、RPC 服务调用（HTTP）

{http/https}://{ip}:{port}

{
    "id": 0,
    "token": "",
    "serverName": "",
    "className": "",
    "methodName": "",
    "data": {}
}