2

伙计们！

我正在使用 WebSocket 实现一个聊天 Web 应用程序，但是，当在 Jetty 9.1.3.v20140225 上运行时，在建立连接之后，客户端没有接收到一些从服务器端发送的消息。奇怪的是，某些消息会出现这种不当行为，但其他消息都可以（请参阅最后的我的 PS）。

我已经尝试过 Chrome 33（我知道使用 permessage-deflate 扩展）和 FireFox 28（不使用），结果相似。实际上，Chrome 会收到一些消息，但 FireFox 却没有收到。

当应用程序在 TomCat 7.0.47 上运行时，它工作得很好，所以我怀疑问题出在 Jetty...

讲述的故事让我们看看重现问题的最小应用程序的代码：

首先有一个简单的页面，您可以通过单击相应按钮来连接、发送消息（并接收响应）和断开 WebSocket。

你好.html：

<html>
<head>
<meta charset="ISO-8859-1">
<title>Minimum - WebSocket Sandbox</title>
<script src="http://code.jquery.com/jquery-1.11.0.min.js"></script>
<script type="text/javascript">
    $(document).ready(function() {
        $("#connect").click(function() {
            connect();
        });
        $("#send").click(function() {
            send("John Doe");
        });
        $("#disconnect").click(function() {
            disconnect();
        });
    });
</script>
<script>
    var wsocket;

    function connect() {
        var base = getAppLocation("ws:");
        wsocket = new WebSocket(base + "/hello");
        wsocket.onmessage = function(e) {
            log("<<< " + e.data);
        };
        wsocket.onopen = function() {
            log("Connection opened.");
        };
        wsocket.onclose = function(e) {
            log("Connection closed.  Reason: (" + e.code + ") " + e.reason);
        };
        wsocket.onerror = function(e) {
            log("Error!");
        };
    }

    function disconnect() {
        wsocket.close(1000, "Closed by user.");
        wsocket = null;
    }

    function send(msg) {
        if ( !wsocket || wsocket.readyState != WebSocket.OPEN ) {
            log("Not connected.");
            return;
        }
        wsocket.send(msg);
        log(">>> " + msg);
    }

    function log(msg) {
        $("#output").append(msg + "<br/>");
    }

    /**
     * This just ajust WebSocket URL ocording to the server serving the page.
     */
    function getAppLocation(proto) {
        if ( !proto ) {
            proto = window.location.protocol;
        }
        else if ( proto == "ws:" && window.location.protocol == "https:" ) {
            proto = "wss:";
        }
        var host = window.location.host;
        var path = window.location.pathname.split('/')[1];
        var base = proto + "//" + host + "/" + path;
        return base;
    }
</script>
</head>
<body>
  <div>
    <button id="connect">Connect</button>
    <button id="send">Send</button>
    <button id="disconnect">Disconnect</button>
  </div>
  <div id="output"></div>
</body>
</html>

在服务器端，有一个端点会在打开连接后立即向客户端发送消息（注释掉的行显示了 Chrome 客户端接收到的示例消息）。它还回显从客户端收到的消息。

你好端点： 

package com.ciandt.helenov.sandbox.websocket.min;

import java.io.IOException;

import javax.websocket.EndpointConfig;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/hello")
public class HelloEndpoint {

    @OnOpen
    public void onOpen ( Session session, EndpointConfig conf ) {
        try {
            // this is not received in the client
            session.getBasicRemote().sendText( "o" );

            // this is (but only if client is a Chrome)
            // session.getBasicRemote().sendText( "a[\"100\"]" );
        }
        catch ( IOException e ) {
            e.printStackTrace();
        }
    }

    @OnMessage
    public void onMessage ( Session session, String msg ) {
        try {
            session.getBasicRemote().sendText( "Hello, " + msg + "!" );
        }
        catch ( IOException e ) {
            e.printStackTrace();
        }
    }
}

最后是打包和运行 Web 应用程序的 pom.xml。我通过 Eclipse 中的嵌入式 maven 插件同时运行 Jetty（出现问题的地方）和 TomCat（工作得很好）

