代码拉取完成,页面将自动刷新
go get -u gitee.com/wiscity/go-rabbitmq
package main
import (
"fmt"
"gitee.com/wiscity/go-rabbitmq"
)
func main() {
addr = "amqp://admin:admin@127.0.0.1:5672/"
# 建立连接
mq := rabbitmq.New(addr)
// 定义队列和交换机
queueExchange := rabbitmq.QueueExchange{
QueueName: "myname",
RoutingKey: "iot.report.opendoor.insert",
ExchangeName: "iot.device.report.opendoor",
ExchangeType: "topic",
}
# 建立生产者
publisher := mq.NewPublisher(queueExchange)
# 发送消息
publisher.Pub([]byte("message"))
# 建立消费者
consumer := mq.NewConsumer(queueExchange)
# 消费消息
consumer.Receive(func(msg amqp.Delivery) {
msg.Ack(false)
fmt.Println(string(msg.Body))
})
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。