Go语言中如何按msgId顺序接收多通道数据并转发？

不需要依赖sync.Mutex和队列结构，既然两个输入通道的消息本身是按msgId有序的，完全可以用归并排序的合并思路来实现全局有序转发，全程只用通道操作和局部变量缓存，没有并发竞争问题。

核心逻辑 #

因为ch1和ch2各自的消息都是按msgId递增的，我们可以：

• 先从两个通道各取出第一个消息（缓存起来）
• 循环比较两个缓存消息的msgId，把较小的发送到目标通道，然后从对应输入通道取下一个消息补充缓存
• 当其中一个通道关闭且无缓存消息时，把另一个通道剩余的所有消息直接转发

代码实现 #

type msg struct {
    msgId uint32
    data  []byte
}

func mergeChannels(ch1, ch2 <-chan msg, out chan<- msg) {
    // 初始化缓存，存储两个通道当前待比较的消息
    var hasMsg1, hasMsg2 bool
    var msg1, msg2 msg

    // 先从ch1取第一个消息
    msg1, hasMsg1 = <-ch1
    // 先从ch2取第一个消息
    msg2, hasMsg2 = <-ch2

    for hasMsg1 || hasMsg2 {
        switch {
        // 只有ch1有缓存消息，直接发送
        case hasMsg1 && !hasMsg2:
            out <- msg1
            msg1, hasMsg1 = <-ch1
        // 只有ch2有缓存消息，直接发送
        case !hasMsg1 && hasMsg2:
            out <- msg2
            msg2, hasMsg2 = <-ch2
        // 两个都有缓存，比较msgId发送较小的
        case msg1.msgId <= msg2.msgId:
            out <- msg1
            msg1, hasMsg1 = <-ch1
        default:
            out <- msg2
            msg2, hasMsg2 = <-ch2
        }
    }
    // 所有消息处理完，关闭输出通道
    close(out)
}

为什么不需要锁？ #

整个合并逻辑在单个goroutine中执行，所有的通道接收、缓存变量读写、消息发送都是串行操作，不存在多个goroutine竞争共享资源的场景，因此完全不需要sync.Mutex。这种方式不仅代码简洁，性能也比加锁的队列方式更高。

扩展场景 #

如果有更多有序输入通道，可以把缓存逻辑扩展为一个小堆（优先队列），每次取出堆中msgId最小的消息发送，然后从对应通道取下一个消息入堆。不过对于两个通道的场景，直接归并是最高效的方案。

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