在协议处理时,在正规处理流程之外想利用channel来做一个类似listener的机制,就是发现如果有listener就把协议数据发给它;而listener可以临时监听自己感兴趣的任意协议并触发相应事件。代码流程大致如下:
chdata := make(chan []byte)
// 协议处理主流程
func process(data []byte) {
defer func() {
// 如果有listener就把协议数据发给它
select { case chdata <- data: default: }
}() // 根据协议号做分发处理 switch data[0] { // ... }
}
// 某个逻辑处理函数
func foo() {
ch := make(chan bool) go func() {
select { case data := <-chdata:
// 等待某个协议 if data[0] == 100 {
ch <- true
}
}
}() <-ch // 后续处理...
}
但是实际发现经常明明协议已经收到了,可就是监听不到导致foo函数死锁或者超时。根本的原因在于当foo函数从chdata获取一个协议进行检查发现不是自己感兴趣的协议时,它所感兴趣的协议已经到达process函数,而这时foo实际上已经不是select的状态,所以process函数认为没有listener在channel上等待数据因而执行default分支,从而导致协议漏掉。