かんがるーさんの日記

最近自分が興味をもったものを調べた時の手順等を書いています。今は Spring Boot をいじっています。

Spring Boot + Spring Integration でいろいろ試してみる ( 大目次 )

他の記事と並行して少しずつ書きためていくつもりです。先に大目次を作成しておきます。更新は不定期です。

Spring Integration は少し難しそうですが、いろいろクラスが用意されていて、理解できると実現できることが増えると思っています。

  1. その1 ( SFTP でファイルアップロードするバッチを作成する )
  2. その2 ( POP3 でメールを受信するバッチを作成する )
  3. その3 ( ディレクトリを監視してファイルが置かれたら処理→削除/移動する常駐型アプリケーションを作成する )
  4. その4 ( 監視しているディレクトリに置かれた Excel ファイルのデータを DB に登録する → 処理が終わったら Excel ファイルを削除/移動する )
  5. その5 ( 監視しているディレクトリに置かれた Excel ファイルのデータを DB に登録する → 処理が終わったら Excel ファイルを削除/移動する2 )
  6. その6 ( AcceptOnceFileListFilter をセットしていないはずの FileReadingMessageSource で同じファイルが2度処理されない理由とは? )
  7. その7 ( STS の integration-graph で Spring Integration のフロー図を描く )
  8. その8 ( MySQL のテーブルのデータを取得して PostgreSQL のテーブルへ登録する常駐型アプリケーションを作成する )
    • その8から Spring Integration DSL を使用しています。
  9. その9 ( Pollers.fixedRate で待機時間を指定しても意味がない場合がある? )
  10. その10 ( URL一覧のファイルが置かれたらアクセス可能かチェックして結果ファイルに出力する )
  11. その11 ( Spring Cloud Sleuth を使用して処理状況を Zipkin で表示する )
  12. その12 ( FTP サーバからファイルをダウンロードして SFTP サーバへアップロードする )
  13. その13 ( FTP サーバからファイルをダウンロードして SFTP サーバへアップロードする2 )
  14. その14 ( delayer のサンプルを作ってみる )
  15. その15 ( RequestHandlerRetryAdvice のサンプルを作ってみる )
  16. その16 ( ExpressionEvaluatingRequestHandlerAdvice のサンプルを作ってみる )
  17. その17 ( @MessagingGateway でメソッド呼び出しのインターフェースで MessageChannel へ Message を送信する )
  18. その18 ( @MessagingGateway でメソッド呼び出しのインターフェースで MessageChannel へ Message を送信する2 )
  19. その19 ( Flow の途中で一時的に別の Flow を実行したいなら wireTap! )
  20. その20 ( MessageChannel に Redis を使用する )
  21. その21 ( MessageChannel に Redis を使用する2 )
  22. その22 ( http でリクエストを受信 → JdbcChannelMessageStore を使用した QueueChannel に Message を送信 → Message を受信して bat ファイルを実行する )
  23. その23 ( http でリクエストを受信 → JdbcChannelMessageStore を使用した QueueChannel に Message を送信 → Message を受信して bat ファイルを実行する2 )
  24. その24 ( MessageSource からの Message 送信有無を制御する )
  25. その25 ( Docker Compose でサーバを構築する、SMTP+POP3サーバ編 )
  26. その26 ( MessageChannel の capacity を超えたメッセージを送信しようとするとどうなるのか? )
  27. その27 ( Spring Integration Extension for AWS で S3 へファイルをアップロード・ダウンロードする )
  28. その28 ( Spring Cloud for AWS で S3 へファイルをアップロード・ダウンロードする )
  29. その29 ( Docker Compose でサーバを構築する、FTP+SFTPサーバ編 )
  30. その30 ( Docker Compose でサーバを構築する、SMTP over SSL+POP over SSLサーバ編 )
  31. 番外編 ( Docker for Windows では host networking driver は使えない )
  32. 番外編 ( POP over SSL で Docker コンテナと通信できなくなる問題を調べてみる。。。が、解決はしませんでした )
  33. その31 ( Aggregator のサンプルを作ってみる )
  34. その32 ( Aggregator のサンプルを作ってみる2 )
  35. その33 ( 5.1 からの新機能 Java Functions Improvements を試してみる )
  36. その34 ( Docker Compose でサーバを構築する、Kafka 編 )
  37. その35 ( Docker Compose でサーバを構築する、Kafka 編2 )
  38. その36 ( Docker Compose でサーバを構築する、Kafka 編3 - Spring Integration DSL で producer, consumer を実装する )
  39. その37 ( Docker Compose でサーバを構築する、Kafka 編4 - zookeeper と kafka を cluster 構成に変更する )
  40. その38 ( Docker Compose でサーバを構築する、Kafka 編5 - broker や zookeeper 停止時の動作を確認する )
  41. その39 ( Docker Compose でサーバを構築する、Kafka 編6 - cp-schema-registry を追加し Apache Avro を使用する )
  42. その40 ( Docker Compose でサーバを構築する、Kafka 編7 - cp-schema-registry を追加し Apache Avro を使用する2 )
  43. その41 ( Docker Compose でサーバを構築する、Kafka 編8 - broker の metrics を収集・表示する )
  44. その42 ( Docker Compose でサーバを構築する、Kafka 編9 - consumer の metrics を収集・表示する )
  45. その43 ( Docker Compose でサーバを構築する、Kafka 編10 - consumer の metrics を収集・表示する2 )
  46. その44 ( Docker Compose でサーバを構築する、Kafka 編11 - kafka-producer-perf-test、kafka-consumer-perf-test コマンドでパフォーマンスを確認する )
  47. その45 ( Docker Compose でサーバを構築する、Kafka 編12 - 簡単な Kafka Streams アプリを作成してみる )
  48. その46 ( Docker Compose でサーバを構築する、Kafka 編13 - 1つのアプリケーション内に複数の Kafka Streams アプリを定義する+KTable を使ってみる )
  49. その47 ( Docker Compose でサーバを構築する、Kafka 編14 - Kafka Streams の Window 処理を試してみる )
  50. その48 ( Docker Compose でサーバを構築する、Kafka 編15 - Kafka Streams で Apache Avro を使用する )

(.....続くはず.....)