使用NetMQ的.NET7客户端报NetMQRuntime异步初始化异常排查

我有两个基于.NET 7的控制台应用，均使用NetMQ（v4.0.1.13），二者程序类结构相似，仅异步任务逻辑不同。程序类代码如下：

class Program
{
    private static readonly CancellationTokenSource cts = new();

    static void Main(string[] args)
    {
        AppDomain.CurrentDomain.ProcessExit += CurrentDomain_ProcessExit;
        var runtime = new NetMQRuntime();
        runtime.Run(cts.Token, <async client | server task here>);
    }

    private static void CurrentDomain_ProcessExit(object? sender, EventArgs e)
    {
        try
        {
            cts.Cancel();
        }
        catch { }
        finally
        {
            NetMQConfig.Cleanup();
        }
    }
}

客户端相关代码：

using var requestSocket = new RequestSocket();
requestSocket.Connect("tcp://localhost:5555");

...

requestSocket.SendMultipartMessage(newBlockMessage); // 步骤1
// 该行抛出"NetMQRuntime must be created before calling async functions"异常！
var result = await requestSocket.ReceiveFrameStringAsync(); // 步骤4

服务器相关代码：

using var responseSocket = new ResponseSocket();
responseSocket.Bind("tcp://localhost:5555");

...
NetMQMessage messages = await responseSocket.ReceiveMultipartMessageAsync(); // 步骤2

...

// 该行执行后客户端触发上述异常
ResponseSocket.SendFrame(SystemEvent.EventTypes.NewBlockAndTransferEventStored.ToString()); // 步骤3

服务器可正常处理异步操作，但客户端在步骤4接收服务器回复时抛出异常，无法定位问题原因。

核心原因 #

NetMQ的异步API必须依赖NetMQRuntime实例提供的上下文才能运行。客户端的RequestSocket是在NetMQRuntime.Run传入的异步任务外部创建的，导致调用异步接收方法时，当前线程没有绑定有效的NetMQRuntime上下文，因此抛出异常。而服务器的ResponseSocket是在异步任务内部创建的，自然处于Runtime上下文范围内，所以能正常执行异步操作。

解决方法 #

1. 调整客户端Socket创建位置
   将客户端的RequestSocket创建及所有操作逻辑，全部移到NetMQRuntime.Run传入的异步委托内部，确保Socket的生命周期完全处于Runtime上下文之中。修改后的客户端异步任务示例：

async Task ClientTask(CancellationToken token)
{
    using var requestSocket = new RequestSocket();
    requestSocket.Connect("tcp://localhost:5555");

    // 步骤1：发送消息
    requestSocket.SendMultipartMessage(newBlockMessage);
    // 步骤4：接收回复，此时已在NetMQRuntime上下文内，可正常执行异步操作
    var result = await requestSocket.ReceiveFrameStringAsync(token);
}

2. 传递取消令牌
   调用异步接收方法时传入CancellationToken，确保任务能响应程序退出时的取消信号，避免资源泄漏。

3. 保持服务器现有逻辑
   服务器的ResponseSocket创建逻辑已处于NetMQRuntime.Run的异步任务内部，符合NetMQ异步API的要求，无需修改。

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