下面的代码的功能是从RabbitMQ中获取数据,为什么不产生死锁(deadlock)

GrootSwt · · 350 次点击 · 开始浏览    置顶
```go func failOnError(err error, msg string) { if err != nil { log.Fatalf("%s: %s", msg, err) } } func main() { // 创建连接 conn, err := amqp.Dial("amqp://admin:admin@localhost:5672/") failOnError(err, "Failed to connect to RabbitMQ") defer conn.Close() // 创建连接通道 ch, err := conn.Channel() failOnError(err, "Failed to open a channel") defer ch.Close() // 如果没有消息队列,创建消息队列 _, err = ch.QueueDeclare( "AUDITLOG_TOPIC_client-40009", true, false, false, false, nil, ) failOnError(err, "Failed to declare a queue") // 从消息队列中获取消息 msgs, err := ch.Consume( "AUDITLOG_TOPIC_client-40009", "", true, false, false, false, nil, ) failOnError(err, "Failed to register a consumer") forever := make(chan bool) // 创建协程获取消息队列 go func() { for d := range msgs { // json数据转换为logDto var logDto dto.LogDto err = json.Unmarshal(d.Body, &logDto) failOnError(err, "Failed to unmarshal json") // logDto转换为logModel logModel := convertor.LogDtoTogModel(logDto) service.InsertLogService(logModel) } }() // 为什么不会deadlock??? <-forever } ```

有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:1006366459

350 次点击  
加入收藏 微博
11 回复  |  直到 2020-11-05 15:32:06
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传