Tyrus wss：// websocket不通过鱿鱼代理

如问题所述，我能够100％重现该问题。我使用的是Squid版本3.5.17（Windows 10 64位），这是使用带有“ echo”网络套接字和Java 7的自签名证书的本地Tomcat（但我认为Java 8并没有什么不同）。
当我使用org.glassfish.tyrus.bundles:tyrus-standalone-client:1.11而不是时，一切正常1.12。

当我发现以下错误修正时，我决定使用以前的版本：
2015 / Nov / 13：Grizzly传输无法通过HTTP代理（github-commit）打开wss连接。

版本1.11已于2015年6月发布，而版本1.12已于2015年9月发布，我希望此修补程序版本为1.13（另请参阅pom历史记录）。

该问题的解决方案可能与此相关（2015 / Aug / 21）。

作为参考，输出为1.12（硬编码超时为30秒，org.glassfish.tyrus.container.grizzly.client.GrizzlyClientContainer.CLIENT_SOCKET_TIMEOUT因此您必须等待一段时间才能出现错误）。

05：07：25.514 [Grizzly（1）SelectorRunner]跟踪ogtcgcGrizzlyClientFilter-handleConnect
使用SSLEngineImpl。
允许不安全的重新协商：false
允许旧的问候消息：true
初始握手是否正确
是安全的重新协商：false
05：07：25.651 [Grizzly（1）]调试ogtcgcGrizzlyClientFilter-handleRead websocket：null content-size = 0标头=
HttpResponsePacket（
  状态= 200
  原因=建立连接
  协议= HTTP / 1.1
  内容长度= -1
  已提交=假
  标头= []
）
javax.websocket.DeploymentException：与“ wss：//127.0.0.1：8443 / wstest / ws / echoAsyncAnnotation”的连接失败。
    在org.glassfish.tyrus.container.grizzly.client.GrizzlyClientSocket._connect（GrizzlyClientSocket.java:398）
    在org.glassfish.tyrus.container.grizzly.client.GrizzlyClientSocket.access $ 000（GrizzlyClientSocket.java:103）
    在org.glassfish.tyrus.container.grizzly.client.GrizzlyClientSocket $ 1.call（GrizzlyClientSocket.java:235）
    在org.glassfish.tyrus.container.grizzly.client.GrizzlyClientSocket $ 1.call（GrizzlyClientSocket.java:231）
    在org.glassfish.tyrus.container.grizzly.client.GrizzlyClientSocket.connect（GrizzlyClientSocket.java:249）
    在org.glassfish.tyrus.container.grizzly.client.GrizzlyClientContainer.openClientSocket（GrizzlyClientContainer.java:95）
    在org.glassfish.tyrus.client.ClientManager $ 3 $ 1.run（ClientManager.java:663）
    在org.glassfish.tyrus.client.ClientManager $ 3.run（ClientManager.java:712）
    在java.util.concurrent.Executors $ RunnableAdapter.call（Executors.java:471）
    在java.util.concurrent.FutureTask.run（FutureTask.java:262）
    在org.glassfish.tyrus.client.ClientManager $ SameThreadExecutorService.execute（ClientManager.java:866）
    在java.util.concurrent.AbstractExecutorService.submit（AbstractExecutorService.java:110）
    在org.glassfish.tyrus.client.ClientManager.connectToServer（ClientManager.java:511）
    在org.glassfish.tyrus.client.ClientManager.connectToServer（ClientManager.java:355）
    在nl.fw.wsclienttest.WsClient.echoDemo（WsClient.java:69）
    在nl.fw.wsclienttest.WsClient.main（WsClient.java:41）

以及我使用的完全不安全的测试客户端的代码：

import java.io.IOException;
import java.net.URI;
import java.security.KeyStore;
import java.security.cert.*;
import java.util.concurrent.*;

import javax.net.ssl.*;
import javax.websocket.*;

import org.glassfish.tyrus.client.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.bridge.SLF4JBridgeHandler;

public class WsClient {

    static {
        SLF4JBridgeHandler.removeHandlersForRootLogger();
        SLF4JBridgeHandler.install();
    }

    private static final Logger log = LoggerFactory.getLogger(WsClient.class);

    public static void main(String[] args) {

        System.getProperties().put("javax.net.debug", "ssl,handshake,data,sslctx");
        try {
            new WsClient().echoDemo();
            log.info("done");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    // localhost does not work via squid proxy
    String destUri = "wss://127.0.0.1:8443/wstest/ws/echoAsyncAnnotation";
    String proxyUri = "http://localhost:3128";
    volatile Session wsSession = null;

    void echoDemo() throws Exception {

        final ClientEndpointConfig cec = ClientEndpointConfig.Builder.create().build();
        ClientManager client = ClientManager.createClient();
        client.getProperties().put(ClientProperties.PROXY_URI, proxyUri);
        client.getProperties().put(ClientProperties.SHARED_CONTAINER, false);

        SSLContext sslCtx = createAllTrustingContext();
        SslEngineConfigurator sslEngineConfigurator = new SslEngineConfigurator(sslCtx, true, false, false);
        sslEngineConfigurator.setHostVerificationEnabled(false); //skip host verification
        client.getProperties().put(ClientProperties.SSL_ENGINE_CONFIGURATOR, sslEngineConfigurator);
        // time-out is set to 30 seconds for all operations, so handshake timeout does not work ...
        // see org.glassfish.tyrus.container.grizzly.client.GrizzlyClientContainer.CLIENT_SOCKET_TIMEOUT
        client.getProperties().put(ClientProperties.HANDSHAKE_TIMEOUT, 3000);
        final CountDownLatch messageLatch = new CountDownLatch(1);
        client.connectToServer(new Endpoint() {

            @Override
            public void onOpen(final Session session, EndpointConfig config) {
                try {
                    session.addMessageHandler(new MessageHandler.Whole<String>() {

                        @Override
                        public void onMessage(String message) {
                            log.info("Received message: {}", message);
                            wsSession = session;
                            messageLatch.countDown();
                        }
                    });
                    session.getBasicRemote().sendText("Hello world");
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }, cec, new URI(destUri));
        try {
            messageLatch.await(5, TimeUnit.SECONDS);
            if (wsSession != null) {
                wsSession.close();
            }
        } finally {
            client.shutdown();
        }
    }

    public static SSLContext createAllTrustingContext() throws Exception {

        SSLContext ctx = SSLContext.getInstance("TLSv1.2");
        KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
        kmf.init((KeyStore) null, "changeit".toCharArray());
        ctx.init(kmf.getKeyManagers(), new TrustManager[] { new TrustServerCertAlways() }, null);
        return ctx;
    }

    static class TrustServerCertAlways implements X509TrustManager {

        @Override public void checkClientTrusted(X509Certificate[] arg0, String arg1) throws CertificateException {
            log.debug("Trusting all client certificates.");
        }

        @Override public void checkServerTrusted(X509Certificate[] arg0, String arg1)   throws CertificateException {
            log.debug("Trusting all server certificates.");
        }

        @Override public X509Certificate[] getAcceptedIssuers() {
            log.debug("No accepted issuers.");
            return null;
        }
    }
}