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

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

#方法 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

#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, "メッセージの公開に失敗しました")

}

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

輸入 （
  「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, "メッセージの公開に失敗しました")
}