2. 程式人生 > >Docker下RabbitMQ四部曲之一：極速體驗(單機和叢集)

Docker下RabbitMQ四部曲之一：極速體驗(單機和叢集)

阿新 • • 發佈：2019-02-19

從本章開始，我們一起在Docker環境實戰RabbitMQ環境部署和對應的Java開發，當前是《Docker下RabbitMQ四部曲》系列的第一篇，整個系列由以下四篇文章組成：
1. 第一篇，即本章，我們用最快的方式體驗RabbitMQ單機環境下生產和消費訊息，然後再體驗RabbitMQ叢集環境下生產和消費訊息；
2. 第二篇，詳細說明如何製作RabbitMQ的docker映象檔案，這個映象支援叢集，也能通過引數來配置記憶體節點、高可用等特性；
3. 第三篇，開發基於SpringBoot的web應用，實現生產和訊息RabbitMQ訊息的功能；
3. 第四篇，實戰高可用，叢集環境中有RabbitMQ宕機，驗證此時訊息的生產和消費是否正常；

環境資訊

本次實戰的環境資訊如下：
1. 作業系統：Ubuntu 16.04.3 LTS
2. docker版本：17.03.2-ce, build f5ec1e2
3. docker-compose版本：1.18.0, build 8dd22a9
4. RabbitMQ版本：3.7.5-rc.1
5. RabbitMQ環境的Erlang版本：19.3.6.5

本章概要

本章的實戰步驟簡述如下：
1. 部署單機版RabbitMQ、生產訊息的web應用、消費訊息的web應用；
2. 檢查RabbitMQ的基本情況、生產和消費訊息；
3. 部署叢集版RabbitMQ、生產訊息的web應用、消費訊息的web應用；
4. 檢查RabbitMQ的基本情況、生產和消費訊息；

部署單機版RabbitMQ

  1. 建立docker-compose.yml檔案，內容如下：
rabbitmq:
  image: bolingcavalry/rabbitmq-server:0.0.3
  hostname: rabbitmq
  ports:
    - "15672:15672"
  environment:
    - RABBITMQ_DEFAULT_USER=admin
    - RABBITMQ_DEFAULT_PASS=888888
producer:
  image: bolingcavalry/rabbitmqproducer:0.0.2-SNAPSHOT
  hostname: producer
  links:
    - rabbitmq:
 
rabbitmqhost
  ports:
      - "18080:8080"
  environment:
   - mq.rabbit.address=rabbitmqhost:5672
   - mq.rabbit.username=admin
   - mq.rabbit.password=888888
consumer:
  image: bolingcavalry/rabbitmqconsumer:0.0.5-SNAPSHOT
  hostname: consumer
  links:
    - rabbitmq:rabbitmqhost
  environment:
   - mq.rabbit.address=rabbitmqhost:5672
   - mq.rabbit.username=admin
   - mq.rabbit.password=888888
   - mq.rabbit.queue.name=consumer.queue


2. 在docker-compose.yml檔案所在目錄執行命令docker-compose up -d，即可下載映象並建立容器，下載過程比較耗時請耐心等待，容器一共三個：RabbitMQ、訊息生產者、訊息消費者；

3. 容器建立成功後，網路架構如下圖所示：
這裡寫圖片描述

4. 為了方便後續體驗，將三個容器資訊列表如下：

名稱 作用 IP地址
single_rabbitmq_1 RabbitMQ伺服器 172.17.0.2
single_producer_1 生產訊息的web應用 172.17.0.4
single_consumer_1 消費訊息的web應用 172.17.0.3

體驗單機版RabbitMQ

單機版的RabbitMQ環境已經部署完畢，接下來我們來體驗一番：
1. 假設執行docker的電腦IP地址為192.168.119.155；
2. 在瀏覽器輸入，這個請求會使single_producer_1容器向RabbitMQ傳送訊息，如下圖：
這裡寫圖片描述
3. 在docker機器上輸入命令docker logs -f single_consumer_1，可以看到容器的日誌，如下所示，receive message : hello, aaa, bbb就是容器從RabbitMQ收到的訊息：

2018-05-12 10:40:23.851  INFO 1 --- [cTaskExecutor-2] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [rabbitmqhost:5672]
2018-05-12 10:40:23.878  WARN 1 --- [172.17.0.2:5672] c.r.c.impl.ForgivingExceptionHandler     : An unexpected connection driver error occured (Exception message: Socket closed)
2018-05-12 10:40:28.890  INFO 1 --- [cTaskExecutor-2] o.s.a.r.l.SimpleMessageListenerContainer : Restarting Consumer@25023b5b: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0
2018-05-12 10:40:28.892  INFO 1 --- [cTaskExecutor-3] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [rabbitmqhost:5672]
2018-05-12 10:40:28.900  INFO 1 --- [cTaskExecutor-3] o.s.a.r.c.CachingConnectionFactory       : Created new connection: connectionFactory#29f69090:4/SimpleConnection@1fff76dd [delegate=amqp://[email protected]:5672/, localPort= 36948]
2018-05-12 11:40:57.048  INFO 1 --- [cTaskExecutor-3] c.b.r.receiver.FanoutReceiver            : receive message : hello, aaa, bbb, 2018-05-12 11:40:56


4. 在瀏覽器訪問，會開啟RabbitMQ的管理頁面，需要登入，如下圖，輸入使用者名稱admin，密碼888888：
這裡寫圖片描述

5. 登入成功後，點選“Connections”的Tab頁，如下圖，目前single_producer_1和single_consumer_1容器都連線到了RabbitMQ：
這裡寫圖片描述

6. 如下圖紅框所示，在“Exchanges”的Tab頁，可以看到一個fanout型的交換機，名為bolingcavalryFanoutExchange：
這裡寫圖片描述

7. 如下圖紅框所示，在“Queues”的Tab頁，可以看到一個佇列，名為consumer.queue：
這裡寫圖片描述

至此，單機版的RabbitMQ我們就體驗完畢了，接下來開始體驗叢集版的RabbitMQ；

清空單機版RabbitMQ的所有容器

在剛才建立的docker-compose.yml檔案所在目錄下執行命令docker-compose down，即可將剛才建立的三個容器徹底清除，如下所示：

root@maven:/usr/local/work/github/blog_demos/rabbitmq_docker_files/single# docker-compose down
Stopping single_producer_1 ... done
Stopping single_consumer_1 ... done
Stopping single_rabbitmq_1 ... done
Removing single_producer_1 ... done
Removing single_consumer_1 ... done
Removing single_rabbitmq_1 ... done

部署叢集版RabbitMQ

  1. 建立叢集版對應的docker-compose.yml檔案，內容如下：
version: '2'
services:
  rabbit1:
    image: bolingcavalry/rabbitmq-server:0.0.3
    hostname: rabbit1
    ports:
      - "15672:15672"
    environment:
      - RABBITMQ_DEFAULT_USER=admin
      - RABBITMQ_DEFAULT_PASS=888888
  rabbit2:
    image: bolingcavalry/rabbitmq-server:0.0.3
    hostname: rabbit2
    depends_on:
      - rabbit1
    links:
      - rabbit1
    environment:
     - CLUSTERED=true
     - CLUSTER_WITH=rabbit1
     - RAM_NODE=true
    ports:
      - "15673:15672"
  rabbit3:
    image: bolingcavalry/rabbitmq-server:0.0.3
    hostname: rabbit3
    depends_on:
      - rabbit2
    links:
      - rabbit1
      - rabbit2
    environment:
      - CLUSTERED=true
      - CLUSTER_WITH=rabbit1
    ports:
      - "15675:15672"
  producer:
    image: bolingcavalry/rabbitmqproducer:0.0.2-SNAPSHOT
    hostname: producer
    depends_on:
      - rabbit3
    links:
      - rabbit1:rabbitmqhost
    ports:
      - "18080:8080"
    environment:
      - mq.rabbit.address=rabbitmqhost:5672
      - mq.rabbit.username=admin
      - mq.rabbit.password=888888
  consumer1:
    image: bolingcavalry/rabbitmqconsumer:0.0.5-SNAPSHOT
    hostname: consumer1
    depends_on:
      - producer
    links:
      - rabbit2:rabbitmqhost
    environment:
     - mq.rabbit.address=rabbitmqhost:5672
     - mq.rabbit.username=admin
     - mq.rabbit.password=888888
     - mq.rabbit.queue.name=consumer1.queue
  consumer2:
    image: bolingcavalry/rabbitmqconsumer:0.0.5-SNAPSHOT
    hostname: consumer2
    depends_on:
      - consumer1
    links:
      - rabbit3:rabbitmqhost
    environment:
      - mq.rabbit.address=rabbitmqhost:5672
      - mq.rabbit.username=admin
      - mq.rabbit.password=888888
      - mq.rabbit.queue.name=consumer2.queue


2. 在docker-compose.yml檔案所在目錄執行命令docker-compose up -d，即可建立容器，容器一共六個：三個RabbitMQ、一個訊息生產者、兩個訊息消費者；
3. 容器建立成功後，網路架構如下圖所示：
這裡寫圖片描述

4. 為了方便後續體驗，將三個容器資訊列表如下：

名稱 作用 IP地址
cluster_rabbit1_1 一號RabbitMQ伺服器 172.17.0.2
cluster_rabbit2_1 二號RabbitMQ伺服器 172.17.0.3
cluster_rabbit3_1 三號RabbitMQ伺服器 172.17.0.6
cluster_producer_1 生產訊息的web應用 172.17.0.4
cluster_consumer1_1 一號消費訊息的web應用 172.17.0.5
cluster_consumer2_1 二號消費訊息的web應用 172.17.0.7

體驗叢集版RabbitMQ

叢集版的RabbitMQ環境已經部署完畢，我們來體驗一番：
1. 假設執行docker的電腦IP地址為192.168.119.155；
2. 在瀏覽器輸入，這個請求會使single_producer_1容器向RabbitMQ傳送訊息，如下圖：
這裡寫圖片描述

3. 在docker機器上輸入命令docker logs -f cluster_consumer1_1，可以看到容器cluster_consumer1_1的日誌，如下所示，receive message : hello, aaa, bbb就是容器從RabbitMQ收到的訊息：

2018-05-12 11:59:17.112  INFO 1 --- [cTaskExecutor-4] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [rabbitmqhost:5672]
2018-05-12 11:59:17.172  INFO 1 --- [cTaskExecutor-4] o.s.a.r.c.CachingConnectionFactory       : Created new connection: connectionFactory#55040f2f:6/SimpleConnection@723a07 [delegate=amqp://[email protected]:5672/, localPort= 48294]
2018-05-12 12:11:12.187  INFO 1 --- [cTaskExecutor-4] c.b.r.receiver.FanoutReceiver            : receive message : hello, aaa, bbb, 2018-05-12 12:11:12


4. 接下來看另一個消費訊息的容器，在docker機器上輸入命令docker logs -f cluster_consumer2_1，可以看到容器cluster_consumer2_1的日誌，如下所示，也受到一條訊息，這證明fanout模式的交換機中的訊息已成功被兩個消費者消費：

2018-05-12 11:59:12.199  INFO 1 --- [cTaskExecutor-3] o.s.a.r.c.CachingConnectionFactory       : Attempting to connect to: [rabbitmqhost:5672]
2018-05-12 11:59:12.263  INFO 1 --- [cTaskExecutor-3] o.s.a.r.c.CachingConnectionFactory       : Created new connection: connectionFactory#568bf312:4/SimpleConnection@11a59930 [delegate=amqp://[email protected]:5672/, localPort= 55972]
2018-05-12 12:11:12.187  INFO 1 --- [cTaskExecutor-3] c.b.r.receiver.FanoutReceiver            : receive message : hello, aaa, bbb, 2018-05-12 12:11:12


5. 在瀏覽器訪問，會開啟RabbitMQ的管理頁面，需要登入，如下圖，輸入使用者名稱admin，密碼888888：
這裡寫圖片描述

6. 登入成功後，在“Overview”的Tab頁，如下圖紅框所示，可見有三個RabbitMQ server，注意綠框中的資訊，一號和三號RabbitMQ都是磁碟型，二號RabbitMQ是記憶體型的：
這裡寫圖片描述

7. 點選“Connections”的Tab頁，如下圖，所有生產者和消費者容器都連線到了RabbitMQ：
這裡寫圖片描述
上圖中表格表明了以下連線關係：
生產者連線一號RabbitMQ、一號消費者連線二號RabbitMQ、二號消費者連線三號RabbitMQ；

8. 如下圖紅框所示，在“Exchanges”的Tab頁，可以看到一個fanout型的交換機，名為bolingcavalryFanoutExchange：
這裡寫圖片描述

9. 如下圖紅框所示，在“Queues”的Tab頁，可以看到兩個佇列，分別存在於二號RabbitMQ和三號RabbitMQ：
這裡寫圖片描述

至此，叢集版的RabbitMQ我們就體驗完畢了，本章旨在讓讀者您用最少的操作來完成整個體驗過程，接下來的文章中，我們會一起實戰這些簡單操作背後的技術細節；

相關推薦

Docker下RabbitMQ四部曲之一：極速體驗(單機和叢集)

從本章開始，我們一起在Docker環境實戰RabbitMQ環境部署和對應的Java開發，當前是《Docker下RabbitMQ四部曲》系列的第一篇，整個系列由以下四篇文章組成： 1. 第一篇，即本章，我們用最快的方式體驗RabbitMQ單機環境下生產和消費訊息

Docker下ELK三部曲之一：極速體驗

《Docker下ELK三部曲》一共三篇文章，為您揭示如何快速搭建ELK環境，以及如何將web應用的日誌上報到ELK用，三部曲內容簡述如下： 1. 極速體驗ELK服務，即本章的內容； 2. 細說技術詳情，例如集成了filebeat服務的映象如何製作，web應用

Docker下RabbitMQ延時佇列實戰兩部曲之一：極速體驗

有的應用場景中，向RabbitMQ發出訊息後，我們希望消費方不要立即消費，可以通過延時佇列來實現，思路是將訊息傳送到A佇列，此佇列沒有消費者，等訊息過期後會進入A佇列的Dead Letter Exchange中，B佇列綁定了這個Dead Letter Excha

Docker下實戰zabbix三部曲之一：極速體驗

對於想學習和實踐zabbix的讀者來說，在真實環境搭建一套zabbix系統是件費時費力的事情，本文內容就是用docker來縮減搭建時間，目標是讓讀者們儘快投入zabbix系統的體驗和實踐； 環境資訊 以下是本次操作的環境： 作業系統：MacBook Pro Docker：19.03.2 全系列文章連結： 三

Kubernetes持久卷實戰兩部曲之一：極速體驗

章節列表 整個《Kubernetes持久卷實戰》由以下兩篇文章組成： 1. 極速體驗靜態持久化儲存，也就是本章的內容； 2. 瞭解k8s的pod、service、pv、pvc的細節； 本章內容 本章目標是用最少的步驟和時間體驗PV，所以先不展開

docker下使用disconf：極速體驗

doc -c attribute http tex iss 如何 eight eas 前面的文章中我們實戰了docker下搭建disconf環境，現在我們學習如何使用disconf提供的動態配置服務，本章我們不深入研究，而是以最快的速度體驗一個Java做的demo，此de

Docker下RabbitMQ四部曲之二：細說RabbitMQ映象製作

本章是《Docker下RabbitMQ四部曲》系列的第二篇，將詳細簡述Docker下製作RabbitMQ映象的技術細節，包括以下內容： 1. 列舉製作RabbitMQ映象時用到的所有材料； 2. 編寫Dockerfile； 3. 編寫容器啟動時執行的指令碼

Docker下極速體驗Kafka

快速體驗Kafka Kafka是一種高吞吐量的分散式釋出訂閱訊息系統，從本章開始我們先極速體驗，再實戰docker下搭建kafka環境，最後開發一個java web應用來體驗kafka服務。 我們一起用最快的速度體驗kafka的訊息釋出訂閱功能： 新建一個

Docker下RabbitMQ延時佇列實戰兩部曲之二：細說開發

