Netty的WebSocket客户端通过SSL连接服务器

生成SSL证书

  1. 本地测试
    • 因为是测试,直接使用jdk自带的keytool工具生成自签名证书(注:自签名证书是不被浏览器认可的,只能用于测试)
    • 打开cmd
    • 输入命令(复制啊):keytool -genkey -keysize 2048 -validity 365 -keyalg RSA -keypass netty123 -storepass netty123 -keystore wss.jks
  2. 阿里云测试
    • 通过域名可取得免费证书(百度)

在ChannelPipeline添加SslHandler

首先写个工具类:SslUtil配置SSLContext

/**
 * @author chihiro
 * @version V1.0
 * @date 2019-06-15 09:00:00
 */
public static SSLContext createSSLContext(String type ,String path ,String password) throws Exception {
    // 证书类型"JKS、PKCS12"    
        KeyStore ks = KeyStore.getInstance(type); 
    // 证书存放地址
        InputStream ksInputStream = new FileInputStream(path); 
        ks.load(ksInputStream, password.toCharArray());
    //KeyManagerFactory充当基于密钥内容源的密钥管理器的工厂。
    //getDefaultAlgorithm:获取默认的 
        KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());KeyManagerFactory 算法名称。
        kmf.init(ks, password.toCharArray());
    //SSLContext的实例表示安全套接字协议的实现,它充当用于安全套接字工厂或 SSLEngine 的工厂。
        SSLContext sslContext = SSLContext.getInstance("TLS");
        sslContext.init(kmf.getKeyManagers(), null, null);
        return sslContext;
}

在ChannelInitialize的子类里面加入SSL

/**
 * @author chihiro
 * @version V1.0
 * @date 2019-06-15 09:00:00
 */
public class MyPipeline extends ChannelInitializer<SocketChannel> {

    @Override
    public void initChannel(SocketChannel ch) throws Exception {
        //阿里云证书与此处配置不同,类型为PKCS12    
        SSLContext sslContext = SslUtil.createSSLContext("JKS","D://wss.jks","netty123");
        //SSLEngine 此类允许使用ssl安全套接层协议进行安全通信
        SSLEngine engine = sslContext.createSSLEngine(); 
        engine.setUseClientMode(false); 
        //SslHandler应当放在首位
        ch.pipeline().addLast(new SslHandler(engine));
        ch.pipeline().addLast(new IdleStateHandler(5, 0, 0, TimeUnit.SECONDS));    
        ch.pipeline().addLast("http-codec", new HttpServerCodec());            
        ch.pipeline().addLast("aggregator", new HttpObjectAggregator(65536));  
        ch.pipeline().addLast("http-chunked", new ChunkedWriteHandler());    
        ch.pipeline().addLast(new AcceptorIdleStateTrigger());    
        ch.pipeline().addLast("handler", new WebSocketHandler());            
        }
}

JS文件的URL

var url = "wss://localhost:8000/ws";

注:阿里云证书不可加【www.】前缀

/ws后缀属于自己定义的,具体定义请查看自己项目中的配置类

运行

  • 运行服务端,在浏览器地址栏输入https://localhost:8000/ 浏览器会提示这是不安全的连接(浏览器不信任自签名证书,如果有域名可以自己申请一个证书,网上有免费测试版的证书),添加例外信任,再在html页面上右键获得它的本地路径 在浏览器中运行。
  • 连接成功。

  目录