メッセージの蓄積
メッセージ蓄積の生成シナリオ:
プロデューサによって生成されるメッセージの速度は、消費者の消費速度よりも高速です。解決策: コンシューマーの数または速度を増やします。
消費者がいない場合。解決策: デッドレターキュー、メッセージの有効期間を設定します。これは、メッセージに有効期間を設定するのと同じです。指定された時間内に消費がない場合、メッセージは自動的に期限切れになります。期限が切れると、クライアント コールバック監視メソッドが実行され、メッセージがデータベース テーブル レコードに保存されます。補償は後から実現します。
メッセージが失われないようにする
1. プロデューサは、メッセージ確認メカニズムを使用して、メッセージが MQ に正常に配信されることを確認します。 2. MQ サーバーはメッセージをハードディスクに保存する必要があります3. コンシューマは手動 ACK メカニズムを使用して、メッセージの消費が成功したことを確認します何をすべきかMQ サーバーの容量がいっぱいの場合はどうしますか? デッドレター キューを使用してメッセージをデータベースに保存し、後で消費された分を補います。 デッドレター キューRabbitMQ デッドレター キューは一般にスペア タイヤ キューとして知られており、メッセージ ミドルウェアが何らかの理由でメッセージを拒否した後、保管のためにメッセージをデッドレター キューに転送できます。 、デッドレターキュー スイッチやルーティングキーなども存在する可能性があります。 生成の背景:- MQ に配信され、MQ に保存されたメッセージの有効期限が切れました
- キューが最大値に達しました長さ (キュー コンテナがすでにいっぱいです) プロデューサーはメッセージの受信を拒否します
- コンシューマーが複数のメッセージを消費できなかった場合、メッセージはデッド レター キューに転送されます
<dependencies>
<!-- springboot-web组件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 添加springboot对amqp的支持 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>
<!--fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.49</version>
</dependency>
</dependencies>yml 構成server:
# 服务启动端口配置
port: 8081
servlet:
# 应用访问路径
context-path: /
spring:
#增加application.druid.yml 的配置文件
# profiles:
# active: rabbitmq
rabbitmq:
####连接地址
host: www.kaicostudy.com
####端口号
port: 5672
####账号
username: kaico
####密码
password: kaico
### 地址
virtual-host: /kaicoStudy
###模拟演示死信队列
kaico:
dlx:
exchange: kaico_order_dlx_exchange
queue: kaico_order_dlx_queue
routingKey: kaico.order.dlx
###备胎交换机
order:
exchange: kaico_order_exchange
queue: kaico_order_queue
routingKey: kaico.orderキュー構成クラス@Configuration
public class DeadLetterMQConfig {
/**
* 订单交换机
*/
@Value("${kaico.order.exchange}")
private String orderExchange;
/**
* 订单队列
*/
@Value("${kaico.order.queue}")
private String orderQueue;
/**
* 订单路由key
*/
@Value("${kaico.order.routingKey}")
private String orderRoutingKey;
/**
* 死信交换机
*/
@Value("${kaico.dlx.exchange}")
private String dlxExchange;
/**
* 死信队列
*/
@Value("${kaico.dlx.queue}")
private String dlxQueue;
/**
* 死信路由
*/
@Value("${kaico.dlx.routingKey}")
private String dlxRoutingKey;
/**
* 声明死信交换机
*
* @return DirectExchange
*/
@Bean
public DirectExchange dlxExchange() {
return new DirectExchange(dlxExchange);
}
/**
* 声明死信队列
*
* @return Queue
*/
@Bean
public Queue dlxQueue() {
return new Queue(dlxQueue);
}
/**
* 声明订单业务交换机
*
* @return DirectExchange
*/
@Bean
public DirectExchange orderExchange() {
return new DirectExchange(orderExchange);
}
/**
* 绑定死信队列到死信交换机
*
* @return Binding
*/
@Bean
public Binding binding() {
return BindingBuilder.bind(dlxQueue())
.to(dlxExchange())
.with(dlxRoutingKey);
}
/**
* 声明订单队列，并且绑定死信队列
*
* @return Queue
*/
@Bean
public Queue orderQueue() {
// 订单队列绑定我们的死信交换机
Map<String, Object> arguments = new HashMap<>(2);
arguments.put("x-dead-letter-exchange", dlxExchange);
arguments.put("x-dead-letter-routing-key", dlxRoutingKey);
return new Queue(orderQueue, true, false, false, arguments);
}
/**
* 绑定订单队列到订单交换机
*
* @return Binding
*/
@Bean
public Binding orderBinding() {
return BindingBuilder.bind(orderQueue())
.to(orderExchange())
.with(orderRoutingKey);
}
}デッドレターキューコンシューマー
@Component
public class OrderDlxConsumer {
/**
* 死信队列监听队列回调的方法
* @param msg
*/
@RabbitListener(queues = "kaico_order_dlx_queue")
public void orderDlxConsumer(String msg) {
System.out.println("死信队列消费订单消息" + msg);
}
}通常のキュー コンシューマ @Component
public class OrderConsumer {
/**
* 监听队列回调的方法
*
* @param msg
*/
@RabbitListener(queues = "kaico_order_queue")
public void orderConsumer(String msg) {
System.out.println("正常订单消费者消息msg:" + msg);
}
}バックグラウンド キュー管理ページは次のとおりです。 
acknowledge-mode: Manual第 2 ステップ、コンシューマー Java コード
int result = orderMapper.addOrder(orderEntity);
if (result >= 0) {
// 开启消息确认机制
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
}
rabbitMQ はメッセージ冪等性の問題をどのように解決するかメッセージ冪等性とは何ですか? MQ コンシューマはどのように冪等性を確保しますか? ###理由: コンシューマが自動再試行をオンにする可能性があり、再試行プロセスによってコンシューマのビジネス ロジック コードが繰り返し実行される可能性があります。現時点では、メッセージは消費されています。ビジネス エラーによりメッセージが再び消費されるため、
解決策が表示されます: メッセージ グローバル ID を使用して、ビジネスに従って決定します。コンシューマはこれを判断できます。ビジネス ID (グローバル固有 ID) に基づくメッセージ。メッセージは消費されました。
コンシューマ コード ロジック:
- ##確認プロデューサー メッセージは MQ (メッセージ確認メカニズム) に配信される必要があります。配信が失敗した場合は、再試行を続けてください。
- コンシューマーは手動確認を使用してメッセージを確認し、消費を達成します冪等性の問題に注意してください。消費が失敗すると、mq は自動的に消費者の再試行を支援します。
- プロデューサの最初のトランザクションが最初に実行されることを確認します。実行が失敗した場合は、補足キューを使用します (プロデューサ自身のトランザクションを補足して、プロデューサの最初のトランザクションが確実に実行されるようにします [データは最終的に一貫した]セックス])。
- 解決策マップ: 中心となるのは、mq を使用して他のシステムにメッセージを送信し、データを変更して戻すことです。
以上がJava RabbitMQメッセージキューの一般的な問題と解決策の分析の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
声明
この記事は亿速云で複製されています。侵害がある場合は、admin@php.cn までご連絡ください。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
R.E.P.O.説明されたエネルギー結晶と彼らが何をするか（黄色のクリスタル）
1 か月前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最高のグラフィック設定
1 か月前By尊渡假赌尊渡假赌尊渡假赌
アサシンのクリードシャドウズ：シーシェルリドルソリューション
3週間前ByDDD
Will R.E.P.O.クロスプレイがありますか？
1 か月前By尊渡假赌尊渡假赌尊渡假赌
ホットツール
SublimeText3 Linux 新バージョン
SublimeText3 Linux 最新バージョン
EditPlus 中国語クラック版
サイズが小さく、構文の強調表示、コード プロンプト機能はサポートされていません
PhpStorm Mac バージョン
最新(2018.2.1)のプロフェッショナル向けPHP統合開発ツール
MinGW - Minimalist GNU for Windows
このプロジェクトは osdn.net/projects/mingw に移行中です。引き続きそこでフォローしていただけます。 MinGW: GNU Compiler Collection (GCC) のネイティブ Windows ポートであり、ネイティブ Windows アプリケーションを構築するための自由に配布可能なインポート ライブラリとヘッダー ファイルであり、C99 機能をサポートする MSVC ランタイムの拡張機能が含まれています。すべての MinGW ソフトウェアは 64 ビット Windows プラットフォームで実行できます。
ZendStudio 13.5.1 Mac
強力な PHP 統合開発環境
