Elixir中修改Actor默认行为及添加行为钩子的实现方法咨询

Elixir 基于 Erlang VM 运行，VM 原生没有提供直接修改全局 send/2 底层逻辑、或者默认进程消息处理流程的官方全局钩子，但可以通过以下4种成熟方案实现你需要的行为植入、甚至自定义邮箱逻辑，覆盖从简单日志挂钩到深度自定义行为的全场景需求。

这是最稳妥的实现方式，无侵入性，也不会影响标准库逻辑：

• 封装自定义的消息发送函数，在调用原生 send/2 前执行发送端钩子（比如打印发送日志）
• 所有业务代码统一调用你封装的发送接口，而非直接使用原生 send/2
• 示例实现：

defmodule ActorHook do
  @moduledoc "统一封装带钩子的进程消息收发能力"
  def send(dest, msg) do
    # 发送端钩子逻辑，可自定义为日志、 metrics 统计等
    IO.inspect("[SEND] 发送进程: #{inspect self()} 目标进程: #{inspect dest} 消息内容: #{inspect msg}")
    # 发送带包装的消息，方便接收端识别并触发到达/处理钩子
    send(dest, {:wrapped_hook_msg, self(), msg})
  end
end

• 接收进程的处理逻辑中统一匹配 {:wrapped_hook_msg, from, payload} 结构，先执行到达钩子，再执行业务处理，处理完成后触发处理完成钩子即可。

如果你的 Actor 基本都是基于 GenServer 实现的，可以通过封装通用基类的方式植入全局钩子：

• 重写 GenServer 的 send/2、call/3、cast/2 接口，植入发送端钩子
• 重写 handle_info/2、handle_call/3、handle_cast/2 的默认回调，在调用业务逻辑前执行到达钩子，业务逻辑执行完成后触发处理完成钩子
• 如果需要修改默认邮箱行为，还可以重写 GenServer 的 handle_message/3 回调，直接干预消息入队、排序、丢弃、过滤等逻辑。

如果不想修改任何业务代码，需要全局给所有进程的消息收发加钩子，可以用 Erlang VM 自带的 Trace 能力：

• Trace 是 VM 原生提供的调试监控能力，可以监控所有进程的 send、receive 事件，不需要修改任何业务代码，也不需要强制业务使用封装接口
• 全局消息日志的示例实现：

# 开启所有进程的 send、receive 事件追踪
:erlang.trace(:all, true, [:send, :receive])

# 启动独立的 trace 事件处理进程，避免影响业务进程性能
spawn(fn -> trace_loop() end)

defp trace_loop do
  receive do
    # 匹配消息发送事件
    {:trace, sender, :send, msg, receiver} ->
      IO.inspect("[SEND] #{inspect sender} -> #{inspect receiver}: #{inspect msg}")
      trace_loop()
    # 匹配消息抵达目标进程邮箱事件
    {:trace, receiver, :receive, msg} ->
      IO.inspect("[ARRIVE] #{inspect receiver} 收到消息: #{inspect msg}")
      trace_loop()
  end
end

• 注意：Trace 会产生一定性能开销，生产环境使用需要严格控制追踪范围，不要全局全开。

如果你需要完全自定义进程的邮箱行为、消息处理全流程，可以直接基于 Erlang 的 proc_lib 实现自定义进程模板：

• 你可以完全自主控制消息从邮箱取出、排序、过滤、重试、处理的全链路逻辑，实现自定义邮箱优先级、消息持久化、自动熔断等任意定制能力
• 所有业务进程都基于你自定义的进程模板启动，即可全局生效你植入的所有钩子逻辑。

重要提醒：绝对不要尝试全局覆盖 Elixir 内核的原生 send/2 函数定义，会导致标准库、第三方依赖的核心逻辑异常，属于高危操作。

内容的提问来源于stack exchange，提问作者Astarno