メインコンテンツまでスキップ

アーキテクチャー

FEPアーキテクチャーは、インターフェースの処理方式によりオンラインアーキテクチャー、バッチアーキテクチャー、一括伝送アーキテクチャーに区分され、ロギング時に必要なロギングアーキテクチャーおよびL4 Switchの役割をするポーリングアーキテクチャーで構成されている。

オンラインアーキテクチャー​

APtoAPなどの一般取引インターフェースが実行される環境で、ゲートウェイコンポーネントとインターフェースコンポーネントで構成される。

ゲートウェイコンポーネント​

A. 通信プロトコル処理​

通信プロトコル処理のために、コネクション情報とコネクショングループ情報を管理する。

コネクション情報は、接続対象の接続情報および通信処理のための詳細属性で、コネクショングループは、同じインターフェースを複数のコネクションが処理する場合に各コネクションの負荷分散ポリシーを管理する。

コネクション情報の詳細設定は、コネクション設定を参照する。

B. 電文伝送​

連携対象から受信した電文を、インターフェースコンポーネントで伝達するか、インターフェースコンポーネントで受信した電文を連携対象に送信する。 この時、キャラクターセットのエンコーディング/デコーディング処理、および全電文の暗号・復号化処理を行う。

インターフェースコンポーネント​

インターフェースコンポーネントは、インターフェース処理を行い、イベントハンドラと処理フローで構成される。

A. イベントハンドラ​

イベントハンドラは、ゲートウェイコンポーネントから非同期方式で伝達された電文を解析し、インターフェースIDと要求/応答を区分する。 また、インターフェース制御状態を確認して処理フローに伝達する。

B. 処理フロー​

処理フローは、電文変換などのインターフェース処理を行う。

要求処理を行う要求フローと応答処理を持つ応答フローがあり、インターフェースごとに定義する。 それぞれのフローは、多数のルーターで構成される。

- フロー​

Apache Camelのルーターグループを意味する。 それぞれの単位機能のルーターを順序に呼び出し、オンラインインターフェースを処理する。

BXIでは、電文変換などのインターフェース処理時に必要な基本フローを提供する。 特化したインターフェース要件を処理するために、フローを開発して適用することができる。

- ルーター​

Apache CamelのRouteのことで、フローで処理される単位機能である。

例えば、電文をマップに変換するUnmarshalは、１つのルーターが提供する機能である。 BXIは、インターフェースの取引処理で一般的に使用されるルーターを提供する。

一般的に提供されるルーターの機能以外の追加機能が必要な場合は、新規にルーターを開発して適用することができる。 開発方法は、Customizingを参照する。

バッチアーキテクチャー​

バッチインターフェース処理アーキテクチャーは、DBtoDB、FiletoFileなどのバッチインターフェースが実行される環境であり、 バッチ作業スケジュールコンポーネントとバッチ作業の実行コンポーネントで構成される。

バッチ作業スケジュールコンポーネント​

登録されたバッチインターフェースの作業スケジュールを管理する機能を持つ。 バッチインターフェースに登録されたスケジュールを利用して、インターフェースを実行する。

スケジュールタイプは、シンプルトリガーとCRONトリガーがある。 シンプルトリガーはN秒、N分、N時間単位で動作する方式であり、CRONトリガーは表現式によって定められた時間に動作する方式である。 ex) 45 5 * * 5 毎日金曜日午前5時45分　スケジュール実行。

バッチ作業の実行コンポーネント​

バッチインターフェースの処理を行い、インターフェースのタイプに応じて下記の機能が使われる。

☑ File処理(FTP)​

Fileを使用するインターフェースのタイプで、FTP方式でファイルを送受信処理する。 FTP接続およびFTP GET/PUT機能を活用して、ファイル転送を実行する。

一括伝送アーキテクチャー​

一括伝送は、対外機関と規定されたプロトコル規約に従って、オンラインファイル伝送処理を行う。ファイル送信とファイル受信に区分される。

ファイル送信は、業務システムの環境設定に設定された送信ディレクトリにファイルをMoveする時点で業務が始まる。 ファイル受信は、対外機関から電文を受信する時点で業務が始まる。

送信業務フロー​

  1. 業務システムで送信ファイルを伝達
  2. ファイル検知およびファイル変更の有無を確認
  3. File to DB作業
  4. プロトコルによってファイルを送信
  5. 送信ファイルのバックアップ管理

受信業務フロー​

  1. 対外共通ヘッダーのパーシングおよび電文処理プロトコルの判断
  2. プロトコルによって電文受信および受信データを保存
  3. 受信ファイルの作成
  4. 業務システムに受信ファイルを伝達

ロギングアーキテクチャー​

BXIのログ処理方式は、オンラインインスタンスが直接ロギングするローカル(L)方式と、別のロギングアーキテクチャーを活用したリモート(R)方式に区分される。

ローカル(L)方式​

インスタンスが、オンラインインターフェースを処理しながら、直接DB/ファイルにログを格納する方式である。 オンライン取引量が多くない場合に使用する。

リモート(R)方式​

インターフェース処理時に発生するログデータを非同期でロギングする。 オンライン取引量が多い場合、インターフェース処理の性能向上のために使用する。

ログデータは、非同期ロギングアーキテクチャーで、Apache Kafkaに非同期で伝達され、レシーバーコンポーネントおよびロギングコンポーネントで構成された、別のロギングインスタンスでDB/Fileに記録される。

☑ Apache Kafka​

大容量のリアルタイムログ処理に特化したアーキテクチャーを提供するオープンソースソフトウェアである。

☑ ロギングインスタンス​

ロギングインスタンスは、下記のコンポーネントで構成される。

  • レシーバーコンポーネント : Kafkaに格納されているログをKafkaコンシューマーから読み込んでロギングコンポーネントに伝達する。
  • ロギングコンポーネント : DBやファイルにログ情報を格納する。 ログ設定およびログ管理は、ログ管理を参照する。

ポーリングアーキテクチャー​

BXIでは、システムとの連携時にL4 Switchを使用しない場合、L4 SwitchのFail-Over機能に代わる機能を提供する。

定期的なメッセージポーリング方式でこれに対応するため、インターフェース処理を実行するインスタンス以外に別のシステムポーリングインスタンスが必要である。 インターフェース処理を行うオンラインインスタンスは、システムポーリングインスタンスのシステム状態情報を利用して取引を処理する。

システムポーリングインスタンス​

HTTPでシステムと定期的にメッセージを送受信しながら状態を確認する。

システム状態情報は、メモリー上で管理され、別のDB同期スレッドが、システムポーリング状態をDBに同期する。

オンラインインスタンス​

定期的にDBのシステムポーリング状態情報をメモリーに同期し、このシステム状態情報を使用して、正常に取引処理が可能だと判断されたシステムに対して、取引を要求する。

システムポーリングインスタンスはノード別に１つだけ登録することができ、１つのシステムポーリングインスタンス情報として複数のノードで使用することができる。 ポーリングアーキテクチャーを使用するための詳細設定はシステムポーリングを参照する。