首页 > 编程语言 >java-rabbitmq-交换机介绍

java-rabbitmq-交换机介绍

时间:2022-10-28 15:03:59浏览次数:46  
标签:java exchange 队列 绑定 rabbitmq 交换机 routing key


java-rabbitmq-交换机介绍


RabbitMQ的四种交换机


直连交换机:Direct exchange
扇出交换机:Fanout exchange
主题交换机:Topic exchange
首部交换机:Headers exchange


【扇出交换机(Fanout exchange)】
特点:不需要自定义定义路由键,只需要将“队列名”和“交换器”进行绑定即可收到消息。
扇出交换机是最基本的交换机类型,它所能做的事情非常简单———广播消息。扇出交换机会把能接收到的消息全部发送给绑定在自己身上的队列。因为广播不需要“思考”,所以扇出交换机处理消息的速度也是所有的交换机类型里面最快的。


【直连交换机(Direct exchange)】
特点:需要且完全匹配“路由键”,消息只能发送到绑定了相同路由键的队列中。
直连交换机是一种带路由功能的交换机,一个队列会和一个交换机绑定,除此之外再绑定一个routing_key,当消息被发送的时候,需要指定一个routing_key,这个消息被送达交换机的时候,就会被这个交换机送到指定的队列里面去。同样的一个routing_key也是支持应用到多个队列中的。
这样当一个交换机绑定多个队列,就会被送到对应的队列去处理。
适用场景:有优先级的任务,根据任务的优先级把消息发送到对应的队列,这样可以指派更多的资源去处理高优先级的队列。


【主题交换机(Topic exchange)】
特点:需要路由键的支持,且路由键可以使用通配符进行模糊匹配。
直连交换机的routing_key方案非常简单,如果我们希望一条消息发送给多个队列,那么这个交换机需要绑定上非常多的routing_key,假设每个交换机上都绑定一堆的routing_key连接到各个队列上。那么消息的管理就会异常地困难。
所以RabbitMQ提供了一种主题交换机,发送到主题交换机上的消息需要携带指定规则的routing_key,主题交换机会根据这个规则将数据发送到对应的(多个)队列上。
主题交换机的routing_key需要有一定的规则,交换机和队列的binding_key需要采用*.#.*.....的格式,每个部分用.分开,其中:
*表示一个单词
#表示任意数量(零个或多个)单词。
假设有一条消息的routing_key为fast.rabbit.white,那么带有这样binding_key的几个队列都会接收这条消息:


【首部交换机(Headers exchange)】
特点:该类型使用的比较少,它也是忽略routingKey的一种路由方式。
首部交换机是忽略routing_key的一种路由方式。路由器和交换机路由的规则是通过Headers信息来交换的,这个有点像HTTP的Headers。将一个交换机声明成首部交换机,绑定一个队列的时候,定义一个Hash的数据结构,消息发送的时候,会携带一组hash数据结构的信息,当Hash的内容匹配上的时候,消息就会被写入队列。
绑定交换机和队列的时候,Hash结构中要求携带一个键“x-match”,这个键的Value可以是any或者all,这代表消息携带的Hash是需要全部匹配(all),还是仅匹配一个键(any)就可以了。相比直连交换机,首部交换机的优势是匹配的规则不被限定为字符串(string)。

标签:java,exchange,队列,绑定,rabbitmq,交换机,routing,key
From: https://blog.51cto.com/u_4518216/5804881

相关文章

  • java-jsoup-解析html文本
    java-jsoup-解析html文本jsoup是一款Java的HTML解析器,可直接解析某个URL地址、HTML文本内容。它提供了一套非常省力的API,可通过DOM,CSS以及类似于j......
  • java + springmvc 酷炫验证码分享
    java+springmvc酷炫验证码分享一、maven依赖<!--https://mvnrepository.com/artifact/com.github.bingoohuang/patchca--><!--验证码--><dependency><groupId>com......
  • 为何工业交换机的价格差别这么大?看完你就明白了
    工业交换机的信号覆盖面是相当广泛的,在一定的平方米数以内,它们都能正常覆盖,在这以前大伙儿也曾用过很多相似的产品,结果发现覆盖面十分狭窄,假如超出了特定的面积就没有办法正......
  • Java8新特性4:Optional
    1Optional介绍Optional类是一个可以为null的容器对象。如果值存在则isPresent()方法会返回true,调用get()方法会返回该对象。Optional是个容器:它可以保存类型T的值,或者......
  • java-guava 布隆筛选器用法及比较
    java-guava布隆筛选器用法及比较布隆筛选器使用场景:   一般用于一个字符串是否存的预测,如爬虫是否抓取过这个URL等。优点:   对于特大的集合来说,检索快、占用内......
  • java springboot 2.x 环境搭建
    环境:javaversion1.8ApacheMaven3.2.2 ide:ideaspringboot:2.1.3.RELEASE创建步骤:1file=>new=>mudule...2选择SpringInitializr:modulesdk选择1.7,其他默认......
  • java-字符串拼接几种方法的性能比较
    java-字符串拼接几种方法的性能比较一、测试方法:String.format();MessageFormat.format();StringBuilder();二、测试结果:性能:StringBuilder>MessageFormat>String三......
  • 力扣907(java)-子数组的最小值之和(中等)
    题目:给定一个整数数组arr,找到min(b) 的总和,其中b的范围为arr的每个(连续)子数组。由于答案可能很大,因此返回答案模10^9+7。 示例1:输入:arr=[3,1,2,4]输......
  • java-floyd最短距离算法
    java-floyd最短距离算法publicstaticvoidmain(String[]args){MatrixDGmatrixDG=newMatrixDG();System.out.println("初始化邻接矩阵");matrixDG.print......
  • Java-五种线程池,四种拒绝策略,三类阻塞队列
    Java-五种线程池,四种拒绝策略,三类阻塞队列(常用)三类阻塞队列:   //1有界队列   workQueue=newArrayBlockingQueue<>(5);//基于数组的先进先出(FIFO)队列,支持公......