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 をよろしくお願いいたします。 以下もご興味があるかもしれません:
|
<<: Mac ノードの削除と再インストールのケーススタディ
>>: Linux環境にMySQLデータベースをインストールする詳細なチュートリアル
序文これは古くからの要望ですが、オンラインで解決策を探している人はまだ多く、特に検索結果の上位にラン...
目次Reactの公式サイトではライフサイクルの説明を見ることができます次に、ネストされたコンポーネン...
主にその構造といくつかの重要な特性について説明します。少しずつ改善しながら紹介していきます。 1) ...
実際、Apacheクラスタを構築するのは難しくありません。私もインターネットで情報を見つけて自分で設...
最も一般的で、最もよく使用され、最も一般的な方法は、submit タイプを使用することです。コードを...
序文Nginx は、イベント駆動型の非同期非ブロッキング処理フレームワークを使用する軽量 HTTP ...
Gird レイアウトは Flex レイアウトといくつかの類似点があり、どちらもコンテナーの内部項目を...
<table id=" <%=var1%>">、var1...
例を通して、MySQL のデータ テーブル送信のクエリが遅い問題の解決策を共有しました。最近、コード...
オンライン MySQL トランザクションの問題の記録先週の金曜日、大きなテーブルを削除する操作を実行...
1. MySQL 5.7.11 zipインストールパッケージをダウンロードするこのマシンはwin7 ...
A: 通常はクライアントに保存されます。 jwt または JSON Web Token は、リクエス...
1. MariaDB と MySQL の紹介1. MariaDB の紹介MariaDB は、MySQ...
効果確認アドレス:ツアープラン(uplanok.com) コード: img{幅: 100%;境界線の...
ショートハンドプロパティは、複数のプロパティに同時に値を割り当てるために使用されます。たとえば、fo...