我正在使用akka http 2.0.3作为应用程序，并希望使用Web套接字。我希望能够将消息从服务器推送到客户端，而不必先接收消息。所以，我正在研究UpgradeToWebsocket特征，看起来使用"handleMessagesWithSinkSource"是正确的选择。现在，为了推送消息，我希望有一个参与者连接到传递给"handleMessagesWithSinkSource"方法的源。但是，当使用"Source.actorRef"方法时，似乎只有在流运行时才会生成参与者，这将在"handleMessagesWithSinkSource"方法中。
所以，我的问题是，如何将消息推送到 web-socket 通道，最好是通过参与者？
发现可以将 ActorPublisher 传递给源：
Source.fromPublisher(ActorPublisher(myActorPublisher)
这样，发布者首先被实例化，然后传递给Source，然后传递给'handleMessagesWithSinkSource'