Rpc客户端 （负责构建netty客户端启动类，向rpc服务端发送请求）
Rpc客户端通道初始化器，用来给通信管道设置各种处理器的
Rpc接口包扫描·注解
Rpc 自动注入 注解
rpc service bean 注入元数据
AOP
自动装配rpc-client包中的bean
动态代理，真正实现被代理"对象"的方法调用的处理器
+ * + * 第一种代理方式: 通过FactoryBean的方式，代理时机，在注册bean定义的时候，"篡改"接口的class + * + * 个性化定制rpc service bean + * （动态代理接口，使得客户端可以在本地直接使用接口调用远程的方法，让用户完全感觉不出来！！） + * + * 这种使用方式有个局限性，就是如果接口有多个实现， + *
+ * 第二种代理方法：使用jdk自带的Proxy类来创建接口类型bean的代理对象 + * 代理时机：借助我们自定义的注入注解@RpcAutowired，复写bean后置处理器（实现BeanPostProcessor接口） + * 的postProcessBeforeInitialization方法，找到带有@RpcAutowired的field，然后对field进行动态代理 + *
bean实例化/初始化前后感知类增强器，这个类在这个框架里可以忽略，是基于Spring的测试类，就是玩的
+ * 动态注册BeanDefinition到ioc容器：定制化 rpc service bean definition + * 里面很关键的一点就是：利用我们自定义的bean包扫描类，对候选bean定义进行条件放行， + * 比如对接口类型的bean定义进行放行，同时，对放行后的bean定义进行修改， + * 将其原有的接口类型指向为一个FactoryBean类型，完成bean的华丽转身！！！ + *
自定义rpc service bean definition 扫描器（主要放开接口不能被作为bd的条件）
+ * Spring 上下文工具类（简单版）：利用Spring（观察者模式）上下文监听器， + * 对上下文刷新完事件进行监听，以回调onApplicationEvent方法顺便拿到全局的Spring的context对象 + *
消息解码器(字节流转消息)
消息编码器(消息对象转byte)
接口未发现
Rpc服务bean未发现异常
+ * RPC消息传输协议，防止客户端与服务端通信时，获取tcp数据包时，出现粘包和拆包的问题 + * 出现原因： + * 1、TCP是基于字节流的，虽然应用层和TCP传输层之间的数据交互是大小不等的数据块， + * 但TCP却把这些数据块仅仅看成是一连串无结构的字节流，没有边界； + * 2、从TCP自身的帧结构上可以看出来，在TCP的首部是没有表示数据长度的字段的 + * 解决办法：那就在传输消息的时候，人为（手动）的带上字节流的长度len，编解码器每次按"需"处理即可 + * （白话：兄弟，我给你寄了2箱苹果，里面总过有125个，我给你放在物业了哈） + *
日期格式化工具类/p> + * + * @author appleyk + * @version V.0.1.1 + * @blob https://blog.csdn.net/appleyk + * @date created on 下午10:03 2021/5/22 + */ +public class DateUtils { + public static final String DEFAULT_FORMAT = "yyyy-MM-dd HH:mm:ss";// 时间格式 + public static String date2Str(Date date){ + SimpleDateFormat format = new SimpleDateFormat(DEFAULT_FORMAT); + return format.format(date); + } + public static String dateNow2Str(){ + return date2Str(new Date()); + } + public static void main(String[] args) { + System.out.println(date2Str(new Date())); + } +} diff --git a/rpc-common/src/main/java/com/appleyk/rpc/common/util/GeneralUtils.java b/rpc-common/src/main/java/com/appleyk/rpc/common/util/GeneralUtils.java new file mode 100644 index 0000000..7716ddb --- /dev/null +++ b/rpc-common/src/main/java/com/appleyk/rpc/common/util/GeneralUtils.java @@ -0,0 +1,65 @@ +package com.appleyk.rpc.common.util; + +import java.util.*; + +/*** + * 通用（判断数据是否空）工具类 + */ +public class GeneralUtils { + + public static boolean isNotEmpty(Object object) { + if (object == null) { + return false; + } else if (object instanceof Integer) { + return Integer.valueOf(object.toString()) > 0; + } else if (object instanceof Long) { + return Long.valueOf(object.toString()) > 0L; + } else if (object instanceof String) { + return ((String)object).trim().length() > 0; + } else if (object instanceof StringBuffer) { + return ((StringBuffer)object).toString().trim().length() > 0; + } else if (object instanceof Boolean) { + return Boolean.valueOf(object.toString()); + } else if (object instanceof List) { + return ((List)object).size() > 0; + } else if (object instanceof Set) { + return ((Set)object).size() > 0; + } else if (object instanceof Map) { + return ((Map)object).size() > 0; + } else if (object instanceof Iterator) { + return ((Iterator)object).hasNext(); + } else if (object.getClass().isArray()) { + return Arrays.asList(object).size() > 0; + } else { + return true; + } + } + + public static boolean isEmpty(Object object) { + if (object == null) { + return true; + } else if (object instanceof Integer) { + return Integer.valueOf(object.toString()) == 0; + } else if (object instanceof Long) { + return Long.valueOf(object.toString()) == 0L; + } else if (object instanceof String) { + return ((String)object).trim().length() == 0; + } else if (object instanceof StringBuffer) { + return ((StringBuffer)object).toString().trim().length() == 0; + } else if (object instanceof Boolean) { + return Boolean.valueOf(object.toString()); + } else if (object instanceof List) { + return ((List)object).size() == 0; + } else if (object instanceof Set) { + return ((Set)object).size() == 0; + } else if (object instanceof Map) { + return ((Map)object).size() == 0; + } else if (object instanceof Iterator) { + return !((Iterator)object).hasNext(); + } else if (object.getClass().isArray()) { + return Arrays.asList(object).size() == 0; + } else { + return false; + } + } +} diff --git a/rpc-common/src/main/java/com/appleyk/rpc/common/util/IdUtils.java b/rpc-common/src/main/java/com/appleyk/rpc/common/util/IdUtils.java new file mode 100644 index 0000000..27baf27 --- /dev/null +++ b/rpc-common/src/main/java/com/appleyk/rpc/common/util/IdUtils.java @@ -0,0 +1,15 @@ +package com.appleyk.rpc.common.util; + +/** + *
ID工具类，简单起见，就返回时间戳吧，不想搞什么雪花分布式ID了
基于protostuff进行对象的序列化和反序列化
在接口实现类上加上该注解，使其具有rpc和spring bean的功能
封装RPC请求对象
封装RPC响应对象
+ * + * CGLib中提供的FastClass增强功能， + * FastClass顾名思义是一个能让被增强类更快调用的Class， + * 主要针对调用方法是变量的场景，用于替代反射调用 + * + *
服务发现接口
服务注册接口
zk客户端自动配置类
基于ZK实现的服务注册与发现中心
+ * CuratorFramework 是Netflix公司开发的一款连接zookeeper服务的框架， + * 提供了比较全面的功能，除了基础的节点的操作，节点的监听，还有集群的连接以及重试。 + *
RPC 服务端 ==> 绑定ip、端口、配置、启动netty服务...etc
Rpc服务端通道处理器
RPC服务端通道消息处理器
rpc-server's beans 自动装配
订单（接口）服务
订单
RPC客户端用例启动类,项目启动后浏览器输入：http://localhost:8066/swagger-ui.html
+ * Rpc"代理"配置，主要是扫描公共接口包， + * 改写spring扫描bean定义的条件，然后借助FactoryBean实现动态代理 + *
RPC服务消费端接口用例测试
全局（API）异常拦截类，有异常了，把异常返回给Client，而不是将异常留在Server端
Netty·ByteBuf对象使用，其封装了NIO的ByteBuffer对象，使其API更好操作
Rpc service bean 测试
zk服务注册和发现中心功能测试
RPC服务端用例启动类
Rpc服务端，XXXX接口实现类 ==> MB模拟
订单服务实现类
Rpc服务端，XXXX接口实现类