摘要：的非工程的會(huì)根據(jù)類路徑是否有來(lái)判斷是否是項(xiàng)目，也可以自己強(qiáng)制指定。添加依賴如果是多模塊的項(xiàng)目，由于子模塊已經(jīng)有了，所以只能把的放到子模塊的的文件上。

SpringBoot的AutoConfiguration會(huì)根據(jù)類路徑是否有servlet來(lái)判斷是否是web項(xiàng)目，也可以自己強(qiáng)制指定。

@SpringBootApplication
public class RpcServerApplication {

    public static void main(String[] args){
        SpringApplication app = new SpringApplication(RpcServerApplication.class);
        app.setWebEnvironment(false);
        app.run(args);
    }
}

如果是多模塊的項(xiàng)目，由于子模塊已經(jīng)有parent了，所以只能把spring boot的parent放到子模塊的parent的pom文件上。

    org.springframework.boot
    spring-boot-starter-parent
    1.3.3.RELEASE
     
  

    UTF-8
  

Spring IOC

        
        
            org.springframework.boot
            spring-boot-starter-actuator
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        

@Component
//實(shí)現(xiàn)ApplicationContextAware以獲得ApplicationContext中的所有bean
public class NettyServer implements ApplicationContextAware {

    private static final Logger logger = LoggerFactory.getLogger(NettyServer.class);

    private Channel channel;
    private EventLoopGroup bossGroup;
    private EventLoopGroup workerGroup;

    private Map exportServiceMap = new HashMap();

    @Value("${rpcServer.host:127.0.0.1}")
    String host;

    @Value("${rpcServer.ioThreadNum:5}")
    int ioThreadNum;
    //內(nèi)核為此套接口排隊(duì)的最大連接個(gè)數(shù)，對(duì)于給定的監(jiān)聽套接口，內(nèi)核要維護(hù)兩個(gè)隊(duì)列，未鏈接隊(duì)列和已連接隊(duì)列大小總和最大值

    @Value("${rpcServer.backlog:1024}")
    int backlog;

    @Value("${rpcServer.port:9090}")
    int port;

    /**
     * 啟動(dòng)
     * @throws InterruptedException
     */
    @PostConstruct
    public void start() throws InterruptedException {
        logger.info("begin to start rpc server");
        bossGroup = new NioEventLoopGroup();
        workerGroup = new NioEventLoopGroup(ioThreadNum);

        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .option(ChannelOption.SO_BACKLOG, backlog)
                //注意是childOption
                .childOption(ChannelOption.SO_KEEPALIVE, true)
                .childOption(ChannelOption.TCP_NODELAY, true)
                .childHandler(new ChannelInitializer() {
                    @Override
                    protected void initChannel(SocketChannel socketChannel) throws Exception {
                        socketChannel.pipeline()
                                //真實(shí)數(shù)據(jù)最大字節(jié)數(shù)為Integer.MAX_VALUE，解碼時(shí)自動(dòng)去掉前面四個(gè)字節(jié)
                                //io.netty.handler.codec.DecoderException: java.lang.IndexOutOfBoundsException: readerIndex(900) + length(176) exceeds writerIndex(1024): UnpooledUnsafeDirectByteBuf(ridx: 900, widx: 1024, cap: 1024)
                                .addLast("decoder", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4))
                                .addLast("encoder", new LengthFieldPrepender(4, false))
                                .addLast(new RpcDecoder(RpcRequest.class))
                                .addLast(new RpcEncoder(RpcResponse.class))
                                .addLast(new ServerRpcHandler(exportServiceMap));
                    }
                });

        channel = serverBootstrap.bind(host,port).sync().channel();

        logger.info("NettyRPC server listening on port " + port + " and ready for connections...");
    }

    @PreDestroy
    public void stop() {
        logger.info("destroy server resources");
        if (null == channel) {
            logger.error("server channel is null");
        }
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
        channel.closeFuture().syncUninterruptibly();
        bossGroup = null;
        workerGroup = null;
        channel = null;
    }

    /**
     * 利用此方法獲取spring ioc接管的所有bean
     * @param ctx
     * @throws BeansException
     */
    public void setApplicationContext(ApplicationContext ctx) throws BeansException {
        Map serviceMap = ctx.getBeansWithAnnotation(ServiceExporter.class); // 獲取所有帶有 ServiceExporter 注解的 Spring Bean
        logger.info("獲取到所有的RPC服務(wù):{}", serviceMap);
        if (serviceMap != null && serviceMap.size() > 0) {
            for (Object serviceBean : serviceMap.values()) {
                String interfaceName = serviceBean.getClass().getAnnotation(ServiceExporter.class)
                        .targetInterface()
                        .getName();
                logger.info("register service mapping:{}",interfaceName);
                exportServiceMap.put(interfaceName, serviceBean);
            }
        }
    }
}

工程netty-rpc