Как настроить WebSockets (RFC 6455) в Netty 3.3? - PullRequest
Новая
       12

Как настроить WebSockets (RFC 6455) в Netty 3.3?

0 голосов
/ 26 января 2012

У меня есть сервер Netty 3.3 с WebSockets от https://github.com/netty/netty/tree/3.2/src/main/java/org/jboss/netty/example/http/websocketx/server

У меня есть клиент, который реализует RFC 6455, но сервер не может декодировать свои сообщения по умолчанию. Во время отладки я вижу, что используется WebSocket08FrameDecoder (вместо WebSocket13FrameDecoder). Когда я понижаю клиента до draft00, все работает нормально. Как настроить Netty для декодирования сообщений RFC 6455?

обновление

Клиент отправляет этот пакет рукопожатия: 

GET /websocket HTTP/1.1
Upgrade: WebSocket
Connection: Upgrade
Sec-WebSocket-Version: 13
Sec-WebSocket-Key: 5a087
Host: 127.0.0.1
Origin: 127.0.0.1

И рукопожатие на сервере WebSocketServerHandshaker13, но я все еще получаю ошибку: 

org.jboss.netty.handler.codec.frame.CorruptedFrameException: unmasked client to server frame
at org.jboss.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder.protocolViolation(WebSocket08FrameDecoder.java:350)
at org.jboss.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder.decode(WebSocket08FrameDecoder.java:138)
at org.jboss.netty.handler.codec.http.websocketx.WebSocket08FrameDecoder.decode(WebSocket08FrameDecoder.java:56)
at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:465)
at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:438)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:343)
at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:274)
at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:194)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)`

1 Ответ

2 голосов
/ 27 января 2012

Если вы заглянете в WebSocketServerHandshakerFactory , он создаст декодер на основе версии веб-сокета, переданной в заголовке HTTP. 

 public WebSocketServerHandshaker newHandshaker(HttpRequest req) {

    String version = req.getHeader(Names.SEC_WEBSOCKET_VERSION);
    if (version != null) {
        if (version.equals(WebSocketVersion.V13.toHttpHeaderValue())) {
            // Version 13 of the wire protocol - RFC 6455 (version 17 of the draft hybi specification).
            return new WebSocketServerHandshaker13(webSocketURL, subprotocols, allowExtensions);
        } else if (version.equals(WebSocketVersion.V08.toHttpHeaderValue())) {
            // Version 8 of the wire protocol - version 10 of the draft hybi specification.
            return new WebSocketServerHandshaker08(webSocketURL, subprotocols, allowExtensions);
        } else {
            return null;
        }
    } else {
        // Assume version 00 where version header was not specified
        return new WebSocketServerHandshaker00(webSocketURL, subprotocols);
    }
}

Пожалуйста, проверьте реализацию вашего клиента, чтобы увидеть, какую версию он отправляет в заголовке HTTP. Это должно быть Sec-WebSocket-Version: 13.

...