Use ByteBuffers for message bodies
メンテナーはふだん 1 日以内に返信
まだ誰も着手していません。
評価
調査の方向性
channel.basicPublish(...) API から始め、メッセージ本文の byte[] 値がどのように変換され送信されるかを調査します。提案されている ByteBuffer と配列オフセットの代替案を、java.nio.Channel の扱いも含めて比較し、その後、採用する API を定義して、既存の動作を維持しながらメッセージ本文で不要なコピーが発生しないことを検証します。
索引モデルが issue の本文から書いたものです。
説明
Hi all,
I would like to propose to use ByteBuffer for message bodies. Now, the API accepts a plain byte[], which forces intermediate copies of buffers if we are already working with ByteBuffer or similar representations of a buffer.
Internally, the client implementation can use array() and arrayOffset() to get the data to be sent over the wire if hasArray() returns true; or copy the contents with get() in the other case. In pure NIO mode, we could simply write the ByteBuffer to the java.nio.Channel without any intermediate overhead.
What do you think?
Thank you!
addendum
FWIW, although I believe native support for ByteBuffer is the preferred solution, we could also avoid the copy if the API would accept an offset in the provided array (+ optionally the length) as an alternative proposal:
channel.basicPublish(..., buffer.array(), buffer.arrayOffset());
channel.basicPublish(..., buffer.array(), buffer.arrayOffset(), <length>);
- 主要言語
- 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 日以内に返信