Thread.interrupt() cause message loss and hang for ChannelRpcTimeout(default 10mins) or forever
メンテナーはふだん 1 日以内に返信
まだ誰も着手していません。
評価
- 難易度
- 4/5
- 見積もり時間
- 3〜5日
- 初心者へのやさしさ
- 35/100
- issue の種類
- バグ
- 明瞭さ
- 説明が足りない
- 活発さ
- 停滞
- 技術スタック
- java, rabbitmq
- 領域
- backend, networking
調査の方向性
com.rabbitmq.client.impl.AMQChannel、特に privateRpc()、rpc(m,k)、getReply(...) から調査を始め、5.8.0 クライアントを使用して警告ログに記載された割り込み経路を再現してください。完了条件は、割り込まれた呼び出しでメッセージが失われず、設定されたタイムアウトを超えて getReply がハングしないことです。リポジトリに回帰テストが用意されている場合は、それを追加または更新してください。
索引モデルが issue の本文から書いたものです。
説明
To avoid thread execution for too long, we interrupt the thread after the time limit is reached. Recently, We find that occasionally messages get lost. We use TX mode , and txCommit() got an ChannelContinuationTimeoutException. I found the following problem according to the warning log.
if thread interrupted before rpc(m,k) then rpc will not be sent to the server. And k.getReply(..) will hang for _rpcTimeout or forever.
client version is 5.8.0
com.rabbitmq.client.impl.AMQChannel
private AMQCommand privateRpc(Method m)
throws IOException, ShutdownSignalException
{
SimpleBlockingRpcContinuation k = new SimpleBlockingRpcContinuation(m);
rpc(m, k);
// At this point, the request method has been sent, and we
// should wait for the reply to arrive.
//
// Calling getReply() on the continuation puts us to sleep
// until the connection's reader-thread throws the reply over
// the fence or the RPC times out (if enabled)
if(_rpcTimeout == NO_RPC_TIMEOUT) {
return k.getReply();
} else {
try {
return k.getReply(_rpcTimeout);
} catch (TimeoutException e) {
throw wrapTimeoutException(m, e);
}
}
}
- 主要言語
- Java
- スター
- 1.3k
- フォーク
- 588
- 平均マージ
- 4時間 40分
- マージ済み PR（30日）
- 38
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートあり
- コントリビューションガイドを読む
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
rabbitmq/rabbitmq-java-client のほかの issue
-
Bump dependenciesオープンdependency-upgrade
難易度 3/5 1〜2日 初心者へのやさしさ 35/100
rabbitmq/rabbitmq-java-client#2110 ·
メンテナーはふだん 1 日以内に返信
-
Add option to automatically set User-ID in basicPublish再び着手できるかも @UmerQureshi21 が 284 日前に担当しましたが、オープン中のプルリクエストはありません。 オープンenhancement
難易度 4/5 3〜5日 初心者へのやさしさ 35/100
rabbitmq/rabbitmq-java-client#1748 · コメント 4 件 ·
メンテナーはふだん 1 日以内に返信
-
enhancement
難易度 5/5 1週間以上 初心者へのやさしさ 25/100
rabbitmq/rabbitmq-java-client#1535 · コメント 5 件 ·
メンテナーはふだん 1 日以内に返信
-
bug
難易度 2/5 1〜3時間 初心者へのやさしさ 45/100
rabbitmq/rabbitmq-java-client#1421 · リアクション 1 件 ·
メンテナーはふだん 1 日以内に返信
-
Thread Pinning occurs with VirtualThreads enabled (spring boot 3)再び着手できるかも @acogoluegnes が 951 日前に担当しましたが、オープン中のプルリクエストはありません。 オープンenhancement help-wanted
rabbitmq/rabbitmq-java-client#1276 · コメント 3 件 · 担当者 2 名 ·
メンテナーはふだん 1 日以内に返信
rabbitmq/rabbitmq-java-client の issue をすべて見る
似ている issue
-
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
aws/context-ontology-accelerator#325 ·
メンテナーはふだん 1 日以内に返信
-
The README tells to run `mvn jeo:disassemble`, which fails with `No plugin found for prefix 'jeo'`オープン
難易度 1/5 1時間未満 初心者へのやさしさ 82/100
objectionary/jeo-maven-plugin#1938 ·
メンテナーはふだん 2 日以内に返信
-
難易度 2/5 1〜3時間 初心者へのやさしさ 78/100
oVirt/ovirt-engine#1219 ·
メンテナーはふだん 1 日以内に返信
-
pending:code-area pending:issue-category to-triage
難易度 2/5 1〜3時間 初心者へのやさしさ 76/100
メンテナーはふだん 1 日以内に返信
-
area:core bug priority:p2
難易度 2/5 1〜3時間 初心者へのやさしさ 82/100
aomarai/minecraft-mcp#247 ·
メンテナーはふだん 1 日以内に返信