pom.xml：

<project xmlns="http://maven.apache.org/POM/4.0.0" 
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="
             http://maven.apache.org/POM/4.0.0 
             http://maven.apache.org/maven-v4_0_0.xsd">

  <modelVersion>4.0.0</modelVersion>

  <name>WebSocket Mininum</name>
  <description>WebSocket Minimum Web Application</description>
  <groupId>com.ciandt.helenov.sandbox</groupId>
  <artifactId>ws-min</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>war</packaging>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <java.version>1.7</java.version>
    <slf4j.version>1.7.2</slf4j.version>
    <logback.version>1.0.13</logback.version>
    <jetty.version>9.1.3.v20140225</jetty.version>
    <tomcat.version>7.0.47</tomcat.version>
  </properties>

  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>3.1</version>
        <configuration>
          <compilerVersion>${java.version}</compilerVersion>
          <source>${java.version}</source>
          <target>${java.version}</target>
          <encoding>${project.build.sourceEncoding}</encoding>
          <compilerArgument>-proc:none</compilerArgument>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-war-plugin</artifactId>
        <version>2.4</version>
        <configuration>
          <attachClasses>true</attachClasses>
        </configuration>
      </plugin>
      <!-- Support to use Eclipse -->
      <plugin>
          <groupId>org.apache.maven.plugins</groupId>
          <artifactId>maven-eclipse-plugin</artifactId>
          <version>2.7</version>
          <configuration>
              <downloadSources>true</downloadSources>
              <downloadJavadocs>true</downloadJavadocs>
              <wtpversion>2.0</wtpversion>
          </configuration>
      </plugin>
      <!-- Support to run Jetty on Eclipse -->
      <plugin>
        <groupId>org.eclipse.jetty</groupId>
        <artifactId>jetty-maven-plugin</artifactId>
        <version>${jetty.version}</version>
        <configuration>
          <webAppConfig>
            <contextPath>/${project.artifactId}</contextPath>
          </webAppConfig>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.apache.tomcat.maven</groupId>
        <artifactId>tomcat7-maven-plugin</artifactId>
        <version>2.2</version>
        <configuration>
          <port>9090</port>
          <path>/${project.artifactId}</path>
          <systemProperties>
            <appserver.base>${project.build.directory}/tomcat-base</appserver.base>
            <appserver.home>${project.build.directory}/tomcat-home</appserver.home>
            <derby.system.home>${project.build.directory}/tomcat-base/logs</derby.system.home>
            <java.io.tmpdir>${project.build.directory}</java.io.tmpdir>
          </systemProperties>
        </configuration>
      </plugin>
    </plugins>
  </build>

  <dependencies>
    <dependency>
      <groupId>javax.websocket</groupId>
      <artifactId>javax.websocket-api</artifactId>
      <version>1.0</version>
      <scope>provided</scope>
    </dependency>
  </dependencies>

</project>

就这样！

在 Jetty 上运行应用程序时（通过调用 mvn jetty:run），我要求连接一个 WebSocket（通过单击页面上的连接按钮），端点中的 onOpen() 方法运行并将一条消息发送回客户端，但它没有收到，因为我希望它会显示。在 TomCat 上运行相同的应用程序时（通过调用 mvn tomcat7:run），它运行得很好。

有人有类似的问题吗？任何人都知道发生了什么？这可能是 Jetty 服务器上的错误吗？

TIA 和问候！

海伦诺

PS：我打算在我的应用程序中使用 Spring 和 SockJS，但是 SockJS 在服务器上中继在连接打开后发送一个“open frame”（只是一个“o”），但是由于它没有收到它，所以它放弃了 WebSocket连接并进行 XHR 流式传输。这就是我试图避免的。但是，由于我设法在没有 Spring 和 SockJS 的情况下重现了该问题（如提供的代码所示），因此我已将他们从与该问题的任何关系中解脱出来。

4

0 回答 0