読者です 読者をやめる 読者になる 読者になる

gRPCとServer-Sent Eventsでサーバプッシュできるplasmaを公開しました

この度OpenFRESHプロジェクト(生放送動画配信プラットフォーム FRESH!オープンソースプロジェクト)は、plasmaというプロダクトを公開しました。

f:id:a-yamada:20170403023140p:plain

plasmaとは

plasmaとは何ぞやという話ですが、gRPC streamとServer Sent Event(SSE)を用いた汎用的なServer Pushミドルウェア

github.com

f:id:a-yamada:20170405113205p:plain

Plasmaにイベントデータ(イベントタイプとPayload)を投げると、それを購読(SUBSCRIBE)しているクライアントに通知される。gRPC Streamを使っているので、基本的にgRPC対応言語で書かれたクライアントであれば利用可能。

WebフロントエンドはServer Sent Eventを利用することで購読が可能。SSEに関してはPolyfill(Yaffle/EventSource)があるのでこれを利用すると良い。

また、Dockerイメージも提供している。Plasmaの利用にはRedisが必要だが、docker-compose も用意してあるのですぐに試すことができる。

モチベーション

世の中のWebアプリやスマートフォンアプリはもちろん、サーバ間通信をするアプリケーションは目的の情報の状態変化を知るために定期的にポーリングして変化を検知するという手法が使われてきたが、変化を知るためだけに延々と同じようなリクエストを送り続けるのはリソースの無駄遣いすぎるのでやめたかった。とにかくこれに尽きる。

構想については自分が温めていたものを、3月からプロジェクトにやってきた徳の高い女性声優好きのインターン生 がほぼ一人で実装した感じ。インターン生のミッションとしてはちょうど良いと思いません?

plasmaのユースケース

SUBSCRIBE型のミドルウェアなので、多くのクライアントが特定のイベントを注視したいといったケースで力を発揮する。例えばFRESH!でいえば、番組のViewが放送前→放送開始になるといったケースでの利用を想定している(他にも色々ある)。

また、Microservices間でのイベント通知にも有効的な使い方できる。サービス間をgRPCで繋いでいるようなシステムであれば、似たようなことをしているケースもあるかと思われる。

イベントでPublishされるPayloadはそのままの中身でSubscribeしているクライアントに到達するので、接続しているクライアントによって返すPayloadを変えたい!みたいなケースには基本的に向いていないが、イベントだけ拾ってクライアントに別途APIで取りに行かせるという手法で回避ができる。

今後のアレコレ

性能的にはProductionで使えるレベルであることを確認しているので、今はplasmaを様々な箇所に投入やっていき〜💪なフェーズ。汎用的なミドルウェアとして作っているので、Payload部分だけが型の恩恵に預かれてないので今後どうしていこうかなぁと思いを馳せているところ。

plasmaだけではないけど、FRESH!としては今後も様々なプロダクトを野ざらしにしていく予定であります。