交換機主要是接收消息并且轉發(fā)到綁定的隊列，交換機不存儲消息，在啟用ack模式后，交換機找不到隊列會返回錯誤。交換機有四種類型：Direct, topic, Headers and Fanout。

圖片

一、topic exchange----(模糊匹配) 

    按規(guī)則轉發(fā)消息(最靈活)，轉發(fā)消息主要是根據(jù)通配符。在這種交換機下，隊列和交換機的綁定會定義一種路由模式，那么，通配符就要在這種路由模式和路由鍵之間匹配后交換機才能轉發(fā)消息。

    1、 路由鍵(routingKey)：必須是字符，用句號.隔開：例如："order.a"；(一般有發(fā)布者定義)；

    2、路由模式：必須包含一個 星號（*），主要用于匹配路由鍵指定位置的一個單詞， #就表示相當于一個或者多個單詞。(例如:order.*.*.*….)（一般由接收者提供），但是也可通過rabbitmq客戶端配置。常用在隊列Queues定義中。

    direct類型要求routingkey完全相等，但是topic exchange可以有通配符：“*”:表示匹配一個單詞， “#”:則表示匹配沒有或者多個單詞。優(yōu)勢：可實現(xiàn)批量訂閱消費。(Routingkey與Queues之間支持模糊匹配)。

圖片

案例：

/**
     * 功能描述:通過消費端注解綁定的方式發(fā)送Topic交換機中
     * @MethodName: sendTopicMessageByZJ
     * @MethodParam: [messageData]
     * @Return: void
     * @Author: yyalin
     * @CreateDate: 2022/4/9 18:17
     */
    public void sendTopicMessageByZJ(String messageData){
        CorrelationData correlationData = new CorrelationData("1");
        rabbitTemplate.convertAndSend("topicExchange",
                "china.car",messageData,correlationData);
    }

二、direct exchange----默認的(全文匹配)

    direct 類型的行為是"先匹配, 再投送". 即:在綁定時設定一個 routingkey, 消息的routingkey 匹配時, 才會被交換器投送到綁定的隊列中。是RabbitMQ默認的交換機模式，也是最簡單的模式，根據(jù)key全文匹配去尋找隊列。(按照routingkey分發(fā)到指定隊列)

    所有發(fā)送到direct exchange的消息被轉發(fā)到routingkey中指定到queue。

注意：direct模式可使用rabbitmq自帶的exchange:AMQP default，所以不需將exchange進行任何綁定操作(binding)，消息傳遞時，routingkey必須完全匹配才會被對列接收，否則該消息會被拋棄。(Routingkey與Queues之間必須全文匹配)。

圖片

    在direct類型的exchange中，只有routingkey完全相同，exchange才會選擇對應的binging進行消息路由。

案例：

/**
     * 功能描述:通過消費端注解綁定的方式發(fā)送Direct交換機中
     * @MethodName: sendDirectMessageByZJ
     * @MethodParam: [messageData]
     * @Return: void
     * @Author: yyalin
     * @CreateDate: 2022/4/9 18:17
     */
    public void sendDirectMessageByZJ(String messageData){
        CorrelationData correlationData = new CorrelationData("1");
        rabbitTemplate.convertAndSend("directExchange",
                "blue",messageData,correlationData);
    }

三、headers Exchange----(自定義匹配規(guī)則)

    設置header attribute參數(shù)類型的交換機，相較于 direct 和 topic 固定地使用 routing_key , headers 則是一個自定義匹配規(guī)則的類型. 在隊列與交換器綁定時, 會設定一組鍵值對規(guī)則, 消息中也包括一組鍵值對( headers 屬性), 當這些鍵值對有一對, 或全部匹配時, 消息被投送到對應隊列.

四、fanout Exchange----(消息廣播模式)

    轉發(fā)消息到所有綁定隊列，消息廣播的模式，不管路由鍵或者是路由模式，會把消息發(fā)給綁定給它的全部隊列，如果配置了routing_key會被忽略。(直接將消息路由到所有綁定的隊列中，無須對消息的routingkey進行匹配操作)。

圖片

案例：

/**
     * 功能描述:發(fā)送FanoutMessage消息
     * @MethodName: sendFanoutMessage
     * @MethodParam: [messageData]
     * @Return: void
     * @Author: yyalin
     * @CreateDate: 2022/4/9 17:46
     */
    public void sendFanoutMessage(String messageData){
        CorrelationData correlationData = new CorrelationData("1");
        rabbitTemplate.convertAndSend("fanoutExchange",
                "",messageData,correlationData);
    }

五、總結

     一般direct和topic用來具體的路由消費，若要用廣播的消息一般用fanout的exchange，header類型比較少。