播放scala web套接字-按顺序不并行地点击web套接字

Question

我已经创建了一个web socket来接收单个消息，它将进行一些处理并将响应消息返回给客户端。我已经使用Play框架创建了web socket。下面给出了代码片段。

代码片段:

def multi_request = WebSocket.tryAccept[String] {
    request =>
      val (out, channel) = Concurrent.broadcast[String]
      val in = Iteratee.foreach[String] {
        msg =>
          channel push ("message " + msg +" request Time: " + System.currentTimeMillis()/1000)
          if(msg.equals("1")) {
            Thread.sleep(20000);
            println(msg);
          } else if(msg.equals("2")) {
            Thread.sleep(10000);
            println(msg);
          } else {
            println(msg);
          }
          channel push ("message " + msg +" response Time: " + System.currentTimeMillis()/1000)
      }
      Future.successful(Right(in, out))
  }

我已经测试了我的web套接字从http://www.websocket.org/echo.html.我连接了我的web套接字，并按顺序传递了三个消息，分别是“1”、“2”和“3”。我在传递这些消息时得到了下面的响应。

SENT: 1

RESPONSE: message 1 request Time: 1457351625

SENT: 2

SENT: 3

RESPONSE: message 1 response Time: 1457351645

RESPONSE: message 2 request Time: 1457351646

RESPONSE: message 2 response Time: 1457351656

RESPONSE: message 3 request Time: 1457351656

RESPONSE: message 3 response Time: 1457351656

web socket请求似乎是顺序地而不是并行地命中服务器的。当我经过客户端时，客户端立即发送了三条消息。但是它并没有同时攻击服务器。

也就是说，第二个请求在第一个响应消息之后命中。第三条消息在第二条响应消息之后出现。

这是默认的 Web 套接字行为吗？

还是我要在Scala play框架中实现多线程来处理这类请求？

或者我在处理来自单个客户端的多个请求的代码中遗漏了什么？

Answer 1

我知道这是网络套接字行为。这个 SO 问题详细解释了您的 Web 套接字连接如何由客户端计算机和服务器的对 （IP，PORT） 以及使用的协议唯一标识。

所以基本上，您的客户机和服务器之间只能有一个“物理websocket连接”（使用同一端口）。看着接受的文档，我读到

如果队列中不存在挂起的连接，并且套接字未标记为非阻塞，则 accept（） 会阻止调用方，直到存在连接。如果套接字被标记为非阻塞，并且队列中不存在挂起的连接，则 accept（） 将失败并显示错误 EAGAIN 或 EWILLBLOCK。

我希望有更了解情况的人来确认这一点，但我从这句话中了解到，由于您的潜在连接正忙于处理第一条消息，accept将告诉您的第二条请求“稍后再试”，因此会产生顺序效应。

如果您真的需要为一个客户端提供并行web套接字，我想在不同端口上打开连接会有所帮助。