分类导航

程序问答发布时间：2022-06-01 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了如何在 Golang 中使用 RabbitMQ 实现 Exchange Header？，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决如何在 Golang 中使用 RabbitMQ 实现 Exchange Header？？

开发过程中遇到如何在 Golang 中使用 RabbitMQ 实现 Exchange Header？的问题如何解决？下面主要结合日常开发的经验，给出你关于如何在 Golang 中使用 RabbitMQ 实现 Exchange Header？的解决方法建议，希望对你解决如何在 Golang 中使用 RabbitMQ 实现 Exchange Header？有所启发或帮助；

所以目前我正在使用 RabbitMQ 和 Golang。我在 RabbitMQ 主页上开始了教程并创建了队列和交换。但是我找不到任何解释如何在 Golang 中实现 Exchange header 的教程。@H_874_3@

重要的是，我也想知道，如何将数据放在 header 中，例如 ID 和名称？@H_874_3@

解决方法

我假设您的意思是队列或交换的名称。您可以遍历一个列表，或者如果 name 永远不会更改，则只需静态键入它。例如，我创建了 x 个基于 CPU 的队列，以将数据并行发送到每个核心，同时串行（每个队列在自己的线程上运行）。可能不是最好的方法，这是我的方法，并添加了一个明显没有内置的第三层，将循环串联到队列中！@H_874_3@

 package main
    
    import (
        "log"
    
        "github.com/streadway/amqp"
    )
    
    var i int = 0
    var coreCount []String = make([]String,runtime.NumCPU())
   
 func main() {
        //Make a connection
        conn,_ := amqp.Dial("amqp://guest:guest@localhost:5672/")
        defer conn.Close()
    
        //Ccreate a chAnnel
        ch,_ := conn.ChAnnel()
        defer ch.Close()
    
        //Declare a queue
        q,err := ch.QueueDeclare(
            "Hello",// Your Queue name is "Hello" bound to the Default Exchange <------ q.Name is Defined here
            false,// should the message be persistent? also queue will survive if the cluster gets reset
            false,// autodelete if there's no consumers (like queues that have anonymous names,often used with fanout exchangE)
            false,// exclusive means I should get an error if any other consumer subsribes to this queue
            false,// no-wait means I don't want RabbitMQ to wait if there's a queue successfully setup
            nil,// arguments for more advanced configuration
        )
    
        //Publish a message
        body := "Hello world"
        err = ch.Publish(
            "",// exchange <--- change the header here
            q.Name,// routIng key 
            false,// mandatory
            false,// immediate
            amqp.publishing{
                ContentType: "text/plain",Body:        []byte(body),})
        log.Printf("message: %s",body)
    
    }