文章/答案/技术大牛

发布

社区首页 >问答首页 >Websockets锁

问Websockets锁
EN

Stack Overflow用户

提问于 2015-10-07 05:04:25

回答 2查看 1.2K关注 0票数 0

我使用的是websocket客户端的python和java实现。但是，由于onMessage是异步的，即使有另一个函数正在执行，它也会立即开始执行。如何确保每个onMessage函数在处理下一条消息之前完全完成。谢谢!

编辑:我订阅了多个通道，无论哪个通道发送消息，我的onMessage处理程序都会处理该消息。在开始处理下一条消息之前，我需要我的onMessage处理程序完全处理它收到的每条消息，但我不能丢失任何消息。我希望这有助于澄清一点。

java

python

websocket

回答 2

Stack Overflow用户

发布于 2015-10-07 16:23:53

这听起来只是一个同时存在的问题。这个怎么样？

private final Object onMessageLock = new Object();

@OnMessage
public void onMessage(String message, Session session)
{
    synchronized (onMessageLock)
    {
        // Handle the message here.
    }
}

票数 0

Stack Overflow用户

发布于 2016-04-27 23:04:03

我测试了Takahiko提出的解决方案。它只能在一个客户端上工作。来自不同客户端的消息仍将并行处理。

如果您希望在消息完全处理之后处理所有消息(无论发送它的客户端是什么)，则必须将Lock对象设为静态：

private static final Object onMessageLock = new Object();

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/32979715

复制

相似问题

问Websockets锁
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Websockets锁EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Websockets锁
EN