手写rpc

野性酷女 2024-02-19 15:31 44阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70][]

模拟rpc系统：

注册中心：map保存服务提供者信息

协议：http协议，netty协议

消费者：customer

提供者：provider

pom:

<dependency>
                <groupId>io.netty</groupId>
                <artifactId>netty-all</artifactId>
                <version>4.1.32.Final</version>
                <scope>system</scope>
                <systemPath>${project.basedir}/lib/netty-all-4.1.32.Final.jar</systemPath>
            </dependency>
    
            
            <dependency>
                <groupId>org.apache.tomcat.embed</groupId>
                <artifactId>tomcat-embed-core</artifactId>
                <version>9.0.12</version>
            </dependency>
            
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>3.8.1</version>
            </dependency>
    
            
            <dependency>
                <groupId>commons-io</groupId>
                <artifactId>commons-io</artifactId>
                <version>2.6</version>
            </dependency>

tomcat服务：结构

<?xml version="1.0" encoding="UTF-8"?>
    
    <Server port="8005" shutdown="SHUTDOWN">
    
      <Service name="Catalina">
    
      
        <Connector port="8080" protocol="HTTP/1.1"
                   connectionTimeout="20000"
                   redirectPort="8443" />
    
        
        <Connector port="8009" protocol="AJP/1.3" redirectPort="8443" />
    
        <Engine name="Catalina" defaultHost="localhost">
    
          <Realm className="org.apache.catalina.realm.LockOutRealm">
          
            <Realm className="org.apache.catalina.realm.UserDatabaseRealm"
                   resourceName="UserDatabase"/>
          </Realm>
    
          <Host name="localhost"  appBase="webapps"
                unpackWARs="true" autoDeploy="true">
            <Valve className="org.apache.catalina.valves.AccessLogValve" directory="logs"
                   prefix="localhost_access_log" suffix=".txt"
                   pattern="%h %l %u %t "%r" %s %b" />
    
          </Host>
        </Engine>
      </Service>
    </Server>

编写tomcat服务器：

package 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;
    
    /**
     * @program: rpcdemo
     * @description:
     * @author: z.hw
     * @create: 2019-01-06 00:33
     **/
    public class HttpServer {
    
        public void start(String hostname,Integer port){
    
            System.out.println("定制tomcat启动服务");
            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 DispartceServlet()); //怎加处理的服务器类
    
            context.addServletMappingDecoded("/*","dispatcher");//增加容器上下文处理路径
    
            try {
                tomcat.start();//初始化
                tomcat.getServer().await();//等待
            } catch (LifecycleException e) {
                e.printStackTrace();
            } finally {
            }
    
    
        }
    
    
    
    }

编写Netty服务器：

package protocol.dubbo;
    
    import io.netty.bootstrap.ServerBootstrap;
    import io.netty.channel.ChannelFuture;
    import io.netty.channel.ChannelInitializer;
    import io.netty.channel.ChannelPipeline;
    import io.netty.channel.nio.NioEventLoopGroup;
    import io.netty.channel.socket.SocketChannel;
    import io.netty.channel.socket.nio.NioServerSocketChannel;
    import io.netty.handler.codec.serialization.ClassResolvers;
    import io.netty.handler.codec.serialization.ObjectDecoder;
    import io.netty.handler.codec.serialization.ObjectEncoder;
    
    import java.net.InetSocketAddress;
    
    
    /**
     * @program: rpcdemo
     * @description:
     * @author: z.hw
     * @create: 2019-01-06 03:03
     **/
    public class NettyServer {
    
    
        public void start(String hostname,int port){
            NioEventLoopGroup nioEventLoopGroup=new NioEventLoopGroup();
            try {
                final ServerBootstrap serverBootstrap=new ServerBootstrap();
                serverBootstrap.group(nioEventLoopGroup)
                        .channel(NioServerSocketChannel.class)
                        .childHandler(new ChannelInitializer<SocketChannel>() {
                            @Override
                            protected void initChannel(SocketChannel socketChannel) throws Exception {
                                ChannelPipeline pipeline=socketChannel.pipeline();
                                pipeline.addLast("decoder",new ObjectDecoder(ClassResolvers
                                        .weakCachingConcurrentResolver(this.getClass().getClassLoader())
                                ));
                                pipeline.addLast("encoder",new ObjectEncoder());
                                pipeline.addLast("handler",new NettyServerHandler());
                            }
                        });
                        ChannelFuture future = serverBootstrap.bind(hostname,port).sync();
                        System.out.println("Server start listen at " + port );
                        future.channel().closeFuture().sync();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }finally {
                nioEventLoopGroup.shutdownGracefully();
            }
        }
    
    }