@Override
public void setServletContext(ServletContext servletContext) {
	RequestUpgradeStrategy strategy = getRequestUpgradeStrategy();
	if (strategy instanceof ServletContextAware) {
		((ServletContextAware) strategy).setServletContext(servletContext);
	}
}
 

private static RequestUpgradeStrategy initRequestUpgradeStrategy() {
	String className;
	if (tomcatWsPresent) {
		className = "org.springframework.web.socket.server.standard.TomcatRequestUpgradeStrategy";
	}
	else if (jettyWsPresent) {
		className = "org.springframework.web.socket.server.jetty.JettyRequestUpgradeStrategy";
	}
	else if (undertowWsPresent) {
		className = "org.springframework.web.socket.server.standard.UndertowRequestUpgradeStrategy";
	}
	else if (glassfishWsPresent) {
		className = "org.springframework.web.socket.server.standard.GlassFishRequestUpgradeStrategy";
	}
	else if (weblogicWsPresent) {
		className = "org.springframework.web.socket.server.standard.WebLogicRequestUpgradeStrategy";
	}
	else if (websphereWsPresent) {
		className = "org.springframework.web.socket.server.standard.WebSphereRequestUpgradeStrategy";
	}
	else {
		throw new IllegalStateException("No suitable default RequestUpgradeStrategy found");
	}

	try {
		Class<?> clazz = ClassUtils.forName(className, AbstractHandshakeHandler.class.getClassLoader());
		return (RequestUpgradeStrategy) ReflectionUtils.accessibleConstructor(clazz).newInstance();
	}
	catch (Throwable ex) {
		throw new IllegalStateException(
				"Failed to instantiate RequestUpgradeStrategy: " + className, ex);
	}
}
 

@Override
protected void registerStompEndpoints(StompEndpointRegistry registry) {
	// Can't rely on classpath detection
	RequestUpgradeStrategy upgradeStrategy = new TomcatRequestUpgradeStrategy();
	registry.addEndpoint("/stomp")
			.setHandshakeHandler(new DefaultHandshakeHandler(upgradeStrategy))
			.setAllowedOrigins("*");
}
 

@Override
public void setServletContext(ServletContext servletContext) {
	RequestUpgradeStrategy strategy = getRequestUpgradeStrategy();
	if (strategy instanceof ServletContextAware) {
		((ServletContextAware) strategy).setServletContext(servletContext);
	}
}
 

private static RequestUpgradeStrategy initRequestUpgradeStrategy() {
	String className;
	if (tomcatWsPresent) {
		className = "org.springframework.web.socket.server.standard.TomcatRequestUpgradeStrategy";
	}
	else if (jettyWsPresent) {
		className = "org.springframework.web.socket.server.jetty.JettyRequestUpgradeStrategy";
	}
	else if (undertowWsPresent) {
		className = "org.springframework.web.socket.server.standard.UndertowRequestUpgradeStrategy";
	}
	else if (glassfishWsPresent) {
		className = "org.springframework.web.socket.server.standard.GlassFishRequestUpgradeStrategy";
	}
	else if (weblogicWsPresent) {
		className = "org.springframework.web.socket.server.standard.WebLogicRequestUpgradeStrategy";
	}
	else if (websphereWsPresent) {
		className = "org.springframework.web.socket.server.standard.WebSphereRequestUpgradeStrategy";
	}
	else {
		throw new IllegalStateException("No suitable default RequestUpgradeStrategy found");
	}

	try {
		Class<?> clazz = ClassUtils.forName(className, AbstractHandshakeHandler.class.getClassLoader());
		return (RequestUpgradeStrategy) ReflectionUtils.accessibleConstructor(clazz).newInstance();
	}
	catch (Throwable ex) {
		throw new IllegalStateException(
				"Failed to instantiate RequestUpgradeStrategy: " + className, ex);
	}
}
 

@Override
protected void registerStompEndpoints(StompEndpointRegistry registry) {
	// Can't rely on classpath detection
	RequestUpgradeStrategy upgradeStrategy = new TomcatRequestUpgradeStrategy();
	registry.addEndpoint("/stomp")
			.setHandshakeHandler(new DefaultHandshakeHandler(upgradeStrategy))
			.setAllowedOrigins("*");
}
 

@Override
public void setServletContext(ServletContext servletContext) {
	RequestUpgradeStrategy strategy = getRequestUpgradeStrategy();
	if (strategy instanceof ServletContextAware) {
		((ServletContextAware) strategy).setServletContext(servletContext);
	}
}
 

