4种不同的交换机类型
直连交换机：Direct exchange
扇形交换机：Fanout exchange
主题交换机：Topic exchange
首部交换机：Headers exchange
交换机具体含意参考 https://www.jianshu.com/p/469...
Topic 交换机
以下代码参数具体含意能够参考 https://segmentfault.com/a/11...
Demo
生产者示例 producer.go
package mainimport ( "fmt" "github.com/streadway/amqp" "time")//因：疾速实现逻辑，故：不处理错误逻辑func main() { conn, _ := amqp.Dial("amqp://user:password@host:ip/vhost") ch, _ := conn.Channel() body := "Hello World! " + time.Now().Format("2006-01-02 15:04:05") fmt.Println(body) var exchange_name string = "j_exch_topic" var routing_key string = "jkey.a.b" var etype string = amqp.ExchangeTopic //申明交换器 ch.ExchangeDeclare(exchange_name, etype, true, false, false, false, nil) // fanout ch.Publish( exchange_name, // exchange 这里为空则不抉择 exchange routing_key, // routing key false, // mandatory false, // immediate amqp.Publishing{ ContentType: "text/plain", Body: []byte(body), //Expiration: "3000", // 设置过期工夫 }) // defer 关键字 defer conn.Close() // 压栈 后进先出 defer ch.Close() // 压栈 后进先出}$ go run producer.goHello World! 2021-03-18 16:08:13消费者示例 consumer.go
package mainimport ( "github.com/streadway/amqp" "log")func main() { conn, _ := amqp.Dial("amqp://user:password@host:ip/vhost") ch, _ := conn.Channel() var exchange_name string = "j_exch_topic" var routing_key string = "jkey.#" var queue_name string = "j_queue" var etype string = amqp.ExchangeTopic // 主题交换机 ch.QueueDeclare(queue_name, true, false, true, false, nil) //申明交换器 amqp.ExchangeFanout ch.ExchangeDeclare(exchange_name, etype, true, false, false, false, nil) ch.QueueBind( queue_name, // queue name routing_key, // routing key: topic 匹配jkey.# exchange_name, // exchange false, nil) //监听 msgs, _ := ch.Consume( queue_name, // queue name "", // consumer true, // auto-ack false, // exclusive false, // no-local false, // no-wait nil, // args ) forever := make(chan bool) go func() { for d := range msgs { //println("tset") log.Printf(" [x] %s", d.Body) } }() log.Printf(" [*] Waiting for logs. To exit press CTRL+C") <-forever}$ go run consumer.go2021/03/18 15:52:30 [*] Waiting for logs. To exit press CTRL+C2021/03/18 15:52:34 [x] Hello World! 2021-03-18 15:52:342021/03/18 15:53:14 [x] Hello World! 2021-03-18 15:53:142021/03/18 16:08:13 [x] Hello World! 2021-03-18 16:08:13