AbstractStandardUpgradeStrategy.java 文件源码

@Override
public void upgrade(ServerHttpRequest request, ServerHttpResponse response,
        String selectedProtocol, List<WebSocketExtension> selectedExtensions, Principal user,
        WebSocketHandler wsHandler, Map<String, Object> attrs) throws HandshakeFailureException {

    HttpHeaders headers = request.getHeaders();
    InetSocketAddress localAddr = request.getLocalAddress();
    InetSocketAddress remoteAddr = request.getRemoteAddress();

    StandardWebSocketSession session = new StandardWebSocketSession(headers, attrs, localAddr, remoteAddr, user);
    StandardWebSocketHandlerAdapter endpoint = new StandardWebSocketHandlerAdapter(wsHandler, session);

    List<Extension> extensions = new ArrayList<Extension>();
    for (WebSocketExtension extension : selectedExtensions) {
        extensions.add(new WebSocketToStandardExtensionAdapter(extension));
    }

    upgradeInternal(request, response, selectedProtocol, extensions, endpoint);
}