我有一个Cowboy websocket 服务器,我想注册一个gen_event处理程序,通过 websocket 发送一些东西。我还需要能够使用websocket_handle/3
. 我在cowboy_http_websocket_handler.erl中没有看到任何明显的内容,并且没有导出cowboy_http_websocket:websocket_send/3。我是否错过了通过打开的套接字发送内容的简单方法?
2 回答
@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 并通过扩展发送到特定的套接字。
在示例 websocket handler中, websocket_info/3 用于发送这样的内容。将 websocket 的初始化代码中的gen_event :add_sup_handler/3与 websocket_info/3 结合起来。将连接的 pid 保持在处理程序的状态,并仅发送带有异步事件的消息。