2021
06-04
06-04
golang 函数返回chan类型的操作
在阅读kafka的golang客户端代码sarama-cluster时,遇到了如下一段代码://Messagesreturnsthereadchannelforthemessagesthatarereturnedby//thebroker.////ThischannelwillonlyreturnifConfig.Group.Modeoptionissetto//ConsumerModeMultiplex(default).func(c*Consumer)Messages()<-chan*sarama.ConsumerMessage{returnc.messages}对于代码中的<-chan*sarama.ConsumerMessage产生了疑问,...
继续阅读 >