このバージョンはまだ開発中であり、まだ安定しているとは見なされていません。最新の安定バージョンについては、Spring Integration 6.5.3 を使用してください!

統合エンドポイント

このセクションでは、外部システムとのメッセージベースの通信をサポートするために、Spring Integration が提供するさまざまなチャネルアダプターとメッセージングゲートウェイについて説明します。

AMQP から Zookeeper までの各システムには独自の統合要件があり、このセクションではそれらについて説明します。

エンドポイントのクイックリファレンステーブル

前のセクションで説明したように、Spring Integration は、外部システム、ファイルシステムなどとのインターフェースに使用される多くのエンドポイントを提供します。

For transparent dependency management, Spring Integration provides a bill-of-materials POM to be imported into the Maven configuration:

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.integration</groupId>
            <artifactId>spring-integration-bom</artifactId>
            <version>7.0.0-RC1</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

要点をまとめると:

  • 受信チャネルアダプターは、データをメッセージングアプリケーションに取り込むための一方向統合に使用されます。

  • 送信チャネルアダプターは、メッセージングアプリケーションからデータを送信するための一方向統合に使用されます。

  • 受信ゲートウェイは、他のシステムがメッセージングアプリケーションを呼び出して応答を受信する双方向統合フローに使用されます。

  • 送信ゲートウェイは、メッセージングアプリケーションが外部サービスまたはエンティティを呼び出し、結果を期待する双方向統合フローに使用されます。

次の表は、適切な章へのクイックリンクを使用して、さまざまなエンドポイントをまとめたものです。

表 1: エンドポイントのクイックリファレンス
モジュール 受信アダプター 送信アダプター 受信ゲートウェイ 送信ゲートウェイ

AMQP

受信チャネルアダプター

送信チャネルアダプター

受信ゲートウェイ

送信ゲートウェイ

Apache Camel

N

送信チャネルアダプター

N

送信ゲートウェイ

Apache Cassandra

N

送信チャネルアダプター

N

送信ゲートウェイ

Debezium

Debezium 受信チャネルアダプター

N

N

N

イベント

Spring アプリケーションイベントの受信

Spring アプリケーションイベントの送信

N

N

フィード

フィード受信チャネルアダプター

N

N

N

ファイル

ファイルを読むおよび "tail" ファイル

ファイルを書く

N

ファイルを書く

FTP(S)

FTP 受信チャネルアダプター

FTP 送信チャネルアダプター

N

FTP 送信ゲートウェイ

GraphQL

N

N

N

GraphQL 送信 ゲートウェイ

Hazelcast

Hazelcast 受信チャネルアダプター

Hazelcast 送信チャネルアダプター

N

N

HTTP

HTTP 名前空間のサポート

HTTP 名前空間のサポート

HTTP 受信コンポーネント

HTTP 送信コンポーネント

JDBC

受信チャネルアダプターおよびストアドプロシージャ受信チャネルアダプター

送信チャネルアダプターおよびストアドプロシージャの送信チャネルアダプター

N

送信ゲートウェイおよびストアドプロシージャの送信ゲートウェイ

JMS

受信チャネルアダプターおよびメッセージ駆動型チャネルアダプター

送信チャネルアダプター

受信ゲートウェイ

送信ゲートウェイ

JMX

通知リスニングチャネルアダプターおよび属性ポーリングチャネルアダプターおよびツリーポーリングチャネルアダプター

通知発行チャネルアダプターおよび操作呼び出しチャネルアダプター

N

操作呼び出し送信ゲートウェイ

JPA

受信チャネルアダプター

送信チャネルアダプター

N

送信ゲートウェイの更新および送信ゲートウェイの取得

Apache Kafka

メッセージ駆動型チャネルアダプターおよび受信チャネルアダプター

送信チャネルアダプター

受信ゲートウェイ

送信ゲートウェイ

メール

メール受信チャネルアダプター

メール送信チャネルアダプター

N

N

MongoDB

MongoDB 受信チャネルアダプター

MongoDB 送信チャネルアダプター

N

N

MQTT

受信(メッセージ駆動型)チャネルアダプター

送信チャネルアダプター

N

N

R2DBC

R2DBC 受信チャネルアダプター

R2DBC 送信チャネルアダプター

N

N

Redis

Redis 受信チャネルアダプター , Redis キュー受信チャネルアダプター , Redis ストア受信チャネルアダプター , Redis ストリーム受信チャネルアダプター

Redis 送信チャネルアダプター , Redis キュー送信チャネルアダプター , RedisStore 送信チャネルアダプター , Redis ストリーム送信チャネルアダプター

Redis キュー受信ゲートウェイ

Redis 送信コマンドゲートウェイおよび Redis キュー送信ゲートウェイ

リソース

リソース受信チャネルアダプター

N

N

N

RSocket

N

N

RSocket 受信ゲートウェイ

RSocket 送信ゲートウェイ

SFTP

SFTP 受信チャネルアダプター

SFTP 送信チャネルアダプター

N

SFTP 送信ゲートウェイ

SMB

SMB 受信チャネルアダプター , SMB ストリーミング受信チャネルアダプター

SMB 送信チャネルアダプター

N

SMB 送信ゲートウェイ

STOMP

STOMP 受信チャネルアダプター

STOMP 送信チャネルアダプター

N

N

ストリーム

ストリームからの読み取り

ストリームへの書き込み

N

N

syslog

Syslog Inbound Channel Adapter

N

N

N

TCP

TCP アダプター

TCP アダプター

TCP ゲートウェイ

TCP ゲートウェイ

UDP

UDP アダプター

UDP アダプター

N

N

WebFlux

WebFlux 受信チャネルアダプター

WebFlux 送信チャネルアダプター

受信 WebFlux ゲートウェイ

送信 WebFlux ゲートウェイ

Web サービス

N

N

受信 Web サービスゲートウェイ

送信 Web サービスゲートウェイ

Web ソケット

WebSocket 受信チャネルアダプター

WebSocket 送信チャネルアダプター

N

N

XMPP

XMPP メッセージおよび XMPP プレゼンス

XMPP メッセージおよび XMPP プレゼンス

N

N

ZeroMQ

ZeroMQ 受信チャネルアダプター

ZeroMQ 送信チャネルアダプター

N

N

さらに、コアメッセージングで説明したように、Spring Integration は、Plain Old Java Object(POJO)とのインターフェースのためのエンドポイントを提供します。チャンネルアダプターで説明したように、<int:inbound-channel-adapter> 要素を使用すると、データの Java メソッドをポーリングできます。<int:outbound-channel-adapter> 要素を使用すると、void メソッドにデータを送信できます。メッセージングゲートウェイで説明したように、<int:gateway> 要素により、Java プログラムはメッセージングフローを呼び出すことができます。これらはそれぞれ、Spring Integration のソースレベルの依存関係を必要とせずに機能します。このコンテキストでの送信ゲートウェイに相当するのは、サービスアクティベーター(サービスアクティベーターを参照)を使用して、ある種の Object を返すメソッドを呼び出すことです。

Starting with version 5.2.2, all the inbound gateways can be configured with an errorOnTimeout boolean flag to throw a MessageTimeoutException when the downstream flow doesn’t return a reply during the reply timeout. The timer is not started until the thread returns control to the gateway, so usually it is only useful when the downstream flow is asynchronous, or it stops because of a null return from some handler, e.g. filter. Such an exception can be handled on the errorChannel flow, e.g. producing a compensation reply for a requesting client.