在這裡以訂單服務為訊息生產者，程式碼中都有詳細的註釋和說明，以下是示例：

新增依賴
首先，建立一個web工程（在這裡我使用springboot2.0.2）。加入rabbitMQ所需要的依賴：

        <!-- rabbitmq依賴 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
同時，我也添加了一些常用依賴

                <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
 
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.2</version>
        </dependency>
配置RabbitMQ
然後，我們需要在專案中配置RabbitMQ

1、配置連線資訊
spring:
  rabbitmq:
    host: 116.85.38.99
    port: 5672
    username: xxxxx
    password: xxxxx
2、配置訊息交換機  exchange
新建一個配置類，配置一個訊息交換機

package com.space.rbq.order.config;
 
import org.springframework.amqp.core.DirectExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * 訊息交換機配置  可以配置多個
 * @author zhuzhe
 * @date 2018/5/25 15:40
 * @email

[email protected]
 */
@Configuration
public class ExchangeConfig {
 
    /** 訊息交換機1的名字*/
    public final String EXCHANGE_01 = "first_exchange";
 
    /**
     *   1.定義direct exchange，繫結first_exchange
     *   2.durable="true" 持久化交換機， rabbitmq重啟的時候不需要建立新的交換機
     *   3.direct交換器相對來說比較簡單，匹配規則為：如果路由鍵匹配，訊息就被投送到相關的佇列
     *     fanout交換器中沒有路由鍵的概念，他會把訊息傳送到所有繫結在此交換器上面的佇列中。
     *     topic交換器你採用模糊匹配路由鍵的原則進行轉發訊息到佇列中
     */
    @Bean
    public DirectExchange directExchange(){
        DirectExchange directExchange = new DirectExchange(EXCHANGE_01,true,false);
        return directExchange;
    }
}
3、配置佇列  queue
注：在這裡，我們只使用到第一個佇列  FirstQueue

package com.space.rbq.order.config;
 
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
import java.util.HashMap;
import java.util.Map;
 
/**
 * 佇列配置  可以配置多個佇列
 * @author zhuzhe
 * @date 2018/5/25 13:25
 * @email [email protected]
 */
@Configuration
public class QueueConfig {
 
    /*對列名稱*/
    public static final String QUEUE_NAME1 = "first-queue";
    public static final String QUEUE_NAME2 = "second-queue";
    public static final String QUEUE_NAME3 = "third-queue";
 
    @Bean
    public Queue firstQueue() {
        /**
         durable="true" 持久化訊息佇列 ， rabbitmq重啟的時候不需要建立新的佇列
         auto-delete 表示訊息佇列沒有在使用時將被自動刪除 預設是false
         exclusive  表示該訊息佇列是否只在當前connection生效,預設是false
         */
        return new Queue(QUEUE_NAME1,true,false,false);
    }
 
    @Bean
    public Queue secondQueue() {
        return new Queue(QUEUE_NAME2,true,false,false);
    }
 
    @Bean
    public Queue thirdQueue() {
        // 配置 自動刪除
        Map<String, Object> arguments = new HashMap<>();
        arguments.put("x-message-ttl", 60000);//60秒自動刪除
        return new Queue(QUEUE_NAME3,true,false,true,arguments);
    }
}
4、將交換機和佇列進行繫結
新建一個RabbitMQConfig配置類，將交換機和佇列繫結

package com.space.rbq.order.config;
 
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * RabbitMq配置
 * @author zhuzhe
 * @date 2018/5/25 13:37
 * @email [email protected]
 */
@Configuration
public class RabbitMqConfig {
 
    /**
     * key: queue在該direct-exchange中的key值，當訊息傳送給direct-exchange中指定key為設定值時，
     * 訊息將會轉發給queue引數指定的訊息佇列
     */
    /** 佇列key1*/
    public static final String ROUTING_KEY_1 = "queue_one_key1";
 
    @Autowired
    private QueueConfig queueConfig;
 
    @Autowired
    private ExchangeConfig exchangeConfig;
 
    /**
     * 將訊息佇列1和交換機1進行繫結,指定佇列key1
     */
    @Bean
    public Binding binding_one() {
        return BindingBuilder.bind(queueConfig.firstQueue()).to(exchangeConfig.directExchange()).with(RabbitMqConfig.ROUTING_KEY_1);
    }
}
這樣，我們就完成了RabbitMq的配置，並且成功建立了訊息交換機和佇列，將其進行繫結。

傳送訊息
新建一個Order類，模擬訂單。同時新建一個OrderController，用於傳送訊息。

package com.space.rbq.order.bean;
import lombok.Data;
import java.io.Serializable;
 
/**
 * Order
 * @author zhuzhe
 * @date 2018/6/7 9:49
 * @email [email protected]
 */
@Data
public class Order implements Serializable{
 
    private Long id;
 
    private Double price;
 
    private String remark;
}
package com.space.rbq.order.controller;
 
import com.google.gson.Gson;
import com.space.rbq.order.bean.Order;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.support.CorrelationData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
 
import java.util.UUID;
 
/**
 * @author zhuzhe
 * @date 2018/6/7 9:48
 * @email [email protected]
 */
@Slf4j
@RequestMapping("/order")
@RestController
public class OrderController {
 
    @Autowired
    private RabbitTemplate rabbitTemplate;
 
    /**
     * 儲存order , 同時需要向store服務傳送通知減庫存
     * @param order
     * @return
     */
    @PostMapping("/save")
    public Order saveOrder(Order order){
        log.info(order.toString());
        Gson gson = new Gson();
        //將order轉換為json字串，便於傳輸
        String json = gson.toJson(order);
        String msgId = UUID.randomUUID().toString();
        /**
         * 傳送訊息
         * 指定訊息交換機  "first_exchange"
         * 指定佇列key    "queue_one_key1"
         */
        rabbitTemplate.convertAndSend("first_exchange", "queue_one_key1",
                json, new CorrelationData(msgId));
        return order;
    }
}
RabbitTemplate是springboot整合rabbitMq為我們預設提供的。裡面有一些預設的配置和方法，我們可以直接使用它來發送訊息。我們可以大概看看

呼叫convertAndSend方法就可以傳送訊息。在這裡需要指定訊息交換機和key。這樣就可以將訊息傳送給指定的隊列了（佇列和交換機通過key在之前已經繫結過了）

此時，我們只需要啟動工程，呼叫saveOrder介面，就可以成功將訊息傳送出去。

至此，就成功實現了訊息的傳送。下節，我們會通過庫存服務訂閱該訊息，實現訊息的消費。
--------------------- 
作者：朱_哲 
來源：CSDN 
原文：https://blog.csdn.net/zhuzhezhuzhe1/article/details/80704136 
版權宣告：本文為博主原創文章，轉載請附上博文連結！