Spring RabbitMQ

キュー構成パラメータ

パラメータ名(めい)	説明(せつめい)	Java 構成例(こうせいれい)	ベストプラクティス
`durable`	キューの永続性(えいぞくせい) 。ディスクへの保存(ほぞん) を決定(けってい) します。	`new Queue("myQueue", true)`	実運用(じつうんよう) では `true` を推奨(すいしょう) します。
`exclusive`	排他性(はいたせい) 。作成(さくせい) した接続(せつぞく) のみに公開(こうかい) 。	`new Queue("myQueue", true, true, false)`	応答用(おうとうよう) の一時的なキューに使用(しよう) 。
`autoDelete`	自動削除(じどうさくじょ) 。最後(さいご) のコンシューマーが離脱後(りだつご) に削除(さくじょ) 。	`new Queue("myQueue", true, false, true)`	一時的(いちじてき) なキューは `true`。
`ignoreDeclarationExceptions`	宣言例外無視(せんげんれいがいむし) 。	`@RabbitListener(queuesToDeclare = @Queue(value = "q", ignoreDeclarationExceptions = "true"))`	インフラとの柔軟(じゅうなん) な接続用(せつぞくよう) 。
`x-queue-type`	キューのタイプ（`stream` や `classic`）。	`QueueBuilder.durable("q").withArgument("x-queue-type", "stream")`	大規模な読(よ) み取(と) りには `stream`。
`x-dead-letter-exchange`	デッドレター交換機(こうかんき) 。	`QueueBuilder.durable("q").withArgument("x-dead-letter-exchange", "dlx")`	エラー処理用(しょりよう) 。
`x-message-ttl`	メッセージの有効期限(ゆうこうきげん) 。	`QueueBuilder.durable("q").withArgument("x-message-ttl", 60000)`	メッセージの滞留回避(たいりゅうかいひ) 。

交換機構成パラメータ

パラメータ名(めい)	説明(せつめい)	Java 構成例(こうせいれい)	使用(しよう) シーン
`durable`	交換機(こうかんき) の永続性(えいぞくせい) 。	`new DirectExchange("ex", true, false)`	本番環境(ほんばんかんきょう) では `true`。
`autoDelete`	自動削除(じどうさくじょ) 。	`new DirectExchange("ex", true, true)`	一時的(いちじてき) な交換機(こうかんき) 。
`type`	タイプ：`direct`, `fanout`, `topic`, `headers`。	`new TopicExchange("myTopic")`	ルーティング要件(ようけん) に応(おう) じて。
`delayed`	遅延交換機(ちえんこうかんき) 。	`ExchangeBuilder.directExchange("ex").delayed().build()`	予約通知(よやくつうち) など。

RabbitListener 注釈パラメータ

パラメータ名(めい)	説明(せつめい)	Java 構成例(こうせいれい)
`queuesToDeclare`	必要(ひつよう) なキューの宣言(せんげん) 。	`@RabbitListener(queuesToDeclare = @Queue("name"))`
`bindings`	交換機(こうかんき) 、キュー、キーのバインディング。	`@RabbitListener(bindings = @QueueBinding(...))`
`ackMode`	確認(かくにん) モード。	`@RabbitListener(queues = "q", ackMode = "MANUAL")`
`concurrency`	並列実行数(へいれつじっこうすう) 。	`@RabbitListener(queues = "q", concurrency = "3-10")`

メッセージ保証レベル

レベル	説明(せつめい)	構成(こうせい) のポイント	使用(しよう) シーン
最大(さいだい) 1回(かい)	紛失(ふんしつ) の可能性(かのうせい) あり、重複(ちょうふく) なし。	`ackMode=NONE`	速度を優先(ゆうせん) 。
最低(さいてい) 1回(かい)	紛失(ふんしつ) なし、重複(ちょうふく) の可能性(かのうせい) あり。	`ackMode=AUTO` + 永続化(えいぞくか)	標準的(ひょうじゅんてき) な業務(ぎょうむ) 。
正確(せいかく) に1回(かい)	紛失(ふんしつ) も重複(ちょうふく) もなし。	冪等性処理(べきとうせいしょり) + 事務	金融決済(きんゆうけっさい) 。

実装

RabbitTemplate：メッセージの送受信(そうじゅうしん) に使用。
AmqpAdmin：キューや交換機(こうかんき) の管理(かんり) 。
MessageConverter：Java オブジェクトと JSON などの変換(へんかん) 。

図解

1対多

  flowchart LR
    EX[Exchange]
    B1((Binding<br/>rk1))
    B2((Binding<br/>rk2))
    Q1[Queue1]
    Q2[Queue2]

    EX --> B1 --> Q1
    EX --> B2 --> Q2

多対1

  flowchart LR
    EX1[Exchange1]
    EX2[Exchange2]
    B1((Binding))
    B2((Binding))
    Q1[Queue1]

    EX1 --> B1 --> Q1
    EX2 --> B2 --> Q1

Spring Scheduling