使用websocket(Erlang、RabbitMQ、websocket、Gen_bunny、Cowboy)向所有连接的用户广播消息

Question

我甚至可以将消息回复给发送它的用户。但是，我要将消息广播给所有连接的用户。

根据我的理解，Erlang将为每个用户创建一个单独的进程。那么，在我拿回RabbitMQ的响应后，如何广播给所有连接的用户呢？？

Answer 1

查看gproc项目：https://github.com/uwiger/gproc

它有一个pub/sub模式，您可以使用它来构建您提到的聊天。

摘自GPROC的Wiki：

subscribe(EventType) ->
    %% Gproc notation: {p, l, Name} means {(p)roperty, (l)ocal, Name}
    gproc:reg({p, l, {?MODULE, EventType}}).

notify(EventType, Msg) -> 
    Key = {?MODULE, EventType},
    gproc:send({p, l, Key}, {self(), Key, Msg}).