package com.fastbee.server;


import com.fastbee.server.config.NettyConfig;
import io.netty.bootstrap.AbstractBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.EventLoopGroup;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.ExecutorService;

/**
 * 基础服务器启动类
 *
 * @Author guanshubiao
 * @Date 2022/9/12 20:22
 */
@Slf4j
@NoArgsConstructor
public abstract class Server {

    protected EventLoopGroup bossGroup;
    protected EventLoopGroup workerGroup;
    protected ExecutorService businessService;
    protected boolean isRunning;
    public NettyConfig config;



    protected Server(NettyConfig config){
        this.config = config;
    }

    /*初始化方法*/
    protected abstract AbstractBootstrap initialize();


    public synchronized boolean start() {
        if (isRunning) {
            log.warn("=>服务:{},在端口:{},已经运行", config.name, config.port);
            return isRunning;
        }
        AbstractBootstrap bootstrap = initialize();
        ChannelFuture future = bootstrap.bind(config.port).awaitUninterruptibly();
        future.channel().closeFuture().addListener(event -> {
            if (isRunning) {
                stop();
            }
        });
        if (isRunning = future.isSuccess()) {
            log.info("=>服务:{},在端口:{},启动成功！", config.name, config.port);
            return isRunning;
        }

        if (future.cause() != null) {
            log.error("服务启动失败", future.cause());
        }
        return isRunning;
    }


    public synchronized void stop() {

        isRunning = false;
        bossGroup.shutdownGracefully();
        if (workerGroup != null) {
            workerGroup.shutdownGracefully();
        }
        if (businessService != null) {
            businessService.shutdown();
        }
        log.warn("=>服务:{},在端口:{},已经停止！", config.name, config.port);
    }


}