ZeroMQ 线程/任务建议

Question

我有一个任务正在为我的 Sub/Pub 模式运行此方法。我看到的问题是这个循环将挂起，直到收到数据。如果我想更改主题或 IP，我无法完成此任务。如果我使用线程，我可以杀死它 - 但这似乎是一个丑陋的解决方案。有没有一种很好的异步方式来设置订阅者的接收端。

ReceiveTask = new Task(ReceiveData);
ReceiveTask.Start();

private void ReceiveData()
{
    while (true)
    {
        byte[] messageTopicReceived = SubSocket.ReceiveFrameBytes();
        byte[] messageReceived = SubSocket.ReceiveFrameBytes();
    }
    //Code that uses byte array and do stuff
}

Answer 1

您可以改为调用 Try 扩展程序，它具有以下签名：

public static bool TryReceiveFrameBytes([NotNull] this IReceivingSocket socket, TimeSpan timeout, out byte[] bytes)

这将允许您将TimeSpan.Zero 作为timeout 传递，这将使其成为非阻塞调用。使用while(true) 可以正常工作，但您可能需要在其中添加Task.Delay 或Thread.Sleep。 Task.Delay 会工作得最好，因为它接受 CancellationToken。可以从不同的线程取消该令牌以快速退出循环。大致如下：

private void ReceiveData(CancellationToken cancellationToken)
{
    while (true)
    {
        bool receivedTopicMessage = SubSocket.TryReceiveFrameBytes(TimeSpan.Zero, out byte[] messageTopicReceived);
        bool receivedMessage = SubSocket.TryReceiveFrameBytes(TimeSpan.Zero, out byte[] messageReceived);

        Task.Delay(1000, cancellationToken);
        if (cancellationToken.IsCancellationRequested)
        {
            return;
        }
    }
    //Code that uses byte array and do stuff
}