import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.Channel;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.ssl.SslContext;
import io.netty.handler.ssl.SslContextBuilder;
import io.netty.handler.ssl.util.SelfSignedCertificate;
import io.netty.util.concurrent.DefaultEventExecutorGroup;
import io.netty.util.concurrent.EventExecutorGroup;

/**
 * Netty 启动器，初始化 spring boot 的时候会自动加载
 */
public class Server {
    private static final Logger LOG = LoggerFactory.getLogger(Server.class);

    /*
     * NioEventLoopGroup 默认创建数量为 CPU * 2，类型为 NioEventLoop 的实例。
     * 每个 NioEventLoop 实例都持有一个线程，以及一个类型为 LinkedBlockingQueue 的任务队列
     */
    EventLoopGroup bossGroup = new NioEventLoopGroup();
    EventLoopGroup workerGroup = new NioEventLoopGroup();
    // 业务线程
    EventExecutorGroup eventExecutorGroup = new DefaultEventExecutorGroup(16);
    static final boolean isSsl = System.getProperty("ssl") != null;

    /**
     * 初始化 Netty
     */
    public void startNetty() {
        try {
            final SslContext sslCtx;
            if (isSsl) {
                SelfSignedCertificate ssc = new SelfSignedCertificate();
                sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey()).build();
            } else {
                sslCtx = null;
            }
            // 引导辅助程序
            ServerBootstrap bs = new ServerBootstrap();
            // 通过NIO方式来接收连接和处理连接
            bs.group(bossGroup, workerGroup);
            // 设置NIO的Channel
            bs.channel(NioServerSocketChannel.class);
            bs.childHandler(new HttpChannelInitializer(sslCtx, eventExecutorGroup));

            bs.option(ChannelOption.SO_BACKLOG, 1024); // 连接数
            // bs.childOption(ChannelOption.SO_KEEPALIVE, true); // 是否长链接
            bs.childOption(ChannelOption.TCP_NODELAY, true); // 是否TCP延迟

            // 配置完成，开始绑定server，通过调用sync同步方法阻塞直到绑定成功
            Channel ch = bs.bind(9999).sync().channel();
            LOG.info("Server startup. listen on {}-{}", (isSsl ? "https" : "http"), 9999);
            // 应用程序会一直等待，直到Channel关闭
            ch.closeFuture().sync();
        } catch (Exception e) {
            LOG.error("server startup failed. {}", e.getMessage(), e);
        } finally {
            LOG.info("释放资源...");
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
            eventExecutorGroup.shutdownGracefully();
            bossGroup = null;
            workerGroup = null;
            eventExecutorGroup = null;
        }
    }

    public static void main(String[] args) {
        new Server().startNetty();
    }
}

@Configuration
public class WebMvcConfig extends WebMvcConfigurerAdapter {
    @Override
    public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
        // 返回 JSON，Long 前端精准度丢失问题
        MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();
        ObjectMapper mapper = new ObjectMapper();
        /*
         * 序列换成json时,将所有的long变成string
         * 因为js中得数字类型不能包含所有的java long值
         */
        SimpleModule module = new SimpleModule();
        module.addSerializer(Long.class, ToStringSerializer.instance);
        module.addSerializer(Long.TYPE, ToStringSerializer.instance);
        mapper.registerModule(module);
        converter.setObjectMapper(mapper);
        converters.add(converter);
    }
}

@Bean
public AegisDatabinding aegisDatabinding() {
    return new AegisDatabinding();
}

/**
  * 这个要配置成多例模式
  */
@Bean
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public org.apache.cxf.jaxws.support.JaxWsServiceFactoryBean jaxWsServiceFactoryBean() {
    JaxWsServiceFactoryBean sf = new JaxWsServiceFactoryBean();
    sf.setWrapped(true);
    sf.setDataBinding(aegisDatabinding());
    return sf;
}

@Bean
public Endpoint userEndpoint(UserService userService) {
    EndpointImpl endpoint = new EndpointImpl(userService);
    endpoint.setServiceFactory(jaxWsServiceFactoryBean());
    endpoint.publish("/imCheckRelatedWeixinService.ws");
    return endpoint;
}