private static RequestUpgradeStrategy initRequestUpgradeStrategy() {
	String className;
	if (tomcatWsPresent) {
		className = "org.springframework.web.socket.server.standard.TomcatRequestUpgradeStrategy";
	}
	else if (jettyWsPresent) {
		className = "org.springframework.web.socket.server.jetty.JettyRequestUpgradeStrategy";
	}
	else if (undertowWsPresent) {
		className = "org.springframework.web.socket.server.standard.UndertowRequestUpgradeStrategy";
	}
	else if (glassfishWsPresent) {
		className = "org.springframework.web.socket.server.standard.GlassFishRequestUpgradeStrategy";
	}
	else if (weblogicWsPresent) {
		className = "org.springframework.web.socket.server.standard.WebLogicRequestUpgradeStrategy";
	}
	else if (websphereWsPresent) {
		className = "org.springframework.web.socket.server.standard.WebSphereRequestUpgradeStrategy";
	}
	else {
		throw new IllegalStateException("No suitable default RequestUpgradeStrategy found");
	}

	try {
		Class<?> clazz = ClassUtils.forName(className, classLoader);
		return (RequestUpgradeStrategy) clazz.newInstance();
	}
	catch (Throwable ex) {
		throw new IllegalStateException(
				"Failed to instantiate RequestUpgradeStrategy: " + className, ex);
	}
}
 

@Override
protected void registerStompEndpoints(StompEndpointRegistry registry) {
	// Can't rely on classpath detection
	RequestUpgradeStrategy upgradeStrategy = new TomcatRequestUpgradeStrategy();
	registry.addEndpoint("/stomp")
			.setHandshakeHandler(new DefaultHandshakeHandler(upgradeStrategy))
			.setAllowedOrigins("*");
}
 

public DefaultHandshakeHandler(RequestUpgradeStrategy requestUpgradeStrategy) {
	super(requestUpgradeStrategy);
}
 

/**
 * A constructor that accepts a runtime-specific {@link RequestUpgradeStrategy}.
 * @param requestUpgradeStrategy the upgrade strategy to use
 */
protected AbstractHandshakeHandler(RequestUpgradeStrategy requestUpgradeStrategy) {
	Assert.notNull(requestUpgradeStrategy, "RequestUpgradeStrategy must not be null");
	this.requestUpgradeStrategy = requestUpgradeStrategy;
}
 

/**
 * Return the {@link RequestUpgradeStrategy} for WebSocket requests.
 */
public RequestUpgradeStrategy getRequestUpgradeStrategy() {
	return this.requestUpgradeStrategy;
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new JettyRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new TomcatRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new UndertowRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy upgradeStrategy() {
	return new JettyRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy upgradeStrategy() {
	return new UndertowRequestUpgradeStrategy();
}
 

public DefaultHandshakeHandler(RequestUpgradeStrategy requestUpgradeStrategy) {
	super(requestUpgradeStrategy);
}
 

/**
 * A constructor that accepts a runtime-specific {@link RequestUpgradeStrategy}.
 * @param requestUpgradeStrategy the upgrade strategy to use
 */
protected AbstractHandshakeHandler(RequestUpgradeStrategy requestUpgradeStrategy) {
	Assert.notNull(requestUpgradeStrategy, "RequestUpgradeStrategy must not be null");
	this.requestUpgradeStrategy = requestUpgradeStrategy;
}
 

/**
 * Return the {@link RequestUpgradeStrategy} for WebSocket requests.
 */
public RequestUpgradeStrategy getRequestUpgradeStrategy() {
	return this.requestUpgradeStrategy;
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new JettyRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new TomcatRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new UndertowRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy upgradeStrategy() {
	return new JettyRequestUpgradeStrategy();
}
 

@Bean
public RequestUpgradeStrategy upgradeStrategy() {
	return new UndertowRequestUpgradeStrategy();
}
 

/**
     * 容器策略, 这里选用netty
     * @return 容器策略
     */
    public RequestUpgradeStrategy requestUpgradeStrategy() {
//        return new JettyRequestUpgradeStrategy();
//        return new TomcatRequestUpgradeStrategy();
        return new NettyRequestUpgradeStrategy();
    }
 

public DefaultHandshakeHandler(RequestUpgradeStrategy requestUpgradeStrategy) {
	super(requestUpgradeStrategy);
}
 

/**
 * A constructor that accepts a runtime-specific {@link RequestUpgradeStrategy}.
 * @param requestUpgradeStrategy the upgrade strategy to use
 */
protected AbstractHandshakeHandler(RequestUpgradeStrategy requestUpgradeStrategy) {
	Assert.notNull(requestUpgradeStrategy, "RequestUpgradeStrategy must not be null");
	this.requestUpgradeStrategy = requestUpgradeStrategy;
}
 

/**
 * Return the {@link RequestUpgradeStrategy} for WebSocket requests.
 */
public RequestUpgradeStrategy getRequestUpgradeStrategy() {
	return this.requestUpgradeStrategy;
}
 

@Bean
public RequestUpgradeStrategy requestUpgradeStrategy() {
	return new JettyRequestUpgradeStrategy();
}