gpt4 book ai didi

websocket - 使用 akka http 通过网络套接字推送消息

转载 作者:行者123 更新时间:2023-12-01 16:40:26 24 4
gpt4 key购买 nike

我正在使用 akka http 2.0.3 作为应用程序,并且想要使用网络套接字。我希望能够将消息从服​​务器推送到客户端,而不必先接收消息。因此,我正在研究 UpgradeToWebsocket 特征,看起来使用“handleMessagesWithSinkSource”是正确的选择。现在,为了推送消息,我希望有一个参与者连接到一个源,该源被传递到“handleMessagesWithSinkSource”方法。但是,当使用“Source.actorRef”方法时, Actor 似乎仅在流程运行时才生成,这将在“handleMessagesWithSinkSource”方法内。

所以,我的问题是,如何将消息推送到网络套接字 channel (最好是通过参与者)?

最佳答案

发现可以将 ActorPublisher 传递给 Source:

Source.fromPublisher(ActorPublisher(myActorPublisher)

这样,发布者首先被实例化,然后传递给 Source,然后传递给“handleMessagesWithSinkSource”

关于websocket - 使用 akka http 通过网络套接字推送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/35634283/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com