golang中for循环遍历channel时需要注意的问题详解
更新时间：2018年04月12日 08:39:32 作者：xialeistudio
这篇文章主要给大家介绍了关于golang中for循环遍历channel时需要注意的问题的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。
前言
for循环是Go语言唯一的循环结构，最近在做一个基于RabbitMQ的应用，由于官方的qos没有golang的版本，所以出了一点问题。
问题代码如下：
_, ch, err := component.NewRabbitMQ()
if err != nil {
panic(err)
}
if err := ch.Qos(10, 0, true); err != nil {
panic(err)
}
msgs, err := ch.Consume("push", "", false, false, false, false, nil)
if err != nil {
panic(err)
}
for m := range msgs {
go func(d *amqp.Delivery) {
defer func() { d.Ack(false) }
// 处理消息
}(&m)
}
发现消费到10条消息，进程就退出了，但是exit code为0，表示系统是正常退出，由于做了日志记录可以确定消费了10条，所以初步确定是qos相关问题。
排查过程
- 首先是把d的tag打印出来，发现全部是一样的，可以确定是重复的一条消息
- 一开始想到可能是经典的go协程执行在for循环结束以后导致的，但是看我的代码不属于这种情况，有使用&m保证每一条消息都是不同循环传入的。所以判断可能是for循环的传递问题。
- 确定方向之后开始写了一个测试项目用来验证我的想法是否正确。
测试代码
package main
import "fmt"
func main() {
ch := make(chan int, 10)
for i := 0; i < 10; i++ {
ch <- i
}
close(ch)
for v := range ch {
fmt.Println(&v)
}
}
执行输出
0xc420086008 0xc420086008 0xc420086008 0xc420086008 0xc420086008 0xc420086008 0xc420086008 0xc420086008 0xc420086008 0xc420086008
到这里才焕然大悟，for循环中，如果循环变量不是指针，那么每次的变量是同一个，不过值变了。，所以上例中的RabbitMQ go协程消费消息那里，需要直接传递值而不是指针，经过测试之后发现，问题确实解决了。
题外话
测试代码那里，如果不close掉channel是会发生死锁的，原因是 当for循环读完channel的10个值之后会继续尝试读取下一个，而由于channel为空又没关闭，会一直阻塞形成死锁
TOOD
研究RabbitMQ Consumer部分的源码来看看消费channel被关闭的问题。
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。
相关文章
这篇文章主要为大家详细介绍了Go语言中的监视器模式与配置热更新的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下2024-03-03
今天小编就为大家分享一篇关于go各种import的使用方法讲解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-04-04
Channel是go语言内置的一个非常重要的特性,也是go并发编程的两大基石之一,下面这篇文章主要给大家介绍了关于Go中channel的相关资料,需要的朋友可以参考下2023-04-04
这篇文章主要为大家介绍了golang 流式读取和发送使用场景示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-12-12
GO 函数式选项模式(Functional Options Pattern)
Option模式支持传递多个参数，并且在参数个数、类型发生变化时保持兼容性，任意顺序传递参数，下面给大家介绍GO 函数式选项模式(Functional Options Pattern)的相关知识，感兴趣的朋友一起看看吧2021-10-10
这篇文章主要介绍了go语言遍历文件夹示例,本文直接给出实现代码,需要的朋友可以参考下2015-03-03
在 Go 语言中,有许多日志库可供选择,但在性能和灵活性方面,Zap 是其中的佼佼者,下面我们就来看看Go 项目中如何使用 Zap 进行结构化日志记录吧2024-11-11
Go string转int,int64,int32及注意事项说明
这篇文章主要介绍了Go string转int,int64,int32及注意事项说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-07-07
这篇文章主要为大家详细介绍了GO实现文件上传操作，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-07-07
相对于C/C++，golang有很多新颖的特性，例如goroutine,channel等等，这些特性其实从golang源码是可以理解其实现的原理。今天这篇文章主要来分析下golang多值返回以及闭包的实现，因为这两个实现golang源码中并不存在，我们必须从汇编的角度来窥探二者的实现。2016-09-09
最新评论