Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

第243章 Netty4 HTTP コンポーネント

Camel バージョン 2.14 以降で利用可能

netty4-http コンポーネントは、Netty4 による HTTP トランスポートを容易にする Netty4 コンポーネントの拡張機能です。

この camel コンポーネントは、プロデューサーエンドポイントとコンシューマーエンドポイントの両方をサポートします。

ストリーム

Netty はストリームベースです。つまり、受信した入力はストリームとして Camel に送信されます。つまり、ストリームのコンテンツを 一度 だけ読み取ることができます。

Netty4 HTTP は、io.netty.handler.codec.http.HttpObjectAggregator を使用して、ストリーム全体をメモリーに読み込み、完全な http メッセージ全体をビルドします。ただし、結果のメッセージは、一度読み取り可能なストリームベースのメッセージのままです。

ヒント

もし、メッセージボディーが空のように見える場合や、何度もデータにアクセスする必要がある場合 (例: マルチキャストや再配送エラー処理) は、ストリームキャッシュを使用するか、何度再読み込みしても安全な String にメッセージボディーを変換します。

Maven ユーザーは、このコンポーネントの pom.xml に以下の依存関係を追加する必要があります。 

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-netty4-http</artifactId>
    <version>x.x.x</version>
    <!-- use the same version as your Camel core version -->
</dependency>
Copy to Clipboard Toggle word wrap
InputStream

InputStream がメッセージボディーとして使用され、大きなデータストリーム (たとえば、> 2 GB) を読み書きする必要がある場合は、disableStreamCache パラメーターを true に設定してストリーミングサポートを使用する必要があります。

例 1: サーバーへの大きなデータストリームのアップロード 

// Upload a large data stream to the server
from("direct:upstream-call")
        .bean(Helper.class, "prepareStream")
        .to("netty-http:http://localhost:{{port}}/upstream?disableStreamCache=true")
        .log("get ${body}");

// Read a large data stream from the client
from("netty-http:http://0.0.0.0:{{port}}/upstream?disableStreamCache=true")
        .bean(Helper.class, "processStream")
        .to("mock:stream-size");
Copy to Clipboard Toggle word wrap

例 2: サーバーからの大きなデータストリームのダウンロード 

// Download a large data stream from the server
from("direct:download-call")
        .to("netty-http:http://localhost:{{port}}/downstream?disableStreamCache=true")
        .bean(Helper.class, "asyncProcessStream")
        .log("get ${body}");

// Write a large data stream to the client
from("netty-http:http://0.0.0.0:{{port}}/downstream?disableStreamCache=true")
        .bean(Helper.class, "prepareStream");
Copy to Clipboard Toggle word wrap

ダウンロードの例では、基になるストリームハンドラーをブロックしないように、他のスレッドで InputStream から読み取る必要があります (asyncProcessStream を参照)。 

    public static void processStream(Exchange exchange) throws Exception {
        InputStream is = exchange.getIn().getBody(InputStream.class);

        byte[] buffer = new byte[1024];
        long read = 0;
        long total = 0;
        while ((read = is.read(buffer, 0, buffer.length)) != -1) {
            total += read;
        }

        exchange.getIn().setBody(new Long(total));
    }

    public static CompletableFuture<Void> asyncProcessStream(Exchange exchange) {
        return CompletableFuture.runAsync(() -> {
            try {
                processStream(exchange);
            } catch (Exception e) {
                exchange.setException(e);
            }
        });
    }
Copy to Clipboard Toggle word wrap

243.1. URI 形式
リンクのコピー

netty コンポーネントの URI スキームは次のとおりです。 

netty4-http:http://0.0.0.0:8080[?options]
Copy to Clipboard Toggle word wrap

URI には、?option=value&option=value&…​ の形式でクエリーオプションを追加できます。

注記

情報: クエリーパラメーターとエンドポイントオプション。Camel が URI クエリーパラメーターとエンドポイントオプションをどのように認識するのか疑問に思われるかもしれません。たとえば、次のようにエンドポイント URI を作成できます - netty4-http:http//example.com?myParam=myValue&compression=true。この例では、myParam が HTTP パラメーターであり、compression が Camel エンドポイントオプションです。このような状況で Camel が使用するストラテジーは、利用可能なエンドポイントオプションを解決し、それらを URI から削除することです。これは、前述の例の場合、compression エンドポイントオプションが解決され、ターゲット URL から削除されるため、Netty HTTP producer によってエンドポイントに送信された HTTP リクエストが http//example.com?myParam=myValue のようになることを意味します。また、動的ヘッダー (CamelHttpQuery など) を使用してエンドポイントオプションを指定できないことにも注意してください。エンドポイントオプションは、エンドポイント URI 定義レベル (DSL 要素 to または from など) でのみ指定できます。

トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat