DockerにRabbitMQを素早くインストールする方法

DockerにRabbitMQを素早くインストールする方法

1. 画像を取得する

#Webコントロールページを含むバージョンを指定します docker pull rabbitmq:management

2. イメージを実行する

#方法 1: デフォルトのゲストユーザー、パスワードも guest
docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq:management

#方法 2: ユーザー名とパスワードを設定する docker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password -p 15672:15672 -p 5672:5672 rabbitmq:management

3. UIページにアクセスする

http://localhost:15672/

4. Golangの場合

#producer プロデューサーコード パッケージ メイン

輸入 (
  「fmt」

  "ログ"

  「github.com/streadway/amqp」
)

定数(
  //AMQP URI

  uri = "amqp://guest:[email protected]:5672/" // 10.0.0.11 はホスト IP です

  //永続的な AMQP 交換名

  exchangeName = ""

  //永続的な AMQP キュー名

  queueName = "テストキュー"

  //メッセージの本文

  bodyMsg 文字列 = "こんにちは天使"
)

//エラーがある場合は出力します func failOnError(err error, msg string) {

  err != nil の場合 {

    log.Fatalf("%s: %s", メッセージ, エラー)

    パニック(fmt.Sprintf("%s: %s", msg, err))

  }

}

関数main() {

  //メッセージ公開関数を呼び出します publish(uri, exchangeName, queueName, bodyMsg)

  log.Printf("%dB を公開しました。OK", len(bodyMsg))

}

//パブリッシャーメソッド //@amqpURI、amqp アドレス //@exchange、exchange 名 //@queue、キュー名 //@body、本文コンテンツ func publish(amqpURI 文字列、exchange 文字列、queue 文字列、本文文字列) {

  //接続を確立 log.Printf("ダイヤル中 %q", amqpURI)

  接続、エラー:= amqp.Dial(amqpURI)

  failOnError(err, "RabbitMQへの接続に失敗しました")

  接続を延期する。Close()

  //チャンネルを作成する

  log.Printf("接続を取得しました。チャネルを取得しています")

  チャネル、エラー:= connection.Channel()

  failOnError(err, "チャネルを開けませんでした")

  チャネルを延期する。Close()

  log.Printf("キューを取得しました、%q を宣言しています", queue)

  //キューを作成する

  q, err := チャネル.QueueDeclare(

    queueName, // 名前

    false、// 耐久性あり

    false, // 未使用の場合は削除

    false, // 排他的

    false, // 待機なし

    nil, // 引数

  )

  failOnError(err, "キューの宣言に失敗しました")

  log.Printf("宣言されたキュー、%dB の body (%q) を公開", len(body), body)

  // プロデューサーはエクスチェンジに送信することしかできず、キューに直接送信することはできません // ここではデフォルトのエクスチェンジを使用します (名前は空文字です)。このデフォルトのエクスチェンジを使用すると、指定されたキューに送信できます。

  // routing_key は指定されたキュー名です err = channel.Publish(

    交換、// 交換

    q.Name, // ルーティングキー

    false, // 必須

    false, // 即時

    amqp.パブリッシング{

      ヘッダー: amqp.Table{},

      コンテンツタイプ: "text/plain",

      コンテンツエンコーディング: "",

      本文: []byte(body),
    })

  failOnError(err, "メッセージの公開に失敗しました")

}

5. 独自のメッセージ確認コード

#プロデューサー
パッケージメイン

輸入 (
  「fmt」
  「github.com/streadway/amqp」
  "ログ"
  「オス」
  「文字列」
)

定数(
  //AMQP URI
  uri = "amqp://guest:[email protected]:5672/"
  //永続的な AMQP 交換名
  exchangeName = ""
  //永続的な AMQP キュー名
  queueName = "テストキューの確認"
)

//エラーがある場合は出力します func failOnError(err error, msg string) {
  err != nil の場合 {
    log.Fatalf("%s: %s", メッセージ, エラー)
    パニック(fmt.Sprintf("%s: %s", msg, err))
  }
}

関数main() {
  bodyMsg := bodyFrom(os.Args)
  //メッセージ公開関数を呼び出します publish(uri, exchangeName, queueName, bodyMsg)
  log.Printf("%dB を公開しました。OK", len(bodyMsg))
}

func bodyFrom(args []string) 文字列 {
  var s 文字列
  len(args) < 2 の場合 || os.Args[1] == "" {
    s = "こんにちは天使"
  } それ以外 {
    s = 文字列.Join(args[1:], " ")
  }
  返品
}

