erlang - 如何使用 Cowboy 通过 websocket 异步发送数据？

Question

我有一个Cowboy websocket 服务器，我想注册一个gen_event处理程序，通过 websocket 发送一些东西。我还需要能够使用websocket_handle/3. 我在cowboy_http_websocket_handler.erl中没有看到任何明显的内容，并且没有导出cowboy_http_websocket:websocket_send/3。我是否错过了通过打开的套接字发送内容的简单方法？

score 4 · Accepted Answer

@nmichaels 的回答为我指明了正确的方向，我在牛仔应用程序中成功使用 gen_event 将内部消息发送到 websocket_info。但是答案有点过时了，牛仔已经发生了很大变化，所以我想补充一下，并提供一个适用于最新牛仔版本的解决方案。希望这会帮助一些刚接触 Erlang 和牛仔的人。

在牛仔中实现 gen_event 需要三个步骤

启动 gen_event 并注册你的处理程序

start(_Type, _Args) ->
Dispatch = cowboy_router:compile(wrinqle_routes:routes_configuration()),
{ok, _} = cowboy:start_http(http, 100, [{port, 3000}],
                            [{env, [{dispatch, Dispatch}]}]),
  pg2:start(),

  gen_event:start({global,my_events}),
  gen_event:add_handler({global,my_events},my_event_handler,[]).

在这里，我已经在全局注册了名为 my_events 的事件（注意：您也可以在本地注册事件）并在模块 my_event_handler 中添加了处理程序

创建一个事件处理程序。
现在您可以从牛仔的任何地方通知您的事件处理程序。例如，下面的代码从 websocket_handler 引发事件
```
{ _,_ }->

   gen_event: notify(global:whereis_name(my_events),{event_name,self()}),
    {ok,Req,State};
```

这段代码所做的只是将事件通知在 my_events 下注册的事件。而已。

OP 遇到的另一个问题是如何向打开的连接和初始化时 pid 未知的连接发送消息。要解决这个问题，您可以使用pg2在通道下注册进程 ID。它是管理 PID 的一个非常有用的模块。所以上面的代码可以转换成这样的

  [H|T] = pg2:get_members(Name)
  gen_event: notify(global:whereis_name(my_events),{event_name, H}).

通过这种方式，您可以将消息发送到特定的 pid 并通过扩展发送到特定的套接字。

score 3 · Accepted Answer

在示例 websocket handler中， websocket_info/3 用于发送这样的内容。将 websocket 的初始化代码中的gen_event :add_sup_handler/3与 websocket_info/3 结合起来。将连接的 pid 保持在处理程序的状态，并仅发送带有异步事件的消息。

erlang - 如何使用 Cowboy 通过 websocket 异步发送数据？

2 回答 2

Related

Reference