自定义实现一个RPC框架（五）

忘是亡心i 2023-02-13 11:51 14阅读 0赞

### 文章目录 ###

*  自定义实现一个RPC框架（五）：
 *   *   *  地址：https://gitee.com/liyunfengfengfeng/rpc
         *  基于HTTP来实现

# 自定义实现一个RPC框架（五）： #

### 地址：https://gitee.com/liyunfengfengfeng/rpc ###

### 基于HTTP来实现 ###

package com.luban.protocol.http;
    
    import com.alibaba.fastjson.JSONObject;
    import com.luban.framework.Invocation;
    import org.apache.commons.io.IOUtils;
    import com.luban.provider.LocalRegister;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import java.io.IOException;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    
    public class HttpServerHandler { 
    
        public void handler(HttpServletRequest req, HttpServletResponse resp) { 
    
            try { 
                Invocation invocation = JSONObject.parseObject(req.getInputStream(), Invocation.class);
    
                var interfaceName = invocation.getInterfaceName();
                var implClass = LocalRegister.get(interfaceName);
                Method method = implClass.getMethod(invocation.getMethodName(), invocation.getParamType());
                var result = (String) method.invoke(implClass.newInstance(), invocation.getParams());
    
                System.out.println("tomcat:" + result);
                IOUtils.write(result, resp.getOutputStream());
            } catch (IOException e) { 
                e.printStackTrace();
            } catch (NoSuchMethodException e) { 
                e.printStackTrace();
            } catch (IllegalAccessException e) { 
                e.printStackTrace();
            } catch (InstantiationException e) { 
                e.printStackTrace();
            } catch (InvocationTargetException e) { 
                e.printStackTrace();
            }
    
    
        }
    }

package com.luban.protocol.http;
    
    import com.luban.framework.Invocation;
    import com.luban.framework.Protocol;
    import com.luban.framework.URL;
    
    public class HttpProtocol implements Protocol { 
    
        @Override
        public void start(URL url) { 
            HttpServer httpServer = new HttpServer();
            httpServer.start(url.getHostname(), url.getPort());
        }
    
        @Override
        public String send(URL url, Invocation invocation) { 
            HttpClient httpClient = new HttpClient();
            return httpClient.send(url.getHostname(), url.getPort(),invocation);
        }
    }

package com.luban.protocol.http;
    
    import org.apache.catalina.*;
    import org.apache.catalina.connector.Connector;
    import org.apache.catalina.core.StandardContext;
    import org.apache.catalina.core.StandardEngine;
    import org.apache.catalina.core.StandardHost;
    import org.apache.catalina.startup.Tomcat;
    
    public class HttpServer { 
        // tomcat,jetty
    
        public void start(String hostname, Integer port) { 
    
    
            Tomcat tomcat = new Tomcat();
    
            Server server = tomcat.getServer();
            Service service = server.findService("Tomcat");
    
            Connector connector = new Connector();
            connector.setPort(port);
    
            Engine engine = new StandardEngine();
            engine.setDefaultHost(hostname);
    
            Host host = new StandardHost();
            host.setName(hostname);
    
            String contextPath = "";
            Context context = new StandardContext();
            context.setPath(contextPath);
            context.addLifecycleListener(new Tomcat.FixContextListener());
    
            host.addChild(context);
            engine.addChild(host);
    
            service.setContainer(engine);
            service.addConnector(connector);
    
            tomcat.addServlet(contextPath, "dispatcher", new DispatcherServlet());
            context.addServletMappingDecoded("/*", "dispatcher");
    
    
            try { 
                tomcat.start();
                tomcat.getServer().await();
            } catch (LifecycleException e) { 
                e.printStackTrace();
            }
    
    
        }
    }

package com.luban.protocol.http;
    
    import com.alibaba.fastjson.JSONObject;
    import com.luban.framework.Invocation;
    
    import java.io.IOException;
    import java.net.MalformedURLException;
    import java.net.URI;
    import java.net.URISyntaxException;
    import java.net.http.HttpRequest;
    import java.net.http.HttpResponse;
    
    public class HttpClient { 
    
        public String send(String hostname, Integer port, Invocation invocation) { 
    
            try { 
                //jdk 13 的语法
                /** * java10引入了局部变量折断 var用于声明局部变量。 * 如var user=new ArrayList<User>(); * 避免了信息冗余 * 对齐了变量名 * 更容易阅读 * java10之前的变量声明： * * URL codefx = new URL("http://codefx.org") * URLConnection connection = codefx.openConnection(); * Reader reader = new BufferedReader( * new InputStreamReader(connection.getInputStream())); * * java10 * * var codefx = new URL("http://codefx.org"); * var connection = codefx.openConnection(); * var reader = new BufferedReader( * new InputStreamReader(connection.getInputStream())); * * 在处理 var时，编译器先是查看表达式右边部分，也就是所谓的构造器，并将它作为变量的类型，然后将该类型写入字节码当中。 * attention * 只能用于带有构造器的局部变量，以下场景不适用 * var foo; foo = "Foo"; * var ints = {0, 1, 2}; * var appendSpace = a -> a + " "; * private var getFoo(){} * 除了局部变量，for循环是唯一可以使用 var的地方： * * var numbers = List.of("a", "b", "c"); * for (var nr : numbers) * System.out.print(nr + " "); * for (var i = 0; i < numbers.size(); i++) * System.out.print(numbers.get(i) + " "); */
                var request = HttpRequest.newBuilder()
                        .uri(new URI("http", null, hostname, port, "/", null, null))
                        .POST(HttpRequest.BodyPublishers.ofString(JSONObject.toJSONString(invocation)))
                        .build();
                var client = java.net.http.HttpClient.newHttpClient();
    
                HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
    
                String result = response.body();
    
    // URL url = new URL("http", hostname, port, "/");
    // HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
    //
    // httpURLConnection.setRequestMethod("POST");
    // httpURLConnection.setDoOutput(true);
    //
    // OutputStream outputStream = httpURLConnection.getOutputStream();
    // ObjectOutputStream oos = new ObjectOutputStream(outputStream);
    //
    // oos.writeObject(invocation);
    // oos.flush();
    // oos.close();
    //
    // InputStream inputStream = httpURLConnection.getInputStream();
    // String result = IOUtils.toString(inputStream);
                return result;
            } catch (MalformedURLException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            } catch (InterruptedException e) { 
                e.printStackTrace();
            } catch (URISyntaxException e) { 
                e.printStackTrace();
            }
    
            return null;
    
        }
    }

package com.luban.protocol.http;
    
    import javax.servlet.ServletException;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    import java.io.IOException;
    
    public class DispatcherServlet extends HttpServlet { 
    
        @Override
        protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { 
            new HttpServerHandler().handler(req, resp);
        }
    }
    
    ublic class DispatcherServlet extends HttpServlet { 
    
        @Override
        protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { 
            new HttpServerHandler().handler(req, resp);
        }
    }