当客户端关闭连接时,Cowboy/Ranch 会终止处理程序进程

Myk*_*ykh 5 erlang elixir cowboy ranch phoenix-framework

我有 Phoenix 应用程序,HTTP 端点背后有复杂的业务逻辑。此逻辑包括与数据库和少量外部服务的交互,一旦请求处理开始,就不得中断,直到所有操作完成为止。

但如果客户端突然关闭连接,Cowboy 或 Ranch 似乎会杀死请求处理程序进程(Phoenix 控制器),这会导致部分执行的业务流程。为了调试这个,我在控制器操作中有以下代码:

Process.flag(:trap_exit, true)

receive do
  msg -> Logger.info("Message: #{inspect msg}")
after
  10_000 -> Logger.info("Timeout")
end
Run Code Online (Sandbox Code Playgroud)

为了模拟连接关闭,我设置了 timeout: curl --request POST 'http://localhost:4003' --max-time 3。在 IEx 控制台中 3 秒后,我看到该进程即将退出:Message: {:EXIT, #PID<0.4196.0>, :shutdown}

因此,我需要让控制器完成其工作,并在客户端仍然存在时回复客户端,或者如果连接丢失则不执行任何操作。这将是实现这一目标的最佳方法:

  • 陷阱在控制器操作中退出并忽略退出消息;
  • 生成未链接Task到控制器操作并等待其结果;
  • 如果可能的话,以某种方式配置 Cowboy/Ranch,这样它就不会杀死处理程序进程(尝试过exit_on_close但没有运气)?

Hau*_*eth 3

处理进程将在请求结束后被杀死,这就是它们的目的。如果你想在后台处理一些数据,那么启动额外的进程。最简单的方法是您提出的第二种方法,但稍微修改一下使用Task.Supervisor.

因此,在您的应用程序主管中,您可以Task.Supervisor从您选择的名称开始:

children = [
  {Task.Supervisor, name: MyApp.TaskSupervisor}
]

Supervisor.start_link(children, strategy: :one_for_one)
Run Code Online (Sandbox Code Playgroud)

然后在您的请求处理程序中:

parent = self()
ref = make_ref()

Task.Supervisor.start_child(MyApp.TaskSupervisor, fn() ->
  send(parent, {ref, do_long_running_stuff()})
end)

receive do
  {^ref, result} -> notify_user(result)
end
Run Code Online (Sandbox Code Playgroud)

这样您就不必担心用户不再接收消息时的处理情况。