阻止消息挂起10000以阻止..使用spring websockets

Question

我在使用spring WebSockets时遇到以下错误：

用例：在我们的服务器端代码中，我们有一个在数据库中搜索值的功能。如果这些值不在数据库中。它将访问servlet并获取数据。第二部分，即访问servlet并获取数据是异步调用。

因此，对于一个请求，我们必须在数据库中搜索多个内容…

示例：在request中，我们得到了一个参数channel:1这个channel映射到多个ID，比如1映射到1,2,3,4,5

在websocket中，一旦请求到达服务器，我将提取通道，映射所有的ID，并在ID上运行一个循环，如下所示：

for(int i=0;i<ids.length;i++)
{

SomeObject databaseRespObj=callToDatabase(i); //SomeObject contains two fields value exists and string values

if(!databaseRespObj.valuesExists)
{
AsynchronouscallToServelt(i); 
//once response received it will send message immediately using session
}

}

在执行上面的服务器端代码时，有时只有我会遇到下面的错误。

java.lang.IllegalStateException: Blocking message pending 10000 for BLOCKING
        at org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.lockMsg(WebSocketRemoteEndpoint.java:130) ~[websocket-common-9.3.8.v20160314.jar:9.3.8.v20160314]
        at org.eclipse.jetty.websocket.common.WebSocketRemoteEndpoint.sendString(WebSocketRemoteEndpoint.java:379) ~[websocket-common-9.3.8.v20160314.jar:9.3.8.v20160314]
        at org.springframework.web.socket.adapter.jetty.JettyWebSocketSession.sendTextMessage(JettyWebSocketSession.java:188) ~[spring-websocket-4.2.4.RELEASE.jar:4.2.4.RELEASE]
        at org.springframework.web.socket.adapter.AbstractWebSocketSession.sendMessage(AbstractWebSocketSession.java:105) ~[spring-websocket-4.2.4.RELEASE.jar:4.2.4.RELEASE]

在spring中使用websocket会话发送异步消息的配置是什么

Answer 1

根据我的理解，当异步技术开始使用时，您有多个线程在同一remoteEndpoint上发送消息。

似乎和这个很相似：

WebSocket异步发送可能导致队列填充后阻塞发送

我不是websocket专家，但据我所知，您试图通过异步servlet调用实现什么是不可能的。但是，如果您更改了项目的设计/配置，这应该是可以实现的。

就我个人而言，我使用Websockets能够向不一定提出请求的任意用户发送消息--只要他连接了，他就必须得到消息。

为此，我只需使用Spring在websocket支持中提供的SimpMessagingTemplate类。要向所需的任何用户发送消息,请执行以下操作：

@Autowired
SimpMessagingTemplate smt;

(.......)
smt.convertAndSendToUser(recipient.getUsername(), "/queue/notify", payload);

• 进行类实例方法调用（而不是servlet，没有网络传输，您不能更快！只是调用您的业务逻辑/服务/什么）
• 每次方法返回数据时，请使用上面代码段中的SimpMessagingTemplate:)
• 如果您愿意，您仍然可以异步地执行此操作！：）

通过这样做，您可以减少延迟（调用servlet会增加很多），并拥有一种可靠的技术。您可以轻松快速地将数千条消息发送给一个用户或多个用户（由您自己决定），而不会遇到“10000条消息用于阻塞”的问题，该问题可能来自多个servlet“回答相同的问题”；）

要从Spring获得SimpMessagingTemplate，您需要使用 标记或等效的非xml-java-config。

我建议查看这个文档，它有更多的信息：http://docs.spring.io/spring/docs/current/spring-framework-reference/html/websocket.html

下面是我在上面创建的一篇文章（我在文章中遇到了另一个问题，与spring配置和上下文层次结构有关，但至少您有一些模板代码可以查看，这些代码是正常的）：

Spring Websocket：未从SimpMessagingTemplate接收任何信息

Spring：如何向根上下文公开SimpMessagingTemplate bean？