寫在前面：本文采用rabbitmq環境是docker單節點。
專案地址：https://github.com/Blankwhiter/AMQP

一、搭建rabbitmq環境

在centos視窗中，執行如下命令拉取映象，以及建立容器：

docker pull rabbitmq:3.7-management
docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq-single rabbitmq:3.7-management

注：5672 -> 客戶端與rabbitmq的通訊埠 15672 -> 圖形化管理介面埠

建立容器後，在瀏覽器輸入http://192.168.10.170:15672

注：192.168.10.170是虛擬機器ip ，預設的username/password為guest/guest

二、springboot整合rabbitmq

1.template操作rabbitmq 收發訊息。

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 

         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example</groupId>
    <artifactId>template</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <
 
packaging>jar</packaging>

    <name>template</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--引入序列化
         由於本次測試沒有引入spring-boot-starter-web模組，故引入jackson-databind
           <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
           </dependency>

       -->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.9.6</version>
            <scope>compile</scope>
        </dependency>
         <!--引入amqp-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>


    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

application.yml

spring:
  rabbitmq:
    host: 192.168.9.219
    port: 5672
    username: guest
    password: guest

AmqpConfig.java

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AmqpConfig {

    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    }
}

測試類，讀者請按照步驟依次執行

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Arrays;
import java.util.HashMap;

@RunWith(SpringRunner.class)
@SpringBootTest
public class TemplateApplicationTests {

    /**
     * rabbitmq 給rabbitmq 收發訊息
     */
    @Autowired
    RabbitTemplate rabbitTemplate;

    /**
     * amqpTemplate 給amqp中介軟體 收發訊息， 推薦使用
     */
    @Autowired
    AmqpTemplate amqpTemplate;

    /**
     * 交換器、佇列管理
     * amqp系統管理功能元件
     */
    @Autowired
    AmqpAdmin amqpAdmin;

    /**
     * 第一步：
     * 使用amqpAdmin初始化。建立交換器，佇列，以及交換器繫結佇列
     * 執行完成。訪問  http://192.168.9.219:15672/#/exchanges/%2F/exchange.direct 可以檢視具體資訊
     */
    @Test
    public void init() {
        /**
         * exchange 型別主要分DirectExchange FanoutExchange TopicExchange HeadersExchange
         * 具體區別更多詳情請檢視 https://blog.csdn.net/belonghuang157405/article/details/83184388 關於amqp相關內容
         */

        //建立交換器 點對點模式
        amqpAdmin.declareExchange(new DirectExchange("exchange.direct"));
        //建立佇列 queue第二個引數：是否持久化
        amqpAdmin.declareQueue(new Queue("direct-queue",true));
        //交換器繫結佇列
        amqpAdmin.declareBinding(new Binding("direct-queue", Binding.DestinationType.QUEUE,"exchange.direct","fruit.apple",null));

    }


    /**
     * 第二步：
     * 傳送訊息
     */
    @Test
    public void sendMessage(){

        //第一種.使用send 需要自己構造一個Message，定義訊息內容以及訊息頭
        //rabbitTemplate.send("exchange.direct","fruit.apple",new Message("apple-message-made".getBytes(),null));

        //第二種.使用convertAndSend  第三個引數object預設當初訊息體，自動序列化傳送給rabbitmq
        HashMap<Object, Object> map = new HashMap<>();
        map.put("type","red apple");
        map.put("data", Arrays.asList(1,2,3));
        // convertAndSend 使用的轉換器是SimpleMessageConverter 會採用jdk序列方式，
        // 但往往大多數會想使用json方式，故多編寫一個配置類:AmqpConfig
        // 這時候再去http://192.168.9.219:15672/#/queues/%2F/direct-queue介面上Get messages時候檢視訊息就是json格式
        rabbitTemplate.convertAndSend("exchange.direct","fruit.apple",map);

    }

    /**
     * 第三步：
     * 接收訊息
     */
    @Test
    public void receiveMessage(){

        Object message = rabbitTemplate.receiveAndConvert("direct-queue");
        System.out.println(message.getClass());
        System.out.println(message.toString());

    }

}

