six-finger-web
一个Web后端框架的轮子从处理Http请求【基于Netty的请求级Web服务器】 到mvc【接口封装转发)】，再到ioc【依赖注入】，aop【切面】，再到 rpc【远程过程调用】最后到orm【数据库操作】全部自己撸一个（简易）的轮子。
为啥要写这个轮子
其实是这样的，小六六自己平时呢？有时候喜欢看看人家的源码比如Spring,但是小六六的水平可能不怎么样，每次看都看得晕头转向，然后就感觉里面的细节太难了，然后我就只能观其总体的思想，然后我就想我如果可以根据各位前辈的一些思考，自己撸一个简单的轮子出来，那我后面去理解作者的思想是不是简单点呢？于是呢 six-finger-web就面世了，它其实就是我的一个学习过程，然后我把它开源出来，希望能帮助那些对于学习源码有困难的同学。还有就是可以锻炼一下自己的编码能力，因为平时我们总是crud用的Java api都是那些，久而久之，很多框架类的api我们根本就不熟练了，所以借此机会，锻炼一下。
特点
- 内置由 Netty 编写 HTTP 服务器，无需额外依赖 Tomcat 之类的 web 服务（刚好小六六把Netty系列写完，顺便用下）
- 代码简单易懂（小六六自己写不出框架大佬那种高类聚，低耦合的代码），能力稍微强一点看代码就能懂，弱点的也没关系，小六六有配套的从0搭建教程。
- 支持MVC相关的注解确保和SpringMVC的用法类似
- 支持Spring IOC 和Aop相关功能
- 支持类似于Mybatis相关功能
- 支持类似于Dubbo的rpc相关功能
- 对于数据返回，只支持Json格式
絮叨
前面是已经写好的章节，下面我给大家来一一走一遍搭建流程
- 适合初中级Java程序员修炼手册从0搭建整个Web项目（一）
- 适合初中级Java程序员修炼手册从0搭建整个Web项目（二）
- 适合初中级Java程序员修炼手册从0搭建整个Web项目（三）
- 适合初中级Java程序员修炼手册从0搭建整个Web项目（四）
- 适合初中级Java程序员修炼手册从0搭建整个Web项目（五）
我来总结一下前面我们已经完成的，我们已经完成了基于Netty的Http服务器，和springmvc spring ioc,spring aop相关的功能，小六六自我感觉良好，最少也有人加我微信跟小六六一起学习了,那么我今天继续，今天我们先来简简单单的了解一下rpc呗！
RPC简介
RPC（Remote Procedure Call Protocol）远程调用： 远程过程调用是一种常用的分布式网络通信协议,它允许运行于 一台计算机的程序调用另一台计算机的子程序，同时将网络的通信细节隐藏起来， 使得用户无须额外地为这个交互作用编程。分布式系统之间的通信大都通过RPC实现
基本上很多的框架的底层都是用的rpc通信，比如我们熟知的 ES RocktMq 等等 分布式的框架几乎都是，所以自己撸撸RPC框架那就很有必要了呗！
今天小六六想说的是，我们不要说一口气就吃成一个胖子，我们先来实现一个最最最简单的案例，来看看rpc他的一个大致过程，然后我们再照着我们dubbo来写个rpc框架，可能会好很多，所以今天就是给大家来个小案例，带领大家先来看看rpc框架的主流思想。
RPC请求过程
- 注册客户端服务
- 开启rpc服务端
- 客户端以本地的方式来调用服务端
- 客户端代理找到服务端地址,连接服务端,然后将参数、方法等通过发送给服务端
- 服务端接收请求后将数据进行解码,然后根据解码的信息来执行本地程序,并将执行的结果返回给客户端
- 客户端进行解码获取返回的结果
代码
IHello
package com.xiaoliuliu.six.finger.web.demo.rpc.simple.test; /** * @author 小六六 * @version 1.0 * @date 2020/10/30 17:46 * 远程服务接口 */ public interface IHello { String sayHello(String info); } 复制代码
HelloService
package com.xiaoliuliu.six.finger.web.demo.rpc.simple.test; import lombok.Data; /** * @author 小六六 * @version 1.0 * @date 2020/10/30 17:47 * 远程服务接口实现类（Server） */ @Data public class HelloService implements IHello { @Override public String sayHello(String info) { String result = "hello : " + info; System.out.println(result); return result; } } 复制代码
RpcProxyServer 也是服务的暴露过程
package com.xiaoliuliu.six.finger.web.demo.rpc.simple.test; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.lang.reflect.Method; import java.net.ServerSocket; import java.net.Socket; /** * @author 小六六 * @version 1.0 * @date 2020/10/30 17:47 * 服务器代理实现 */ public class RpcProxyServer { private IHello hello = new HelloService(); public void publisherServer(int port) { try (ServerSocket ss = new ServerSocket(port)) { while (true) { try (Socket socket = ss.accept()) { try (ObjectInputStream ois = new ObjectInputStream(socket.getInputStream())) { String method = ois.readUTF(); Object[] objs = (Object[]) ois.readObject(); Class<?>[] types = new Class[objs.length]; for (int i = 0; i < types.length; i++) { types[i] = objs[i].getClass(); } Method m = HelloService.class.getMethod(method, types); Object obj = m.invoke(hello, objs); try (ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream())) { oos.writeObject(obj); oos.flush(); } } } catch (Exception e) { e.printStackTrace(); } } } catch (Exception e) { e.printStackTrace(); } } } 复制代码
RpcProxyClient
package com.xiaoliuliu.six.finger.web.demo.rpc.simple.test; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; import java.lang.reflect.Proxy; import java.net.Socket; /** * @author 小六六 * @version 1.0 * @date 2020/10/31 10:24 * RPC 客户端代理实现 */ public class RpcProxyClient<T> { public static Object proxyClient(Class clazz) { return Proxy.newProxyInstance(clazz.getClassLoader(),new Class[]{clazz},new InvocationHandler() { @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { try (Socket socket = new Socket("localhost", 8000)) { try (ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream())) { oos.writeUTF(method.getName()); oos.writeObject(args); oos.flush(); try (ObjectInputStream ois = new ObjectInputStream(socket.getInputStream())) { return ois.readObject(); } } } } }); } } 复制代码
RpcServer 测试
package com.xiaoliuliu.six.finger.web.demo.rpc.simple.test; /** * @author 小六六 * @version 1.0 * @date 2020/10/31 10:26 */ public class RpcServer { //发布服务 public static void main(String[] args) { RpcProxyServer server = new RpcProxyServer(); server.publisherServer(8000); } } 复制代码
RpcClient
package com.xiaoliuliu.six.finger.web.demo.rpc.simple.test; /** * @author 小六六 * @version 1.0 * @date 2020/10/31 10:26 */ public class RpcClient { // 调用服务 public static void main(String[] args) { IHello hello = (IHello) RpcProxyClient.proxyClient(IHello.class); String s = hello.sayHello("小六六写rpc demo呀"); System.out.println(s); } } 复制代码
结果
结尾
好了，rpc的开头，我们就写完了，其实也很简单，通过代理 和网络通信来屏蔽代码的实现细节，做过调用远程服务和本地服务一样，无感知。后面的话，我们就模仿一下dubbo,来完成它的部分功能，dubbo的人家可不是一个单纯的rpc框架，它致力于服务治理，这个就很广了，我们后面再看。
