做网站推广的前期条件,网站搜索引擎优化技术,go搭建网站,管理类网站开发价格RabbitMQ-默认读、写方式介绍
RabbitMQ-发布/订阅模式
RabbitMQ-直连交换机(direct)使用方法
目录
1、概述
2、topic交换机使用方法
2.1 适用场景
2.2 解决方案
3、代码实现
3.1 源代码实现
3.2 运行记录
4、小结 1、概述
topic 交换机是比直连交换机功能更加强大的…
RabbitMQ-默认读、写方式介绍
RabbitMQ-发布/订阅模式
RabbitMQ-直连交换机(direct)使用方法
目录
1、概述
2、topic交换机使用方法
2.1 适用场景
2.2 解决方案
3、代码实现
3.1 源代码实现
3.2 运行记录
4、小结 1、概述
topic 交换机是比直连交换机功能更加强大的交换方式通过不同的路由规则可以实现fanout、direct两种交换机的功能。
2、topic交换机使用方法
2.1 适用场景
假设我们要对动物做一个描述根据速度、颜色、种类等特征对其进行分别入到不同的mq队列中routing key的格式为speed.colour.species比如说所有黄色动物入队列1跑的速度慢的还有小兔子入队列2哪该如何实现该需求呢
2.2 解决方案
结合2.1描述的需求我们可以画出如下框图 知识点解释
* (star) 和正则的功能类似可以代表一整个单词。
# (hash) 代表0个或者多个单词。
如果一条消息的routing key为「quick.orange.rabbit」将会被同时路由到Q1和Q2「lazy.orange.elephant」的routing key同样也将会被同时路由到Q1和Q2「quick.orange.fox」的消息只会被路由Q1【lazy.brown.fox】只会被路由到Q2【lazy.pink.rabbit】只会被路由到Q2一次虽然匹配了两个binding【quick.brown.fox】没有匹配到任何的绑定那么消息将会被丢弃。
如果一个队列绑定的是【#】那么他将会接收到所有的消息会忽略调binding key实现类似扇形交换机的功能。
如果一个routing key中没有设计【#】和【*】那么他会实现类似直连交换机的功能。
3、代码实现
3.1 源代码实现
生产者
package mainimport (fmtamqp github.com/rabbitmq/amqp091-go
)func main() {conn, err : amqp.Dial(amqp://guest:guestlocalhost:5672/)if err ! nil {fmt.Println(Failed to connect to RabbitMQ)return}defer conn.Close()ch, err : conn.Channel()if err ! nil {fmt.Println(Failed to open a channel)return}err ch.ExchangeDeclare(logs_topic, // nametopic, // typetrue, // durablefalse, // auto-deletedfalse, // internalfalse, // no-waitnil, // arguments)if err ! nil {fmt.Println(Failed to declare an exchange,err:, err)return}body : Hello World by topic exchangeerr ch.Publish(logs_topic, // exchangequick.orange.fox, // routing keyfalse,false,amqp.Publishing{ContentType: text/plain,Body: []byte(body),})if err ! nil {fmt.Println(Failed to publish a message)return}
}代码示例中routing key为【quick.orange.fox】这条消息将会被路由到2.2中的Q1队列中。
消费侧代码
package mainimport (fmtamqp github.com/rabbitmq/amqp091-go
)func main() {conn, err : amqp.Dial(amqp://guest:guestlocalhost:5672/)if err ! nil {fmt.Println(Failed to connect to RabbitMQ)return}defer conn.Close()ch, err : conn.Channel()if err ! nil {fmt.Println(Failed to open a channel)return}err ch.ExchangeDeclare(logs, direct, true, false, false, false, nil)if err ! nil {fmt.Println(Failed to declare an exchange)return}q, err : ch.QueueDeclare(logs_topic, // nametrue, // durablefalse, // delete when unusedfalse, // exclusivefalse, // no-waitnil, // arguments)err ch.QueueBind(q.Name, // queue name*.orange.*, // routing key(binding key)logs_topic, // exchangefalse,nil,)msgs, err : ch.Consume(q.Name, // queue, // consumertrue, // auto-acktrue, // exclusivefalse, // no-localfalse, // no-waitnil, // args)var forever chan struct{}go func() {for d : range msgs {fmt.Printf( [x] %s\n, d.Body)}}()fmt.Printf( [*] Waiting for logs. To exit press CTRLC)-forever
}3.2 运行记录
发送消息 接收消息 4、小结
学到这里发现topic交换机完全具备fanout、direct两种交换机的全部功能日常开发完全可以使用topic交换机根据不同routing key即可以实现扇形和直连交换机的功能。
比如第3章节中消费者routing key设置为【#】则这个队列可以接收所有消息类似扇形交换机功能。
