在使用nsq消費時，發(fā)現(xiàn)如果HandleMessage方法執(zhí)行時間超過2分鐘希太，在此方法運行完后克饶，就會 拋出
IO error - EOF錯誤。測試發(fā)現(xiàn)誊辉，當超過2分鐘時矾湃，nsqadmin 后臺顯示的節(jié)點未連接。在查看github Issues時堕澄，有人提出過邀跃，于是做了測試，發(fā)現(xiàn)一切正常蛙紫。（在實際開發(fā)中拍屑，不建議把慢執(zhí)行放在消費服務里，因為HandleMessage方法不執(zhí)行完坑傅，是不會消費下一個隊列消息的）
func (m *MyHandler) HandleMessage(msg *nsq.Message) (err error) {
// msg.NSQDAddress的地址是[--broadcast-address所指的ip] --broadcast-address=nsqd
fmt.Printf("%s recv from %v, msg:%v\n", m.Title, msg.NSQDAddress, string(msg.Body))
done := make(chan int)
go func() {
t := time.Tick(time.Second * 10)
for {
select {
case <-t:
fmt.Println("touch.")
msg.Touch()
case <-done:
return
}
}
}()
// 測試sleep500秒
time.Sleep(time.Second * 500)
done <- 1
/*//msg.DisableAutoResponse() // 禁用自動提交
// err := 執(zhí)行業(yè)務邏輯
if err != nil {
//msg.Requeue(time.Second * 5) // 重新放入隊列消費
} else {
//msg.Finish() // 手動提交消費完成僵驰，移出隊列
}*/
return
}