//パブリッシャーメソッド //@amqpURI、amqp アドレス //@exchange、exchange 名 //@queue、キュー名 //@body、本文コンテンツ func publish(amqpURI 文字列、exchange 文字列、キュー文字列、本文文字列) {
  //接続を確立 log.Printf("ダイヤル中 %q", amqpURI)
  接続、エラー:= amqp.Dial(amqpURI)
  failOnError(err, "RabbitMQへの接続に失敗しました")
  接続を延期する。Close()

  //チャンネルを作成する
  log.Printf("接続を取得しました。チャネルを取得しています")
  チャネル、エラー:= connection.Channel()
  failOnError(err, "チャネルを開けませんでした")
  チャネルを延期する。Close()

  log.Printf("キューを取得しました、%q を宣言しています", queue)

  //キューを作成する
  q, err := チャネル.QueueDeclare(
    queueName, // 名前
    false、// 耐久性あり
    false, // 未使用の場合は削除
    false, // 排他的
    false, // 待機なし
    nil, // 引数
  )
  failOnError(err, "キューの宣言に失敗しました")

  log.Printf("宣言されたキュー、%dB の body (%q) を公開", len(body), body)

  // プロデューサーは Exchange にのみ送信でき、キューに直接送信することはできません。
  // 今のところ、デフォルトの交換 (名前として空の文字列) を使用します。このデフォルトの交換により、特定のキューに送信できるようになります。
  // routing_key は指定されたキュー名です。
  エラー = チャネル.公開(
    交換、// 交換
    q.Name, // ルーティングキー
    false, // 必須
    false, // 即時
    amqp.パブリッシング{
      ヘッダー: amqp.Table{},
      コンテンツタイプ: "text/plain",
      コンテンツエンコーディング: "",
      本文: []byte(body),
    })
  failOnError(err, "メッセージの公開に失敗しました")
}

これで、docker で rabbitmq を素早くインストールする手順に関するこの記事は終了です。docker で rabbitmq をインストールする方法の詳細については、123WORDPRESS.COM の以前の記事を検索するか、次の関連記事を引き続き参照してください。今後とも 123WORDPRESS.COM をよろしくお願いいたします。

以下もご興味があるかもしれません:
  • DockerでRabbitMqの共通クラスタとミラークラスタを構築する詳細な操作
  • Docker を使用した RabbitMQ 環境のデプロイの詳細な紹介
  • Dockerでrabbitmqをデプロイする際に発生した2つの問題
  • dockerでrabbitmqをインストールすると管理ページに入れなくなる問題
  • Docker デプロイメント RabbitMQ コンテナ実装プロセス分析
  • Dockerはrabbitmqのサンプルコードをインストールして実行します
  • Dockerでrabbitmqクラスタをデプロイする方法
  • Dockerでrabbitmqクラスタ環境を構築する方法
  • RabbitMQ の Docker インストールと設定手順

<<:  Mac ノードの削除と再インストールのケーススタディ

>>:  Linux環境にMySQLデータベースをインストールする詳細なチュートリアル

推薦する

高度な CSS の 3 つの方法を使用して複数行の省略を実装するサンプル コード

序文これは古くからの要望ですが、オンラインで解決策を探している人はまだ多く、特に検索結果の上位にラン...

React のネストされたコンポーネントの構築順序

目次Reactの公式サイトではライフサイクルの説明を見ることができます次に、ネストされたコンポーネン...

HTML テーブルタグについての簡単な説明

主にその構造といくつかの重要な特性について説明します。少しずつ改善しながら紹介していきます。 1) ...

ApacheとTomcatによるクラスタ環境構築プロセスの分析

実際、Apacheクラスタを構築するのは難しくありません。私もインターネットで情報を見つけて自分で設...

HTMLフォームのいくつかの送信方法の概要

最も一般的で、最もよく使用され、最も一般的な方法は、submit タイプを使用することです。コードを...

nginx を介してローカルでリバースプロキシを構成するプロセス全体

序文Nginx は、イベント駆動型の非同期非ブロッキング処理フレームワークを使用する軽量 HTTP ...

CSS3 のディスプレイのグリッドレイアウトとフレックスレイアウトの詳細な説明

Gird レイアウトは Flex レイアウトといくつかの類似点があり、どちらもコンテナーの内部項目を...

HTMLタグIDは変数にできる

<table id=" <%=var1%>">、var1...

MySQLの遅いクエリ問題の詳細な分析データ送信

例を通して、MySQL のデータ テーブル送信のクエリが遅い問題の解決策を共有しました。最近、コード...

MySQL で削除されたレコードが有効にならない理由のトラブルシューティング

オンライン MySQL トランザクションの問題の記録先週の金曜日、大きなテーブルを削除する操作を実行...

MySQL 5.7.11 zip インストールと設定方法のグラフィックチュートリアル

1. MySQL 5.7.11 zipインストールパッケージをダウンロードするこのマシンはwin7 ...

jwtを使用してノードによって生成されたトークンをどこに保存するかについての簡単な説明

A: 通常はクライアントに保存されます。 jwt または JSON Web Token は、リクエス...

MySQLからMariaDBへのスムーズな移行のための詳細な手順

1. MariaDB と MySQL の紹介1. MariaDB の紹介MariaDB は、MySQ...

CSS でショートカット プロパティを記述する際は、トラブルの順序に注意してください (落とし穴を避けるため)

ショートハンドプロパティは、複数のプロパティに同時に値を割り当てるために使用されます。たとえば、fo...