监督的GenServer没有重启？

Question

我缩小了问题的大小,因为它太大了.这是代码:

defmodule MayRaiseGenServer do
  use GenServer

  def start_link do
    IO.puts "started MyServer, name is #{__MODULE__}"

    GenServer.start_link(__MODULE__, [], name: __MODULE__)
  end

  def maybe_will_raise do
    GenServer.call(__MODULE__, :maybe_will_raise)
  end

  def handle_call(:maybe_will_raise,_from, state) do
    IO.puts "maybe_will_raise called!"
    :random.seed(:erlang.now)
    number = Enum.to_list(1..100) |> Enum.shuffle |> List.first
    IO.puts "number is #{number}"
    if rem(number,2) != 0 do
      raise "#{number}"
    end
    {:reply, {"You got lucky"}, state}
  end
end

defmodule MayRaiseSupervisor do
  use Supervisor

  def start_link([]) do
    IO.puts "starting supervisor, name is #{__MODULE__}"
    Supervisor.start_link(__MODULE__, [])
  end

  def init(arg) do
    IO.puts "initted with arg: #{arg}"
    children = [
      worker(MayRaiseGenServer, [])
    ]

    supervise(children, strategy: :one_for_one, restart: :transient, name: __MODULE__)
  end
end

MayRaiseSupervisor.start_link([])
IO.inspect MayRaiseGenServer.maybe_will_raise
:timer.sleep(2000)
IO.puts "after sleep"

最初,我只看到一次启动GenServer的消息,但现在我再次看到它.这是输出:

starting supervisor, name is Elixir.MayRaiseSupervisor
initted with arg:
started MyServer, name is Elixir.MayRaiseGenServer
maybe_will_raise called!
number is 14
started MyServer, name is Elixir.MayRaiseGenServer

11:32:28.807 [error] GenServer MayRaiseGenServer terminating
** (RuntimeError) 14
    lib/mini.ex:20: MayRaiseGenServer.handle_call/3
    (stdlib) gen_server.erl:615: :gen_server.try_handle_call/4
    (stdlib) gen_server.erl:647: :gen_server.handle_msg/5
    (stdlib) proc_lib.erl:247: :proc_lib.init_p_do_apply/3
Last message: :maybe_will_raise
State: []
** (exit) exited in: GenServer.call(MayRaiseGenServer, :maybe_will_raise, 5000)
    ** (EXIT) an exception was raised:
        ** (RuntimeError) 14
            lib/mini.ex:20: MayRaiseGenServer.handle_call/3
            (stdlib) gen_server.erl:615: :gen_server.try_handle_call/4
            (stdlib) gen_server.erl:647: :gen_server.handle_msg/5
            (stdlib) proc_lib.erl:247: :proc_lib.init_p_do_apply/3
    (elixir) lib/gen_server.ex:604: GenServer.call/3
    lib/mini.ex:45: (file)
    (elixir) lib/code.ex:363: Code.require_file/2

从上面的输出来看,我不太清楚会发生什么.根据IO上显示的消息,看起来GenServer重新启动,但为什么再次抛出异常？此外,在此代码中:

MayRaiseSupervisor.start_link([])
IO.inspect MayRaiseGenServer.maybe_will_raise
:timer.sleep(2000)
IO.puts "after sleep"

如果方法调用MayRaiseGenServer.maybe_will_raise确实会引发错误,那么它看起来就像之后的行,带有timer.sleep和IO.puts不再运行的行.即使我更改代码以尝试处理异常,如下所示:

MayRaiseSupervisor.start_link([])
try do
  IO.inspect MayRaiseGenServer.maybe_will_raise
rescue
  RuntimeError -> IO.puts "there was an error"
end
:timer.sleep(2000)
IO.puts "after sleep"

我似乎仍然无法达到最后IO.puts(如果有错误).有没有办法处理调用,maybe_will_raise这将允许我处理它引发错误,并继续执行？我猜测主管在重启时不会自动重试一段代码.

Answer 1

正如我的观点。

上面的输出告诉您当使用退出信号引发异常时的堆栈跟踪GenServer.call(MayRaiseGenServer, :maybe_will_raise, 5000)以及错误日志，因为terminate/2调用时有一个原因{%RuntimeError{message: ...}, [...]。

您可以定义terminate/2回调来查看：

def terminate(reason, _state) do
  IO.inspect reason
end

终止/2

如果 Reason 不是 :normal, :shutdown 也不是 {:shutdown, term}，则会记录错误。

但是，当 GenServer 回调内部引发异常时（除了init/1），它将调用terminate/2通知服务器即将退出（已发送退出信号）。

因此该行之后的代码将不会被执行：

try do
IO.inspect MayRaiseGenServer.maybe_will_raise
...

但 IO.puts“started MyServer”输出不应该再次出现吗？

并且当您的 GenServer 退出时。您的主管将启动一个新的进程，将主进程与您的 GenServer 进程链接起来（您MayRaiseGenServer.start_link再次接到电话）

最后一件事是如果你想让代码继续执行。你可以像这样捕获退出信号：

MayRaiseSupervisor.start_link([])
try do
  IO.inspect MayRaiseGenServer.maybe_will_raise
catch
  :exit, _ -> IO.puts "there was an error"
end
:timer.sleep(2000)
IO.puts "after sleep"

raise但我认为你应该考虑在 GenServer 回调中使用。希望有所帮助！