使用SniHandler确定客户端与Netty服务器协商的TLS版本

基础概念

SNI（Server Name Indication）是一种TLS/SSL扩展，允许客户端在握手过程中指定它希望连接的服务器主机名。这对于在同一IP地址上托管多个域名的服务器非常有用，因为它允许服务器为每个域名提供不同的证书。

Netty是一个高性能、异步事件驱动的网络应用框架，用于快速开发可维护的高性能协议服务器和客户端。

SniHandler的作用

SniHandler是Netty中的一个处理器，用于处理SNI事件。它允许你在TLS握手过程中获取客户端请求的主机名，并根据该主机名选择合适的SSL上下文（包括证书）。

类型

SniHandler主要有以下几种类型：

DefaultSniHandler：Netty提供的默认SniHandler，它会根据客户端请求的主机名选择合适的SSL上下文。
CustomSniHandler：自定义的SniHandler，你可以根据需要实现自己的逻辑来处理SNI事件。

应用场景

多域名服务器：在同一IP地址上托管多个域名的服务器，使用SniHandler可以根据客户端请求的主机名提供相应的证书。
动态证书选择：根据不同的客户端或请求类型，动态选择不同的证书进行TLS握手。

示例代码

以下是一个简单的示例，展示如何在Netty服务器中使用SniHandler来确定客户端与服务器协商的TLS版本：

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.ssl.SslContext;
import io.netty.handler.ssl.SslContextBuilder;
import io.netty.handler.ssl.SupportedCipherSuiteFilter;
import io.netty.handler.ssl.util.SelfSignedCertificate;

public class TlsServer {

    static final int PORT = Integer.parseInt(System.getProperty("port", "8443"));

    public static void main(String[] args) throws Exception {
        SelfSignedCertificate ssc = new SelfSignedCertificate();
        SslContext sslCtx = SslContextBuilder.forServer(ssc.certificate(), ssc.privateKey())
                .ciphers("TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256", SupportedCipherSuiteFilter.INSTANCE)
                .build();

        EventLoopGroup bossGroup = new NioEventLoopGroup(1);
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(bossGroup, workerGroup)
             .channel(NioServerSocketChannel.class)
             .childHandler(new ChannelInitializer<SocketChannel>() {
                 @Override
                 public void initChannel(SocketChannel ch) throws Exception {
                     ChannelPipeline p = ch.pipeline();
                     p.addLast(sslCtx.newHandler(ch.alloc()));
                     p.addLast(new SniHandler());
                     p.addLast(new SimpleChannelInboundHandler<TlsHandshakeCompletionEvent>() {
                         @Override
                         protected void channelRead0(ChannelHandlerContext ctx, TlsHandshakeCompletionEvent msg) throws Exception {
                             System.out.println("TLS version: " + msg.sslSession().cipherSuite());
                             ctx.fireChannelRead(msg);
                         }
                     });
                 }
             });

            ChannelFuture f = b.bind(PORT).sync();
            f.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }

    static class SniHandler extends ChannelInboundHandlerAdapter {
        @Override
        public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
            if (evt instanceof SniEvent) {
                SniEvent sniEvent = (SniEvent) evt;
                System.out.println("Client requested hostname: " + sniEvent.hostname());
                // 根据hostname选择合适的SSL上下文
            }
            super.userEventTriggered(ctx, evt);
        }
    }
}