分享web开发知识

注册/登录|最近发布|今日推荐

主页 IT知识网页技术软件开发前端开发代码编程运营维护技术分享教程案例
当前位置：首页 > 技术分享

简单Tomcat ?HTTP RPC框架

发布时间：2023-09-06 01:13责任编辑：傅花花关键词：暂无标签

RPC基础知识

什么是RPC?

RPC（Remote Procedure Call Protocol）——远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。

RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。

RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

RPC的模型

C/S模式
基于传输层协议(例如TCP/IP) 远程调用不是新的一种数据传输协议
事件响应基本模型(请求、计算、响应)

RPC设计的目的

通过固定的协议调用非本机的方法
提供不同语言程序之间通信
可以在不了解底层通信,像本地方法一样调用

RPC框架完全封装了网络传输以及其他细节,比如Spring的RPC框架在调用远程对象的方法时就像调用Spring Bean对象一样使用.

RPC的应用大量的分布式应用都使用了RPC协议,比如分布式操作系统、分布式计算、分布式软件设计

RPC过程详解

RPC框架封装网络传输和其他细节,消费者和生产者不用去关心底层原理

消费者的代理层控制了整个RPC调用的流程,生成代理对象,封装请求报文,发送请求之类的

服务提供者会有一个监听模块,用来监听请求,并且按照约定,应该是注册了的服务才会被消费者调用到,注册的服务需要被反射调用到,用来计算结果

RPC框架的特点和设计模型

封装网络交互

尽量不要让RPC框架的使用者涉及到过多的网络层的开发

远程调用对象的代理

将接口代理的对象放入到Spring 容器之中,方便服务端开发

支持容器(Spring、Jetty等)

支持Spring容器,还有Jetty这样的web容器

可配置,可扩展

尽量做到可配置,可扩展

设计模型

Proxy代理层

用于对象的代理,对象的反射调用,RPC流程的控制

Serialize序列化层

将请求和结果做序列化和反序列化

Invoke网络模块

网络通信相关的处理

Container容器组件

支持代理层监听网络请求

代码实现

pom.xml

[html]view plaincopy
  1. <projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd">
  2. <modelVersion>4.0.0</modelVersion>
  3. <groupId>com.ibigsea</groupId>
  4. <artifactId>http-rpc</artifactId>
  5. <version>0.0.1-SNAPSHOT</version>
  7. <dependencies>
  8. <dependency>
  9. <groupId>com.alibaba</groupId>
  10. <artifactId>fastjson</artifactId>
  11. <version>1.2.3</version>
  12. </dependency>
  13. <dependency>
  14. <groupId>ch.qos.logback</groupId>
  15. <artifactId>logback-classic</artifactId>
  16. <version>1.0.13</version>
  17. </dependency>
  18. <dependency>
  19. <groupId>org.mortbay.jetty</groupId>
  20. <artifactId>jetty</artifactId>
  21. <version>6.1.26</version>
  22. </dependency>
  23. <dependency>
  24. <groupId>org.apache.httpcomponents</groupId>
  25. <artifactId>httpcore</artifactId>
  26. <version>4.3.3</version>
  27. </dependency>
  28. <dependency>
  29. <groupId>org.apache.httpcomponents</groupId>
  30. <artifactId>httpclient</artifactId>
  31. <version>4.3.6</version>
  32. <exclusions>
  33. <exclusion>
  34. <artifactId>commons-logging</artifactId>
  35. <groupId>commons-logging</groupId>
  36. </exclusion>
  37. </exclusions>
  38. </dependency>
  39. <dependency>
  40. <groupId>org.springframework</groupId>
  41. <artifactId>spring-context</artifactId>
  42. <version>3.2.8.RELEASE</version>
  43. <exclusions>
  44. <exclusion>
  45. <artifactId>commons-logging</artifactId>
  46. <groupId>commons-logging</groupId>
  47. </exclusion>
  48. </exclusions>
  49. </dependency>
  50. <dependency>
  51. <groupId>commons-logging</groupId>
  52. <artifactId>commons-logging</artifactId>
  53. <version>1.2</version>
  54. </dependency>
  55. </dependencies>
  56. </project>

config包下面的

ConsumerConfig.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.config;
  3. /**
  4. *服务消费者配置
  5. *
  6. *@authorbigsea
  7. *
  8. */
  9. publicclassConsumerConfig{
  11. /**
  12. *请求地址服务提供者监听的地址和端口
  13. */
  14. privateStringurl;
  16. publicStringgetUrl(){
  17. returnurl;
  18. }
  20. publicvoidsetUrl(Stringurl){
  21. this.url=url;
  22. }
  24. }

