Multichannel distributed pub/sub messaging, with full duplication across several nodes.
Usage:
dps:new(<<"channel1">>),
dps:new(<<"channel2">>).
dps:publish(<<"channel1">>, <<"Message1">>).
TS = 0,
dps:subscribe(<<"channel1">>, TS),
dps:subscribe(<<"channel2">>, TS),
dps:subscribe(<<"channel3">>, TS),
receive
{dps_msg, Channel, LastTS, Messages} ->
reply({json, [{ts,LastTS},{messages,Messages}]})
end.
multi_fetch will wait for first message from any requested channel. Can return immediately with many messages, if your TS is too old and some messages have arrived after it.
TS = list_to_integer(proplists:get_value("ts",Query, "0")),
{ok, LastTS, Messages} = dps:multi_fetch([<<"channel1">>,<<"channel2">>], TS, 30000),
reply({json, [{ts,LastTS}, {messages,Messages}]}).
- Replace lists with a priority queue implementation
- Add tests (ideally - integration tests)
- Add more robust nodes discovering
- Add docs and specs
- Add channels closing support
- Compare to replicated redis pub/sub
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent