Webシステムにおいて、同じ画面を複数ユーザーが表示・操作している状態で画面を同期化したいと考えています。
○期待している動作
ユーザが画面を操作>AjaxでDBを更新>更新内容を、同じ画面を開いている別ユーザの画面にも反映
○現状
play.libs.EventSourceのリファレンスに乗っているサンプルコードを実装し、一定時間ごとにサーバからクライアントへデータを送信できることを確認しました。
・javascript
$(function() {
/**************************************************************************
*
* 同期処理用SSE
*
**************************************************************************/
var eventSource = new EventSource("/xxx/sse/test");
eventSource.onmessage = function (event) {
alert(event.data);
};
});
・サーバ側
public Result testSSE() {
Source<String, ?> tickSource = Source.tick(Duration.Zero(), Duration.create(10000, TimeUnit.MILLISECONDS), "TICK");
Source<EventSource.Event, ?> eventSource = tickSource.map((tick) -> EventSource.Event.event(df.format(ZonedDateTime.now())));
return ok().chunked(eventSource.via(EventSource.flow())).as(Http.MimeTypes.EVENT_STREAM);
}
○疑問
このサンプルを参考に、「一定時間ごと」ではなく「DB更新処理が完了する毎」にフラグを変更したいのですが、方法がわからずに頓挫している状態です。
ご存知の方がいらっしゃいましたらご協力をお願いします・・・。
○仮説
AkkaStreamで時間ごとに繰り返してるようなのでその処理を削り、DB保存処理の完了後にeventSourceを作成してやればいくのでは?と考えました。
しかし結果として、DB保存処理を走らせていないにも関わらず、3秒程度の間隔でクライアント側にメッセージが表示されました。
Source.singleの意味合いを勘違いしていると思うのですが、現状はここで行き詰っています。
・javascript
$(function() {
/**************************************************************************
*
* 同期処理用SSE
*
**************************************************************************/
var eventSource = new EventSource("/xxx/sse/test2");
eventSource.onmessage = function (event) {
alert(event.data);
};
});
・サーバ側
public Source<EventSource.Event, ?> eventSource = Source.single(EventSource.Event.event("test Datas"));
public Result saveDB() {
...
eventSource = Source.single(EventSource.Event.event("test Datas"));
}
public Result testSSE2() {
return ok().chunked(eventSource.via(EventSource.flow())).as(Http.MimeTypes.EVENT_STREAM);
}