本章是《Docker下RabbitMQ延時佇列實戰兩部曲》的終篇，上一章《Docker下RabbitMQ延時佇列實戰兩部曲之一：極速體驗》我們快速體驗了延時佇列的生產和消費，今天來實戰整個開發過程； SpringBoot框架下進行RabbitMQ開發，相關

初識RabbitMQ系列之一：簡單介紹

核心概念 out queue producer 概念 images logs 紅色 .org 一：RabbitMQ是什麽？ 眾所周知，MQ是Message Queue（消息隊列）的意思，RabbitMQ就是眾多MQ框架其中的一款，開源實現了AMQP協議（官網：http:/

CentOS7環境安裝Kubernetes四部曲之一：標準化機器準備

通過Rancher安裝Kubernetes的文章前面已經寫過，但那時是需要科學上網才能安裝成功(下載gcr.io/google_containers/XXXXX的映象)，本次實戰依舊是用Rancher來安裝Kubernetes，但是會做一些設定，使得不用翻牆也能

極速體驗編譯openjdk8（docker環境）

本文不講解編譯openjdk8的過程，而是專注於用最少的步驟把openjdk8原始碼編譯構建成jdk。 進行本文的實踐有個前提：請讀者們先在電腦上安裝docker 總的來說整個過程只有六步，如下： 1. 指定映象建立一個容器，這個映象中已經把編譯所需的工具

RabbitMQ指南之一："Hello World!"

新建 指定 根據 依賴 只需要 工作 說明 配置 hello 　　為什麽要使用MQ消息中間件？它解決了什麽問題？關於為什麽要使用消息中間件？消息中間件是如何做到同步變異步、流量削鋒、應用解耦的？網上已經有很多說明，我這裏就不再說明了，讀者可以參考（https://www.j

Gin框架系列01：極速上手

## Gin是什麼？ Gin是Go語言編寫的web框架，具備中介軟體、崩潰處理、JSON驗證、內建渲染等多種功能。 ## 準備工作 本系列演示所有程式碼都在Github中，感興趣的同學可以自行查閱，歡迎大家一起完善。 ```shell https://github.com/pingyeaa/golan

Linux運維學習筆記之一：運維的原則和學習方法

linux 運維 筆記 一直在用Linux，但從未系統學習過，從1月1日開始學習到7月16日結束，近七個月學習，讓自已對Linux有了新的認識，老男孩老師的課真的不錯，實戰性很強。由於只能中午和晚上10點以後才有時間，所以所有的實驗是在不同電腦上完成的，文中IP可能有點問題，但應該不會影響實驗。同時，為了保證

[1月20號] 努比亞全機型ROM貼 最全最新NubiaUI5.0 ROOT 極速體驗

使用 高級 優化 ade 效果 作者 個性 com wlc 前言 感謝在開發過程中mandfx和dgtl198312予以的幫助！本帖將整理所有Nubia手機的最新刷機包，還有少數機型未制作刷機包，需要的機油可以聯系我制作recovery以及刷機包加群237227

libevent學習之一：libevent原始碼的特點和結構

1.特點 Libevent是一個用於開發可擴充套件性網路伺服器的基於事件驅動(event-driven)模型的網路庫。Libevent有幾個顯著的特點：  （1）事件驅動（event-driven），高效能； （2）輕量級，專注於網路，不如 ACE 那麼臃腫龐大；  （3）原始碼

Disruptor 極速體驗

已經不記得最早接觸到 Disruptor 是什麼時候了，只記得發現它的時候它是以具有閃電般的速度被介紹的。於是在腦子裡， Disruptor 和“閃電”一詞關聯了起來，然而卻一直沒有時間去探究一下。       最近正在進行一項對效能有很高要求的產品專案的研究，自然想起了閃

極速體驗:Oracle 18c 下載和Scalable Sequence新特性

Oracle 18c 已至，目前已經可以從Oracle Edelivery 網站下載。 該網站的

Qt總結之一：遍歷資料夾和檔案目錄，並過濾和獲取檔案資訊、字尾名、字首名（一）

一、採用遞迴和QDir實現資料夾下所有檔案遍歷的方法 #include <QDir> bool FindFile(const QString & path) {     QDir dir(path);   if (!dir.exists(