blocks|key|2349647|text|在Akka+actors的帮助下，我成功地实现了websocket。第一步，定义将处理消息执行元|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|2349648|public+class+WebSocketActor+extends+AbstractActor+{

++++private+final+ActorRef+out;

++++@Inject
++++public+WebSocketActor(ActorRef+out)+{
++++++++this.out+=+out;
++++}

++++@Override
++++public+Receive+createReceive()+{
++++++++return+receiveBuilder()
++++++++++++++++.match(String.class,+message+->
++++++++++++++++++++++++out.tell("Sending+message+at+"+%2B+LocalDateTime.now().toString(),+self())
++++++++++++++++)
++++++++++++++++.build();
++++}

++++public+static+Props+props(final+ActorRef+out)+{
++++++++return+Props.create(WebSocketActor.class,+out);
++++}
}|code-block|syntax|javascript|2349649|此执行元将为每个客户端创建。ActorRef+out将向已连接的客户端发送消息。在本例中，对于传递给WebSocketActor每个字符串消息，响应都会发送到客户端。|style|CODE|2349650|现在定义API端点，为客户端打开对websocket的访问。定义将在新连接上创建actor的新实例的ActorFlow|2349651|public+WebSocket+ws()+{
++++return+WebSocket.Text.accept(request+->+ActorFlow.actorRef((out)+->+WebSocketActor.props(out),+actorSystem,+materializer));
}|2349652|根据source+code的说法，ActorFlow使用flowActor名字创建演员。因此，为了将消息发送到代码中某个位置的websockets，我们可以根据参与者的path找到参与者。这将向所有连接的客户端广播消息|2349653|actorSystem.actorSelection("/user/*/flowActor").tell("Hello",+ActorRef.noSender());|2349654|不幸的是，我没有找到简单的方法来改变ActorFlow的默认名称，但也许这个答案可以帮助你play-scala-akka-websockets-change-actor-path。|2349655|你也可以从播放框架的例子中查看play-java-websocket-example项目。|2349656|entityMap|0|LINK|mutability|MUTABLE|url|https://www.playframework.com/documentation/2.6.x/JavaWebSockets#Handling-WebSockets-with-actors|1|https://github.com/playframework/playframework/blob/master/framework/src/play-streams/src/main/scala/play/api/libs/streams/ActorFlow.scala#L40|2|https://doc.akka.io/docs/akka/2.5/general/addressing.html#what-is-an-actor-path-|3|https://stackoverflow.com/questions/37281559/play-scala-akka-websockets-change-actor-path/37441095|4|https://github.com/playframework/play-java-websocket-example^0|1|B|0|0|0|E|C|1E|E|0|0|0|S|9|2|B|1|2C|4|2|0|0|19|18|3|0|F|R|4|0^^$0|@$1|2|3|4|5|6|7|1E|8|@]|9|@$A|1F|B|1G|1|1H]]|C|$]]|$1|D|3|E|5|F|7|1I|8|@]|9|@]|C|$G|H]]|$1|I|3|J|5|6|7|1J|8|@$A|1K|B|1L|K|L]|$A|1M|B|1N|K|L]]|9|@]|C|$]]|$1|M|3|N|5|6|7|1O|8|@]|9|@]|C|$]]|$1|O|3|P|5|F|7|1P|8|@]|9|@]|C|$G|H]]|$1|Q|3|R|5|6|7|1Q|8|@$A|1R|B|1S|K|L]]|9|@$A|1T|B|1U|1|1V]|$A|1W|B|1X|1|1Y]]|C|$]]|$1|S|3|T|5|F|7|1Z|8|@]|9|@]|C|$G|H]]|$1|U|3|V|5|6|7|20|8|@]|9|@$A|21|B|22|1|23]]|C|$]]|$1|W|3|X|5|6|7|24|8|@]|9|@$A|25|B|26|1|27]]|C|$]]|$1|Y|3|-4|5|6|7|28|8|@]|9|@]|C|$]]]|Z|$10|$5|11|12|13|C|$14|15]]|16|$5|11|12|13|C|$14|17]]|18|$5|11|12|13|C|$14|19]]|1A|$5|11|12|13|C|$14|1B]]|1C|$5|11|12|13|C|$14|1D]]]]

