网站络,全网关键词搜索排行,天气预报权威发布,自适应主题 wordpress为什么学习Hessian RPC#xff1f;
存粹的RPC#xff0c;只解决PRC的四个核心问题#xff08;1.网络通信2.协议 3.序列化 4.代理#xff09;Java写的HessianRPC落伍了#xff0c;但是它的序列化方式还保存着#xff0c;被Dubbo(Hessian Lite)使用。 被落伍#xff0c;只…为什么学习Hessian RPC
存粹的RPC只解决PRC的四个核心问题1.网络通信2.协议 3.序列化 4.代理Java写的HessianRPC落伍了但是它的序列化方式还保存着被Dubbo(Hessian Lite)使用。 被落伍只是因为Hessian RPC出的比较早当时没有注册中心熔断限流等。所以当我们学习PRC时最好学一个简单的存粹的没有其他的额外功能。
Hessian 的概念
Hession 是Resin服务器的伴生产品。基于Java编程语言设计的RPC框架只支持Java编程语言使用现在新出的gRPC Thrift支持多语言。Hessian的序列化是二进制的。
Hessian设计思想
Hessian使用的resin服务器类似于Tomcat使用的是HTTP协议由于使用的是JDK做代理所以必须要用接口定义调用类。对象的数据类型必须要实现Serliazble。服务的发布需要使用HessanServlet进行配置在web.xml进行配置。 那么如何进行调用配置的服务客户端进行代理HessianProxyFactory做代理服务。
RPC的开发
引入依赖
dependenciesdependencygroupIdjunit/groupIdartifactIdjunit/artifactIdversion4.13.1/versionscopetest/scope/dependencydependencygroupIdjavax.servlet/groupIdartifactIdjavax.servlet-api/artifactIdversion3.1.0/versionscopeprovided/scope/dependencydependencygroupIdorg.slf4j/groupIdartifactIdslf4j-api/artifactIdversion1.7.32/version/dependencydependencygroupIdch.qos.logback/groupIdartifactIdlogback-classic/artifactIdversion1.2.9/version/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.22/version/dependencydependencygroupIdcom.caucho/groupIdartifactIdhessian/artifactIdversion4.0.38/version/dependency
/dependencies开发服务端
1. 开发Service
2. DAO --- Mybaits
注意一定要定义Service的接口自定义的数据类型实现Serliazliable模拟一下登录功能 实体类
Data
ToString
NoArgsConstructor
AllArgsConstructor
public class User implements Serializable {private static final long serialVersionUID 1L;private String name;private String password;
}Service
public interface UserService {public boolean login(String username,String password);public void register(User user);}ServrceImpl
Slf4j
public class UserServiceImpl implements UserService {Overridepublic boolean login(String username, String password) {log.debug(login method invoke name {} password {},username,password);return false;}Overridepublic void register(User user) {log.debug(register method invoke user {},user);}
}配置web.xml servletservlet-nameuserServiceRPC/servlet-nameservlet-classcom.caucho.hessian.server.HessianServlet/servlet-classinit-paramparam-namehome-api/param-nameparam-valuecom.liu.service.UserService/param-value/init-paraminit-paramparam-namehome-class/param-nameparam-valuecom.liu.service.UserServiceImpl/param-value/init-param/servletservlet-mappingservlet-nameuserServiceRPC/servlet-nameurl-pattern/userServiceRPC/url-pattern/servlet-mapping客户端开发
Slf4j
public class HessianRPCClient {public static void main(String[] args) throws MalformedURLException {// TODOHessianProxyFactory factory new HessianProxyFactory();String urlName http://localhost:8080/rpc_hessian/userServiceRPC;UserService userService (UserService) factory.create(UserService.class, urlName);boolean login userService.login(liu, 123456);log.debug(userService value is {},login);}
}HessianRPC核心源码分析
1. HessianRPC client创建代理的方式 JDK Proxy.newProxyInstance()public Object create(Class? api, URL url, ClassLoader loader){if (api null)throw new NullPointerException(api must not be null for HessianProxyFactory.create());InvocationHandler handler null;handler new HessianProxy(url, this, api);return Proxy.newProxyInstance(loader,new Class[] { api,HessianRemoteObject.class },handler);}2. 代理中 通过网络 Http请求 连接 远端RPC服务通过流 数据写出去了。HessianProxy#invoke() 1.通过 URLConnection 进行网络连接 2.解析协议 传递数据Hessian序列化
前面说了Hessian已经落伍了但他的序列化方式还保留着我们看看怎么使用的。 // 1. 序列化OutputStream outputStream new FileOutputStream(D:\\StudyCodes\\rpc_lession\\rpc_hessian\\test);Hessian2Output hessian2Output new Hessian2Output(outputStream);hessian2Output.writeObject(new User(liu, 123456));hessian2Output.flush();outputStream.close();// 2. 反序列化InputStream inputStream new FileInputStream(D:\\StudyCodes\\rpc_lession\\rpc_hessian\\test);Hessian2Input hessian2Input new Hessian2Input(inputStream);User user (User) hessian2Input.readObject();System.out.println(user);inputStream.close();log.info(user: {}, user);
