websocket wss https

keytool -genkey -alias websocket -keyalg RSA -keystore ./ws.jks -validity 3650  -storepass 123456

keytool -importkeystore -srckeystore ./ws.jks -destkeystore ./ws.jks -deststoretype pkcs12





server.ssl.key-store=classpath:ws.jks

server.ssl.enabled=true

server.ssl.key-alias=websocket

server.ssl.key-store-password=123456

server.ssl.ciphers=TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256





import javax.annotation.Resource;



import org.eclipse.paho.client.mqttv3.MqttException;

import org.eclipse.paho.client.mqttv3.MqttPersistenceException;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.ApplicationArguments;

import org.springframework.boot.ApplicationRunner;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.web.socket.config.annotation.EnableWebSocket;

import org.springframework.web.socket.config.annotation.WebSocketConfigurer;

import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

@SpringBootApplication

@EnableWebSocket

public class Application implements ApplicationRunner, WebSocketConfigurer {

	@Autowired

	private R01MqttDisruptorListener r01MqttDisruptorListener;

	@Resource

	MqHandler mqHandler;



	@Override

	public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {



		registry.addHandler(mqHandler, "/mq");



	}



	public static void main(String[] args) throws Exception {

		Application app = new Application();

		SpringApplication.run(Application.class, args);



	}

}







import org.springframework.stereotype.Component;

import org.springframework.web.socket.CloseStatus;

import org.springframework.web.socket.TextMessage;

import org.springframework.web.socket.WebSocketHandler;

import org.springframework.web.socket.WebSocketMessage;

import org.springframework.web.socket.WebSocketSession;



import com.alibaba.fastjson.JSON;

@Component

public class MqHandler implements WebSocketHandler{



}

import org.apache.catalina.Context;
import org.apache.catalina.connector.Connector;
import org.apache.tomcat.util.descriptor.web.SecurityCollection;
import org.apache.tomcat.util.descriptor.web.SecurityConstraint;
import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SSLConfig {

    @Bean
    public TomcatServletWebServerFactory servletContainer() { //springboot2 新变化

        TomcatServletWebServerFactory tomcat = new TomcatServletWebServerFactory() {

            @Override
            protected void postProcessContext(Context context) {

                SecurityConstraint securityConstraint = new SecurityConstraint();
                securityConstraint.setUserConstraint("CONFIDENTIAL");
                SecurityCollection collection = new SecurityCollection();
                collection.addPattern("/*");
                securityConstraint.addCollection(collection);
                context.addConstraint(securityConstraint);
            }
        };
        tomcat.addAdditionalTomcatConnectors(initiateHttpConnector());
        return tomcat;
    }

    private Connector initiateHttpConnector() {
        Connector connector = new Connector("org.apache.coyote.http11.Http11NioProtocol");
        connector.setScheme("http");
        connector.setPort(18888);//http端口
        connector.setSecure(true);//这个坑，网上普遍为false重定向容易出错，我这里设置为true
        connector.setRedirectPort(19999);
        return connector;
    }

}



var tprotocol = window.location.protocol;
	var ws;
	if (tprotocol == "http:")
		ws = new WebSocket("ws://localhost:18888/mq");
	else
		ws = new WebSocket("wss://localhost:19999/mq");