ProviderConfig.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.config;
  3. /**
  4. *服务提供者配置
  5. *
  6. *@authorbigsea
  7. *
  8. */
  9. publicclassProviderConfig{
  11. /**
  12. *监听端口服务提供者监听请求端口
  13. */
  14. privateintport;
  16. publicProviderConfig(){
  17. }
  19. publicProviderConfig(intport){
  20. this.port=port;
  21. }
  23. publicintgetPort(){
  24. returnport;
  25. }
  27. publicvoidsetPort(intport){
  28. this.port=port;
  29. }
  31. }

序列化层

Request.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.serizlize;
  3. importjava.io.Serializable;
  5. importcom.alibaba.fastjson.annotation.JSONType;
  7. /**
  8. *请求信息
  9. *
  10. *@authorbigsea
  11. *
  12. */
  13. publicclassRequestimplementsSerializable{
  15. privatestaticfinallongserialVersionUID=-4363326153251862952L;
  17. privateClassclazz;
  19. privateStringmethod;
  21. privateObjectparam;
  23. publicRequest(){
  24. }
  26. publicRequest(Classclazz,Stringmethod,Objectparam){
  27. this.clazz=clazz;
  28. this.method=method;
  29. this.param=param;
  30. }
  32. publicClassgetClazz(){
  33. returnclazz;
  34. }
  36. publicvoidsetClazz(Classclazz){
  37. this.clazz=clazz;
  38. }
  40. publicStringgetMethod(){
  41. returnmethod;
  42. }
  44. publicvoidsetMethod(Stringmethod){
  45. this.method=method;
  46. }
  48. publicObjectgetParam(){
  49. returnparam;
  50. }
  52. publicvoidsetParam(Objectparam){
  53. this.param=param;
  54. }
  56. /**
  57. *通过反射执行对应的方法
  58. *
  59. *@parambean
  60. *@return
  61. *@throwsException
  62. */
  63. publicObjectinvoke(Objectbean)throwsException{
  64. returnclazz.getMethod(method,param.getClass()).invoke(bean,param);
  65. }
  67. }

JsonParser.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.serizlize;
  3. importcom.alibaba.fastjson.JSON;
  4. importcom.alibaba.fastjson.parser.ParserConfig;
  5. importcom.alibaba.fastjson.serializer.SerializerFeature;
  7. /**
  8. *反序列化
  9. *
  10. *@authorbigsea
  11. *
  12. */
  13. publicclassJsonParser{
  14. /**
  15. *反序列化请求将请求反序列化成一个请求报文
  16. *
  17. *@paramparam
  18. *@return
  19. */
  20. publicstaticRequestreqParse(Stringparam){
  21. returnJSON.parseObject(param,Request.class);
  22. }
  24. /**
  25. *反序列化响应将响应反序列化成一个响应报文
  26. *
  27. *@paramresult
  28. *@return
  29. */
  30. publicstatic<T>TresbParse(Stringresult){
  31. return(T)JSON.parse(result);
  32. }
  34. }

JsonFormatter.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.serizlize;
  3. importcom.alibaba.fastjson.JSON;
  4. importcom.alibaba.fastjson.parser.ParserConfig;
  5. importcom.alibaba.fastjson.serializer.SerializerFeature;
  7. /**
  8. *序列化
  9. *
  10. *@authorbigsea
  11. *
  12. */
  13. publicclassJsonFormatter{
  15. /**
  16. *将请求序列化成字符串
  17. *
  18. *@paramclazz
  19. *@parammethod
  20. *@paramparam
  21. *@return
  22. */
  23. publicstaticStringreqFormatter(Classclazz,Stringmethod,Objectparam){
  24. Requestrequest=newRequest(clazz,method,param);
  25. returnJSON.toJSONString(request,SerializerFeature.WriteClassName);
  26. }
  28. /**
  29. *将响应序列化成字符串
  30. *
  31. *@paramparam
  32. *@return
  33. */
  34. publicstaticStringresbFormatter(Objectparam){
  35. returnJSON.toJSONString(param,SerializerFeature.WriteClassName);
  36. }
  38. }


