导语
昨天的内容主要讲了RabbitMQ的发布订阅模式和路由模式，都很好的满足了我们的日志打印，但是如果说，我对日志的打印，希望可以过滤掉一些内容呢，比如说，在打印错误日志的时候，只打印login时的错误？这个时候，就需要我们使用主题订阅的模式，可以说，主题订阅模式可以完全代替路由模式，因为在主题订阅模式中，如果没有响应的关键词，便和路由模式完全一样。
主题交换器介绍
在使用主题交换器时需要注意以下几点
在使用routing_key，必须是有点分隔符进行分隔
*可以代表代替一个单词
#可以代替0个或多个单词
案例
我们对我们之前的例子做修改，这次修改希望生产者可以在运行的时候指定路由需要增加下面这个函数
func severityFrom(args []string) string {
var s string
if (len(args) < 2) || os.Args[1] == "" {
s = "#"
} else {
s = os.Args[1]
}
fmt.Println(s)
return s
}
func bodyFrom(args []string) string {
var s string
if (len(args) < 3) || os.Args[2] == "" {
s = "hello"
} else {
s = strings.Join(args[2:], " ")
}
return s
}
现在来看我们的生产者
首先需要申请一个主题模式的交换器
err = ch.ExchangeDeclare(
"logs_topic", //交换器的名字
"topic", //交换器的类型、这里为广播类型
true, //是否持久
false, //无用的时候是否自动删除
false, //true表示是。客户端无法直接发送msg到内部交换器，只有交换器可以发送msg到内部交换器。
false, //no-wait
nil, //arguments
)
然后发送消息到交换器
err = ch.Publish(
"logs_topic", //发送到交换机的名字
severityFrom(os.Args), // routing key // 路由，即队列的名字
false, //mandatory
false, //immediate
amqp.Publishing{
DeliveryMode: amqp.Persistent, //消息的持久化
ContentType: "text/plain",
Body: []byte(body),
},
)
现在我们写两个消费者，消费者的路由不一样,消费者生产交换器和生产者完全一样，接着我们需要看第一个消费者绑定路由
err = ch.QueueBind(
q.Name, //队列的名字
"#.info.*", //routing key
"logs_topic", //所绑定的交换器
false,
nil,
)
第二个消费者绑定路由
err = ch.QueueBind(
q.Name, //队列的名字
"info.#", //routing key
"logs_topic", //所绑定的交换器
false,
nil,
)
运行
image
只有绑定了info.#收到了消息
image
image
现在尝试一下看看运行以上是否info.#和info.*都收到了消息？
推荐阅读
- 开发环境搭建（持续更新中）
- RabbitMQ系列笔记介绍篇
- Golang中Modle包的使用
- goriila context深入学习笔记
- Go Context深入学习笔记
- 基于Nginx和Consul构建高可用及自动发现的Docker服务架构
- 关于log日志的深入学习笔记
本文欢迎转载，转载请联系作者，谢谢！
- 公众号【常更新】：无崖子天下无敌
- GitHub：https://github.com/yuwe1
- CSDN【看心情更新】: https://blog.csdn.net/weixin_40051278
- 博客地址【定期更新】：https://mowuya.cn/
打开微信扫一扫，关注微信公众号
网友评论