Springboot Bean 的@PostConstruct，@PreDestroy

比眉伴天荒 2023-05-21 15:23 3阅读 0赞

1、@PostConstruct

spring 在执行完bean 的构造方法之后，init 方法之前，会执行该方法

构造方法 > @Autowired > @PostConstruct

2、@PreDestroy

spring 在执行完bean 的destroy() 方法后，并在servlet 容器完全销毁之前执行该方法

![2020041709501689.jpg][]

使用示例

package com.ahies.stm.app.gatenetty;
    
    import io.netty.bootstrap.ServerBootstrap;
    import io.netty.channel.ChannelFuture;
    import io.netty.channel.ChannelOption;
    import io.netty.channel.EventLoopGroup;
    import io.netty.channel.nio.NioEventLoopGroup;
    import io.netty.channel.socket.nio.NioServerSocketChannel;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
    
    import javax.annotation.PostConstruct;
    import javax.annotation.PreDestroy;
    import java.net.InetSocketAddress;
    
    @Component
    @Slf4j
    public class GateNettyServer {
        /**
         * boss 线程组用于处理连接工作
         */
        private EventLoopGroup boss = new NioEventLoopGroup();
        /**
         * work 线程组用于数据处理
         */
        private EventLoopGroup work = new NioEventLoopGroup();
        @Value("${gate.netty.port}")
        private Integer port;
    
    
        /**
         * 启动Netty Server
         *
         * @throws InterruptedException
         */
        @PostConstruct
        public void start() throws InterruptedException {
            //bean 初始化执行
            ServerBootstrap bootstrap = new ServerBootstrap();
            bootstrap.group(boss, work)
                    // 指定Channel
                    .channel(NioServerSocketChannel.class)
                    //使用指定的端口设置套接字地址
                    .localAddress(new InetSocketAddress(port))
    
                    //服务端可连接队列数,对应TCP/IP协议listen函数中backlog参数
                    .option(ChannelOption.SO_BACKLOG, 2048)
    
                    //设置TCP长连接,一般如果两个小时内没有数据的通信时,TCP会自动发送一个活动探测数据报文
                    .childOption(ChannelOption.SO_KEEPALIVE, true)
    
                    //将小的数据包包装成更大的帧进行传送，提高网络的负载
                    .childOption(ChannelOption.TCP_NODELAY, true)
                    .childOption(ChannelOption.SO_REUSEADDR, true)
    
                    .childHandler(new GateNettyServerHandlerInitializer());
            ChannelFuture future = bootstrap.bind().sync();
            if (future.isSuccess()) {
                log.info("启动 GATE Netty Server");
            }
        }
    
        @PreDestroy
        public void destory() throws InterruptedException {
            log.info("关闭GATE Netty");
            GateTcpServerHandler.channels.close();
            boss.shutdownGracefully().sync();
            work.shutdownGracefully().sync();
    
        }
    }

[2020041709501689.jpg]: /images/20230521/100e71f2b0614e3d9925a8c0d0d8a6a5.png