// 未分类
RabbitMq Golang使用
发布 2020-05-18 · 永久链接
选个看起来挺活跃的RabbitMq吧
最近在做一个玩具项目的时候有用到MQ来分离两个服务，其中有个场景是类似广播，然后符合条件的服务给出回应。
直接的demo如下，主要是Exchange这些的配置的坑，以及Auto Ack之类的。
mq服务器是自己的旧笔记本，demo内网1000M跑起来还蛮壮观嘿嘿
``` go
package main
import (
"fmt"
"time"
"github.com/streadway/amqp"
)
func Api(port string) {
conn, err := amqp.Dial(fmt.Sprintf("amqp://%s:%s@%s:%d/", "dqn", "dqn", "192.168.1.104", 5672))
if err != nil {
println(err.Error())
}
chann, err := conn.Channel()
// publish each sec
go func() {
_ = chann.ExchangeDeclare("ApiSend", "fanout", false, false, false, false, nil)
for true {
chann.Publish("ApiSend", "", false, false, amqp.Publishing{
ContentType: "text/plain",
Body: []byte("data from api[" + port + "]"),
})
time.Sleep(1 * time.Nanosecond)
}
}()
_, _ = chann.QueueDeclare("ApiGetQueue", false, false, false, false, nil)
_ = chann.ExchangeDeclare("ApiGet", "fanout", false, false, false, false, nil)
_ = chann.QueueBind("ApiGetQueue", "", "ApiGet", false, nil)
consumeChan, err := chann.Consume("ApiGetQueue", "", false, false, false, false, nil)
if err != nil {
println(err.Error())
}
for d := range consumeChan {
println("[api get] --> ", string(d.Body))
d.Ack(false)
}
}
func Data(port string) {
conn, err := amqp.Dial(fmt.Sprintf("amqp://%s:%s@%s:%d/", "dqn", "dqn", "192.168.1.104", 5672))
if err != nil {
println(err.Error())
}
chann, err := conn.Channel()
// publish each sec
_ = chann.ExchangeDeclare("ApiGet", "fanout", false, false, false, false, nil)
_, _ = chann.QueueDeclare("ApiSendGet"+port, false, false, false, false, nil)
_ = chann.ExchangeDeclare("ApiSend", "fanout", false, false, false, false, nil)
_ = chann.QueueBind("ApiSendGet"+port, "", "ApiSend", false, nil)
consumeChan, err := chann.Consume("ApiSendGet"+port, "", false, false, false, false, nil)
if err != nil {
println(err.Error())
}
for d := range consumeChan {
println("[data "+port+" get] --> ", string(d.Body))
chann.Publish("ApiGet", "", false, false, amqp.Publishing{
ContentType: "text/plain",
Body: []byte("data from data[" + port + "]"),
})
d.Ack(false)
}
}
func main() {
go Api("1111")
go Data("2222")
Data("3333")
}
```