http容器 httpContainer.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.container;
  3. importorg.mortbay.jetty.Connector;
  4. importorg.mortbay.jetty.Server;
  5. importorg.mortbay.jetty.handler.AbstractHandler;
  6. importorg.mortbay.jetty.nio.SelectChannelConnector;
  7. importorg.slf4j.Logger;
  8. importorg.slf4j.LoggerFactory;
  10. importcom.ibigsea.rpc.config.ProviderConfig;
  12. /**
  13. *利用Jetty实现简单的嵌入式Httpserver
  14. *
  15. *@authorbigsea
  16. *
  17. */
  18. publicclassHttpContainer{
  20. privateLoggerLOG=LoggerFactory.getLogger(HttpContainer.class);
  22. privateAbstractHandlerhttpHandler;
  23. privateProviderConfigproviderConfig;
  25. /**
  26. *构造方法
  27. *
  28. *@paramhttpHandler
  29. */
  30. publicHttpContainer(AbstractHandlerhttpHandler){
  31. this(httpHandler,newProviderConfig(8080));
  32. }
  34. /**
  35. *构造方法
  36. *
  37. *@paramhttpHandler
  38. *@paramproviderConfig
  39. */
  40. publicHttpContainer(AbstractHandlerhttpHandler,ProviderConfigproviderConfig){
  41. this.httpHandler=httpHandler;
  42. this.providerConfig=providerConfig;
  43. }
  45. publicvoidstart(){
  46. //进行服务器配置
  47. Serverserver=newServer();
  48. try{
  49. SelectChannelConnectorconnector=newSelectChannelConnector();
  50. //设置监听端口
  51. connector.setPort(providerConfig.getPort());
  52. //设置handler,请求过来之后通过该handler来处理请求
  53. server.setHandler(httpHandler);
  54. server.setConnectors(newConnector[]{connector});
  55. server.start();
  56. LOG.info("容器启动~");
  57. }catch(Exceptione){
  58. LOG.error("容器启动异常~",e);
  59. }
  61. }
  63. }

RpcException.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.exception;
  3. /**
  4. *异常
  5. *
  6. *@authorbigsea
  7. *
  8. */
  9. publicclassRpcExceptionextendsThrowable{
  10. privateObjectdata;
  12. publicRpcException(Stringmessage,Throwablecause,Objectdata){
  13. super(message,cause);
  14. this.data=data;
  15. }
  17. publicRpcException(Objectdata){
  18. super();
  19. this.data=data;
  20. }
  22. publicObjectgetData(){
  23. returndata;
  24. }
  25. }

HttpInvoke.java

[java]view plaincopy
  1. packagecom.ibigsea.rpc.invoke;
  3. importjava.io.OutputStream;
  4. importjava.util.ArrayList;
  5. importjava.util.List;
  7. importorg.apache.http.HttpHost;
  8. importorg.apache.http.HttpResponse;
  9. importorg.apache.http.NameValuePair;
  10. importorg.apache.http.client.HttpClient;
  11. importorg.apache.http.client.entity.UrlEncodedFormEntity;
  12. importorg.apache.http.client.methods.HttpPost;
  13. importorg.apache.http.conn.routing.HttpRoute;
  14. importorg.apache.http.impl.client.HttpClients;
  15. importorg.apache.http.impl.conn.PoolingHttpClientConnectionManager;
  16. importorg.apache.http.message.BasicNameValuePair;
  17. importorg.apache.http.util.EntityUtils;
  19. importcom.ibigsea.rpc.config.ConsumerConfig;
  20. importcom.ibigsea.rpc.exception.RpcException;
  22. /**
  23. *http请求和响应处理
  24. *
  25. *@authorbigsea
  26. *
  27. */
  28. publicclassHttpInvoke{
  30. privatestaticfinalHttpClienthttpClient=getHttpClient();
  32. /**
  33. *单例
  34. */
  35. privatestaticHttpInvokehttpInvoke;
  37. privateHttpInvoke(){
  39. }
  41. publicstaticsynchronizedHttpInvokegetInstance(){
  42. if(httpInvoke==null){
  43. httpInvoke=newHttpInvoke();
  44. }
  45. returnhttpInvoke;
  46. }
  48. /**
  49. *发送请求
  50. *
  51. *@paramrequest
  52. *服务消费者将(类信息、方法、参数)封装成请求报文,序列化后的字符串
  53. *@paramconsumerConfig
  54. *服务消费者请求的地址
  55. *@return请求结果
  56. *@throwsRpcException
  57. */
  58. publicStringrequest(Stringrequest,ConsumerConf

知识推荐

我的编程学习网——分享web前端后端开发技术知识。 垃圾信息处理邮箱 tousu563@163.com 网站地图
icp备案号 闽ICP备2023006418号-8 不良信息举报平台 互联网安全管理备案 Copyright 2023 www.wodecom.cn All Rights Reserved