RabbitMQ客户端消息未匹配指定模式问题求助

让我来帮你分析下这个常见的RabbitMQ消费问题——你的进程能收到消息但总是走到第二个handle_info子句，核心原因大概率是模式匹配不匹配，咱们一步一步来捋清楚：

1. 先确认实际收到的消息结构 #

你已经在第二个子句里用lager:info打印了Message，先仔细看日志输出：

• 是不是严格的{#'basic.deliver'{...}, #amqp_msg{...}}格式？
• 如果不是，可能是消费方式有误（比如用了basic_get而非basic_consume），或者RabbitMQ客户端版本差异导致结构体字段变化。

2. 检查State的结构匹配 #

第一个handle_info子句里的State定义是{Channel, Tag, Module}，这里有个很容易踩的坑：

• 你要确认gen_server在init/1里返回的State是不是完全这个结构？如果初始化时State是{Channel, Module}（没有中间的Tag），那这个子句直接匹配失败，跳转到第二个。
• 更关键的是：你把Tag同时放在了#'basic.deliver'{delivery_tag = Tag}和State里，这意味着模式匹配要求消息的delivery_tag必须等于State里存储的Tag值——这几乎不可能（除非你刻意把每个消息的delivery_tag提前存在State里，这显然不符合常规消费逻辑）！这大概率是变量名冲突导致的匹配失败，把State里的自定义值误命名成了Tag。

3. 修正方案示例 #

如果你的State不需要存储消息的delivery_tag（这个值每个消息自带，用完ack即可），可以把第一个子句的State改成更合理的结构：

handle_info({#'basic.deliver'{delivery_tag = Tag}, #amqp_msg{payload = Payload}}, {Channel, Module} = State) ->
    % 确认ack消息
    amqp_channel:cast(Channel, #'basic.ack'{delivery_tag = Tag}),
    % 启动子进程处理消息
    gen_server:start_link(Module, Payload, []),
    {noreply, State};
handle_info(Message, State) ->
    lager:info("Received unexpected message: ~p", [Message]),
    {noreply, State}.

如果你的State确实需要存储某个自定义Tag值，那就改个变量名避免冲突：

handle_info({#'basic.deliver'{delivery_tag = DeliveryTag}, #amqp_msg{payload = Payload}}, {Channel, MyCustomTag, Module} = State) ->
    amqp_channel:cast(Channel, #'basic.ack'{delivery_tag = DeliveryTag}),
    gen_server:start_link(Module, Payload, []),
    {noreply, State};
handle_info(Message, State) ->
    lager:info("Received unexpected message: ~p", [Message]),
    {noreply, State}.

最后验证步骤 #

修改后重启进程，如果还是匹配不上：

• 在init/1或者第二个子句里加日志打印当前State的结构：lager:info("Current State: ~p", [State])；
• 对比消息结构和State结构，确认模式匹配的每个部分都完全对应。

内容的提问来源于stack exchange，提问作者Ufuk Hacıoğulları