从零开始手写 dubbo rpc 框架-01-服务端启动

浅浅的花香味﹌ 2023-05-29 02:26 32阅读 0赞

# 服务端启动 #

## 功能 ##

实现 server 端服务启动。

## maven 依赖 ##

<dependency>
        <groupId>io.netty</groupId>
        <artifactId>netty-all</artifactId>
        <version>4.1.17.Final</version>
    </dependency>

## 核心代码 ##

就是最简单的一个 netty server 端启动代码。

import com.github.houbb.log.integration.core.Log;
    import com.github.houbb.log.integration.core.LogFactory;
    import com.github.houbb.rpc.server.constant.RpcServerConst;
    import com.github.houbb.rpc.server.handler.RpcServerHandler;
    import io.netty.bootstrap.ServerBootstrap;
    import io.netty.channel.*;
    import io.netty.channel.nio.NioEventLoopGroup;
    import io.netty.channel.socket.nio.NioServerSocketChannel;
    
    /** * rpc 服务端 * @author binbin.hou * @since 0.0.1 */
    public class RpcServer extends Thread { 
    
        private static final Log log = LogFactory.getLog(RpcServer.class);
    
        /** * 端口号 */
        private final int port;
    
        public RpcServer() { 
            this.port = RpcServerConst.DEFAULT_PORT;
        }
    
        public RpcServer(int port) { 
            this.port = port;
        }
    
        @Override
        public void run() { 
            // 启动服务端
            log.info("RPC 服务开始启动服务端");
    
            EventLoopGroup bossGroup = new NioEventLoopGroup();
            EventLoopGroup workerGroup = new NioEventLoopGroup();
    
            try { 
                ServerBootstrap serverBootstrap = new ServerBootstrap();
                serverBootstrap.group(workerGroup, bossGroup)
                        .channel(NioServerSocketChannel.class)
                        .childHandler(new ChannelInitializer<Channel>() { 
                            @Override
                            protected void initChannel(Channel ch) throws Exception { 
                                ch.pipeline().addLast(new RpcServerHandler());
                            }
                        })
                        // 这个参数影响的是还没有被accept 取出的连接
                        .option(ChannelOption.SO_BACKLOG, 128)
                        // 这个参数只是过一段时间内客户端没有响应，服务端会发送一个 ack 包，以判断客户端是否还活着。
                        .childOption(ChannelOption.SO_KEEPALIVE, true);
    
                // 绑定端口，开始接收进来的链接
                ChannelFuture channelFuture = serverBootstrap.bind(port).syncUninterruptibly();
                log.info("RPC 服务端启动完成，监听【" + port + "】端口");
    
                channelFuture.channel().closeFuture().syncUninterruptibly();
                log.info("RPC 服务端关闭完成");
            } catch (Exception e) { 
                log.error("RPC 服务异常", e);
            } finally { 
                workerGroup.shutdownGracefully();
                bossGroup.shutdownGracefully();
            }
        }
    }

## 测试代码 ##

/** * 服务启动代码测试 * @param args 参数 */
    public static void main(String[] args) { 
        new RpcServer().start();
    }

*  服务启动日志

[INFO] [2019-11-01 13:26:28.680] [Thread-0] [c.g.h.r.s.c.RpcServer.run] - RPC 服务开始启动服务端
    [INFO] [2019-11-01 13:26:30.371] [Thread-0] [c.g.h.r.s.c.RpcServer.run] - RPC 服务端启动完成，监听【9627】端口