I've managed to implement websocket with help of <a href="https://www.playframework.com/documentation/2.6.x/JavaWebSockets#Handling-WebSockets-with-actors" rel="nofollow noreferrer">Akka actors</a>. At first step define actor that will handle messages

<pre><code>public class WebSocketActor extends AbstractActor {

 private final ActorRef out;

 @Inject
 public WebSocketActor(ActorRef out) {
 this.out = out;
 }

 @Override
 public Receive createReceive() {
 return receiveBuilder()
 .match(String.class, message -&gt;
 out.tell("Sending message at " + LocalDateTime.now().toString(), self())
 )
 .build();
 }

 public static Props props(final ActorRef out) {
 return Props.create(WebSocketActor.class, out);
 }
}
</code></pre>

This actor will be created per client. <code>ActorRef out</code> will send message to connected client. In this example response is send to client on each string message passed to <code>WebSocketActor</code>.

Now define API endpoint to open access to websocket for clients. Define ActorFlow that will create new instance of actor on new connection

<pre><code>public WebSocket ws() {
 return WebSocket.Text.accept(request -&gt; ActorFlow.actorRef((out) -&gt; WebSocketActor.props(out), actorSystem, materializer));
}
</code></pre>

According to <a href="https://github.com/playframework/playframework/blob/master/framework/src/play-streams/src/main/scala/play/api/libs/streams/ActorFlow.scala#L40" rel="nofollow noreferrer">source code</a> ActorFlow creates actors with <code>flowActor</code> name. So to send message to websockets somewhere in the code we can find actors by their <a href="https://doc.akka.io/docs/akka/2.5/general/addressing.html#what-is-an-actor-path-" rel="nofollow noreferrer">path</a>. This will broadcast message to all connected clients

<pre><code>actorSystem.actorSelection("/user/*/flowActor").tell("Hello", ActorRef.noSender());
</code></pre>

Unfortunately I didn't find easy way to change ActorFlow default name but maybe this answer may help you <a href="https://stackoverflow.com/questions/37281559/play-scala-akka-websockets-change-actor-path/37441095">play-scala-akka-websockets-change-actor-path</a>.

Also you can check <a href="https://github.com/playframework/play-java-websocket-example" rel="nofollow noreferrer">play-java-websocket-example</a> project from playframework examples.

I am trying to do the following with Play Framework 2.6 :

<ol>
<li>The browser targets the server and a websocket is created</li>
<li>Later on (after some other request is performed), the servers sends a message to the browser via the websocket previously created</li>
</ol>

1) Can be easily done with a route :

<pre><code>public WebSocket socket() {
 return WebSocket.Text.accept(request -&gt; {
 // Log events to the console
 Sink&lt;String, ?&gt; in = Sink.foreach(System.out::println);

 // Send a single 'Hello!' message and then leave the socket open
 Source&lt;String, ?&gt; out = Source.single("Hello!").concat(Source.maybe());

 return Flow.fromSinkAndSource(in, out);
 });
}
</code></pre>

and the websocket can be saved server side.

2) But then how can I send data via the websocket ? (triggered server side)

This was easy to do with 2.5 but the documentation is not very helpful for play 2.6.

Thank you

Create websocket with play framework 2.6

服务器

路由

我正在尝试使用Play Framework2.6来做以下事情：浏览器以服务器为目标并创建websocket随后(在执行了某些其他请求之后)，服务器通过先前创建的websocket 向浏览器发送消息1)可以通过路由轻松完成：public WebSocket socket() {    return WebSocket.T...

问使用play framework 2.6创建websocket
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用play framework 2.6创建websocketEN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用play framework 2.6创建websocket
EN