2.使用@RabbitListene註解，監聽訊息

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example</groupId>
    <artifactId>annotation</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>annotation</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.6.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--引入amqp-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

application.yml

spring:
  rabbitmq:
    host: 192.168.9.219
    port: 5672
    username: guest
    password: guest

AmqpConfig.java

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AmqpConfig {

    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    }
}

測試類，讀者請按照步驟依次執行

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.amqp.core.*;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Arrays;
import java.util.HashMap;

@RunWith(SpringRunner.class)
@SpringBootTest
public class AnnotationApplicationTests {

    /**
     * rabbitmq 給rabbitmq 收發訊息
     */
    @Autowired
    RabbitTemplate rabbitTemplate;

    /**
     * amqpTemplate 給amqp中介軟體 收發訊息， 推薦使用
     */
    @Autowired
    AmqpTemplate amqpTemplate;

    /**
     * 交換器、佇列管理
     * amqp系統管理功能元件
     */
    @Autowired
    AmqpAdmin amqpAdmin;

    /**
     * 第一步：
     * 使用amqpAdmin初始化。建立交換器，佇列，以及交換器繫結佇列
     * 執行完成。訪問 http://192.168.9.219:15672/#/exchanges/%2F/exchange.fanout 可以檢視具體資訊
     */
    @Test
    public void init() {
        /**
         * exchange 型別主要分DirectExchange FanoutExchange TopicExchange HeadersExchange
         * 具體區別更多詳情請檢視 https://blog.csdn.net/belonghuang157405/article/details/83184388 關於amqp相關內容
         */

        //建立交換器 廣播模式
        amqpAdmin.declareExchange(new FanoutExchange("exchange.fanout"));
        //建立佇列 queue第二個引數：是否持久化
        amqpAdmin.declareQueue(new Queue("fanout-queue1",true));
        amqpAdmin.declareQueue(new Queue("fanout-queue2",true));
        amqpAdmin.declareQueue(new Queue("fanout-queue3",true));
        //交換器繫結佇列
        amqpAdmin.declareBinding(new Binding("fanout-queue1", Binding.DestinationType.QUEUE,"exchange.fanout","fruit.orange-1",null));
        amqpAdmin.declareBinding(new Binding("fanout-queue2", Binding.DestinationType.QUEUE,"exchange.fanout","fruit.orange-2",null));
        amqpAdmin.declareBinding(new Binding("fanout-queue3", Binding.DestinationType.QUEUE,"exchange.fanout","fruit.orange-3",null));

    }

    /**
     * 第二步：
     * 傳送訊息
     */
    @Test
    public void sendMessage(){

        //第一種.使用send 需要自己構造一個Message，定義訊息內容以及訊息頭
        //rabbitTemplate.send("exchange.fanout","fruit.apple",new Message("apple-message-made".getBytes(),null));

        //第二種.使用convertAndSend  第三個引數object預設當初訊息體，自動序列化傳送給rabbitmq
        HashMap<Object, Object> map = new HashMap<>();
        map.put("type","red orange");
        map.put("data", Arrays.asList(1,2,3));
        // convertAndSend 使用的轉換器是SimpleMessageConverter 會採用jdk序列方式，
        // 但往往大多數會想使用json方式，故多編寫一個配置類:AmqpConfig
        // 這時候再去http://192.168.9.219:15672/#/queues/%2F/fanout-queueX介面上Get messages時候檢視訊息就是json格式
        rabbitTemplate.convertAndSend("exchange.fanout","",map);

    }

}

按照步驟執行完上述程式碼，編寫MessageService類，並啟動專案。
MessageService.java

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

import java.util.HashMap;

@Service
public class MessageService {

    @RabbitListener(queues = "fanout-queue1")
    public void receiveQueue1Message(HashMap<String,Object> map){
        System.out.println("fanout-queue1 begin");
        Object  message = map.getOrDefault("data", "no message");
        System.out.println(message.toString());
        System.out.println("fanout-queue1 end");
    }

    @RabbitListener(queues = "fanout-queue2")
    public void receiveQueue2Message(HashMap<String,Object> map){
        System.out.println("fanout-queue2 begin");
        Object  message = map.getOrDefault("data", "no message");
        System.out.println(message.toString());
        System.out.println("fanout-queue2 end");
    }

