求助：NetMQ中RouterSocket.ReceiveReady事件无限触发

问题原因 #

你的代码存在两个核心问题导致事件重复触发：

1. ReceiveReady事件处理函数中，直接使用全局router对象接收消息，而非事件参数提供的e.Socket。NetMQ的事件机制要求必须通过事件参数的套接字实例完成消息读取，否则会导致事件持续触发。
2. RouterSocket遵循多部分消息格式（身份帧+内容帧），若消息未被完整读取，也会触发重复接收事件。

修复后的代码 #

using NetMQ;
using NetMQ.Sockets;
using System.Text;

using (RouterSocket router = new RouterSocket())
{
    router.Connect("tcp://127.0.0.1:8976");
    router.ReceiveReady += RouterSocket_ReceiveReady;
    
    // RouterSocket通信需遵循多部分格式，客户端发送消息需携带身份帧（此处用空帧适配服务端逻辑）
    router.SendMultipartMessage(new NetMQMessage() 
    {
        new NetMQFrame(""),
        new NetMQFrame(Encoding.ASCII.GetBytes("Hello"))
    });

    using (NetMQPoller poller = new NetMQPoller { router })
    {
        poller.Run();
    }
}

void RouterSocket_ReceiveReady(object? sender, NetMQSocketEventArgs e)
{
    // 使用事件参数中的Socket接收消息，确保正确消费消息
    var message = e.Socket.ReceiveMultipartMessage();
    
    // 解析多部分消息：第一个帧是身份帧，后续为内容帧
    if (message.FrameCount > 1)
    {
        string content = Encoding.ASCII.GetString(message[1].Buffer);
        Console.WriteLine($"Received: {content}");
    }
}

额外注意事项 #

• 用using语句管理NetMQ套接字和Poller，避免资源泄漏。
• RouterSocket多用于服务端实现路由逻辑，若仅需简单请求-响应场景，推荐使用RequestSocket和ResponseSocket，它们已封装身份帧处理逻辑。
• 服务端回复RouterSocket客户端时，必须将收到的身份帧放在回复消息的最前面，否则客户端无法正确识别响应。

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