Spring IntegrationでTCP通信する処理の流れを調べてみた(サーバ編)

前回に引き続き、Spring IntegrationでTCP通信する処理の流れを整理するために、煩雑ではありますがクライアント側のシーケンス図を描いてみました。

前回：
Spring IntegrationでTCP通信する処理の流れを調べてみた(クライアント編)

前段階

autoStartUpが有効、つまりアプリケーション起動時にInboundGatewayやConnectionFactoryが起動するケースを想定しています。そのため起点がおかしなことになってしまいました。

1. InboundGatewayはConnectionFactoryを設定するメソッドを呼ぶ。
2. ConnectionFactoryは送受信者としてSender, ListenerにInboundGatewayを登録する(InboundGatewayはTcpSender, TcpListenerを実装している)。
3. ConnectionFactoryのライフサイクルをstartにする。

TCP接続(クライアントからの受信準備)

1. 指定したポート番号をもとにServerSocketFactoryにServerSocketを生成するよう依頼する。
2. 受け取ったServerSocketを保持し、Socketが接続を受け入れられる状態で待機させる。
3. TcpConnectionServerListeningEventを発行する。
4. SocketをもとにTcpConnectionを構築する。
5. TcpConnectionはConnectionFactoryを介して、InboundGatewayを送受信者として登録する。
6. InboundGatewayがTcpConnectionを保持する、
7. TcpConnectionOpenEventを発行する。

TCP接続(クライアントへの返信)

1. クライアントからメッセージを受信する。
2. メッセージとチャネルを電文変換・業務処理をおこなうためのテンプレートであるMessagingTemplateに渡す。
3. 処理結果をInboundGatewayに返す。
4. 返信するメッセージをTcpConnectionに渡す。
5. MessageMapperにメッセージを渡す。
6. MessageMapperはメッセージのペイロードを抽出して返す。
7. TcpConnectionはペイロードを直列化してクライアントに返信する。

備考：
図では省略していますが、MessagingTemplateとInboundGatewayの間にはChannelや各種エンドンポイントがあります。

TCP接続(接続の解除)

1. TCP接続が確立している間になんらかの例外が発生した場合ConnectionExceptionEventを発行する。
2. Socketを閉じる。
3. TcpConnectionはInboundGatewayに解除する接続をリストから削除するよう依頼する。
4. ConnectionCloseEventを発行する。
5. LifeCycleを管理するProcessorがInboundGatewayに停止するよう依頼する。
6. InboundGatewayはConnectionFactoryに停止するよう依頼する。
7. ConnectionFactoryはServerSocketを閉じる。
8. まだ残っているTCP接続があれば、それらを閉じる。
9. TcpConnectionはInboundGatewayに解除する接続をリストから削除するよう依頼する。またタスクが残っている場合はそれも削除する。

備考：
1でなんらかの例外が発生した場合と記載しましたが、Socketが閉じられた場合などを指します。
詳しくはTcpNetConneciton#runを参照してください。

図の作成に使ったサービス

↑の図は前回に引き続きWebSequenceDiagramsというサービスを利用して作成しました。