    @RabbitListener(queues = "fanout-queue3")
    public void receiveQueue3Message(HashMap<String,Object> map){
        System.out.println("fanout-queue3 begin");
        Object  message = map.getOrDefault("data", "no message");
        System.out.println(message.toString());
        System.out.println("fanout-queue3 end");
    }


}

 
 

            
  
           

              
              
            
            
相關推薦
			   
            
            
            
 

    

    
    
springboot簡易整合rabbitmq
     
  
  
  
 寫在前面：本文采用rabbitmq環境是docker單節點。 專案地址：https://github.com/Blankwhiter/AMQP 
 一、搭建rabbitmq環境 
 在centos視窗中，執行如下命令拉取映象，以及建立容器： 
 docker pull rabbitmq:3. 

  
 

    

    
    
springboot簡易整合ElasticSearch
     
  
  
  
 寫在前面：本文將搭建的ElasticSearch環境採用單機單節點方式，如果讀者想採用叢集方式請移步至https://blog.csdn.net/belonghuang157405/article/details/83301937 
 Elasticsearch: 權威指南 : https: 

  
 

    

    
    
springboot 簡單整合rabbitmq
     
 
                pom檔案新增：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp< 

  
 

    

    
    
SpringBoot學習（六）—— springboot快速整合RabbitMQ
     
 
    目錄
    
        
        Rabbit MQ訊息佇列
        簡介
        Rabbit MQ工作模式
        交換機模式
        引入RabbitMQ佇列
        程式碼實戰
        
        
    

Rabbi 

  
 

    

    
    
【SpringBoot系列5】SpringBoot整合RabbitMQ
     
 urn   項目   div   fin   交換   ng-   eat   convert   sta   前言：
因為項目需要用到RabbitMQ，前幾天就看了看RabbitMQ的知識，記錄下SpringBoot整合RabbitMQ的過程。
給出兩個網址：
RabbitMQ官方教程：http:// 

  
 

    

    
    
SpringBoot整合RabbitMq
     
 tostring   易用性   toc   分布   code   prior   temp   模式匹配   推薦   1,該筆記主要是記錄自己學習Springboot整合RabbitMq過程，推薦一篇學習RabbitMq非常好的博客：http://blog.720ui.com/2017/rabbitmq 

  
 

    

    
    
SpringBoot整合RabbitMQ之發送接收消息實戰
     
 container   會同   prope   spring   註解   流行   pin   public   lin   實戰前言 前幾篇文章中，我們介紹了SpringBoot整合RabbitMQ的配置以及實戰了Spring的事件驅動模型，這兩篇文章對於我們後續實戰RabbitMQ其他知識要點將起到奠 

  
 

    

    
    
SpringBoot整合RabbitMQ之典型應用場景實戰二
     
 factor   aid   分享圖片   actor   esp   rem   排隊   stc   tps   實戰前言RabbitMQ 作為目前應用相當廣泛的消息中間件，在企業級應用、微服務應用中充當著重要的角色。特別是在一些典型的應用場景以及業務模塊中具有重要的作用，比如業務服務模塊解耦、異步通信、 

  
 

    

    
    
SpringBoot整合RabbitMQ之典型應用場景實戰三
     
 分布   boot   自動刪除   blog   jce   地址   這樣的   實施   微服務   實戰前言RabbitMQ 作為目前應用相當廣泛的消息中間件，在企業級應用、微服務應用中充當著重要的角色。特別是在一些典型的應用場景以及業務模塊中具有重要的作用，比如業務服務模塊解耦、異步通信、高並發限流 

  
 

    

    
    
企業級 SpringBoot 教程 （十五）Springboot整合RabbitMQ
     
 vmware   builder   ring   boot   ()   清單   mil   throws   www   這篇文章帶你了解怎麽整合RabbitMQ服務器，並且通過它怎麽去發送和接收消息。我將構建一個springboot工程，通過RabbitTemplate去通過MessageListen 

  
 

    

    
    
【Spring Boot】（30）、SpringBoot整合RabbitMQ
     
  
 
 
 1、安裝 
 1.1、Erlang： 
 Erlang下載地址，下載後安裝即可。 
 1.2、RabbitMQ安裝 
 RabbitMQ下載地址，下載後安裝即可。 
 注意：Erlang的版本要與RabbitMQ版本需要匹配才行。 
 
  
   
    RabbitMQ 
    Mini 

  
 

    

    
    
springboot整合rabbitMQ的使用
     
  
 
 RabbitMQ介紹 
 RabbitMQ是一個開源的AMQP實現，伺服器端用Erlang語言編寫，支援多種客戶端，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等，支援AJAX。用於在分散式系統中儲存轉發訊息，在易用性、擴充套件性 

  
 

    

    
    
SpringBoot整合RabbitMQ之 典型應用場景實戰二
     
  
 
 
 實戰前言 
 RabbitMQ 作為目前應用相當廣泛的訊息中介軟體，在企業級應用、微服務應用中充當著重要的角色。特別是在一些典型的應用場景以及業務模組中具有重要的作用，比如業務服務模組解耦、非同步通訊、高併發限流、超時業務、資料延遲處理等。上一篇博文我分享了RabbitMQ在業務服務模組解耦，非 

  
 

    

    
    
SpringBoot整合RabbitMQ之 典型應用場景實戰一
     
  
 
 
 實戰前言 
 RabbitMQ 作為目前應用相當廣泛的訊息中介軟體，在企業級應用、微服務應用中充當著重要的角色。特別是在一些典型的應用場景以及業務模組中具有重要的作用，比如業務服務模組解耦、非同步通訊、高併發限流、超時業務、資料延遲處理等。 
 RabbitMQ 官網拜讀 
 首先，讓我們先拜讀 

  
 

    

    
    
SpringBoot整合RabbitMQ之Spring事件驅動模型
     
  
 
 
 實戰背景：在進入RabbitMQ各大技術知識點之前，我們先來談談跟事件驅動息息相關的ApplicationEvent、ApplicationListener以及ApplicationEventPublisher這三大元件，點選進去看其原始碼可以發現裡面使用的CachingConnectionFa 

  
 

    

    
    
SpringBoot整合RabbitMQ之整合配置篇
     
  
 
 
 實戰背景：RabbitMQ實戰第一階段-RabbitMQ的官網拜讀已經結束了，相信諸位童鞋或多或少都能入了個門，如果還是覺得迷迷糊糊似懂非懂的，那我建議諸位可以親自去拜讀拜讀官網的技術手冊或者看多幾篇我的視訊跟原始碼！因為接下來我們將進入第二階段，即應用實戰階段。其中，第一階段的內容因為屬於入門 

  
 

    

    
    
SpringBoot學習筆記05——SpringBoot整合RabbitMQ（下）
     
  
 
 下面我們來學習一下rabbitMQ消費者配置，話不多說直接上程式碼。 
 1.向application.properties檔案中新增配置 
 #rabbitMQ的 5672 埠
spring.rabbitmq.addresses=192.168.31.199:32771
#使用者名稱密碼
spri 

  
 

    

    
    
SpringBoot學習筆記04——SpringBoot整合RabbitMQ（上）
     
  
 
 首先需要搭建一個RabbitMQ的服務，我是在docker跑了一個rabbitMQ的服務， 
 docker的命令語句  
 docker run --name rabbit -P -d rabbitmq:3-management 
 映射出來的埠號如下圖 
  
 rabbitMQ這裡我 

  
 

    

    
    
SpringBoot整合RabbitMQ解耦合
     
  
  
  
 RabbitMQ的訊息接收者程式往往需要操作業務資料，如何將收發訊息的工具類與業務系統解耦合，提供訊息工具類的應用範圍是一個需要解決的問題，本例中新增一層介面，參考下圖：  
 同步訊息 
 SyncSendMsg 
 package com.test.util;

import java. 

  
 

    

    
    
SpringBoot整合RabbitMQ之基礎例項2
     
  
 
  
  
 此文承接SpringBoot整合RabbitMQ之基礎例項1的所有配置 
 配置交換機，佇列及繫結關係 
 package com.etoak.crazy.config.rabbitmq;

import org.springframework.amqp.core.Binding;
im