Spring Bootでバックエンドシステムを作成しよう

dependencies {
    : // (省略)
    implementation 'org.apache.camel:camel-spring-boot-starter:2.24.1'
}

import org.apache.camel.builder.RouteBuilder;
: (省略)
@Component
public class ZipcodeImportRouteBuilder extends RouteBuilder {

    //  (1) 定義を宣言する設定
    @Override
    public void configure() throws Exception {
        // (2) 処理ルートを定義する
        from("file://" + file.getAbsolutePath() + File.pathSeparator + "import").process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                // ファイルが存在したときの処理を記述
            }
        }).to("direct:import");
        //  (3) ルートは複数指定できる
        from("direct:import").process(new Processor() {
           // (省略)
        });
    }
}

@Component
public class ZipcodeImportRouteBuilder extends RouteBuilder {
    : (省略)

    @Override
    public void configure() throws Exception {
        File file = new File(".");

        // (1) 実行しているフォルダ以下のimportフォルダをチェックする
        from("file://" + file.getAbsolutePath() + File.pathSeparator + "import").process((Exchange exchange) -> {
            File importFile = exchange.getIn().getBody(File.class);
            InputStream is = new FileInputStream(importFile);

            // (2) 次処理の入力データを設定する
            Message in = exchange.getIn();
            in.setBody(is);
        }).to("direct:import");

        //  (3) InputStreamの入力を受けてデータを登録するルート
        from("direct:import").process((Exchange exchange) -> {
            Message msg = exchange.getIn();
            Object body = msg.getBody();
            if(body instanceof InputStream){
               InputStream is = (InputStream)body;
               try {
                   importData(is);
                   exchange.getOut().setHeader("Status","OK");
               }
               // (省略)
            }
        });
    }

    // (3)
    protected void importData(InputStream is) throws UnsupportedEncodingException, IOException{
        // (省略) InputStreamからCSVデータを読んで、DBに追加、または更新する
    }
}

import org.springframework.scheduling.annotation.EnableScheduling;

@EnableScheduling
public class MainApplication {
    // (省略)
}

: (省略)
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class WebDownloadTask {

    // (1) Apache CamelのContextオブジェクトを取得する
    @Autowired
    CamelContext camelContext;

    // (2) Springのスケジュール機能を使った実行
    @Scheduled(cron = "0 0 1 * * *")
    public void downloadFile(){

        // (3) 指定したURLからファイルをダウンロードする
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder(URI.create(downloadUrl)).build();

        try {
            Path path = Files.createTempFile("download-",".zip");

            HttpResponse<Path> response = client.send(request, HttpResponse.BodyHandlers.ofFile(path));
            File file = path.toFile();
            if(file.exists()){

                ZipFile zipFile = new ZipFile(file);
                ZipEntry entry = zipFile.entries().nextElement();
                InputStream is = zipFile.getInputStream(entry);

                // (4) ダウンロードしたZipファイル内のデータ（1つのみ）を入力とし、"direct:import"のエンドポイントに処理をつなげる
                ProducerTemplate template = camelContext.createProducerTemplate();
                Exchange exchange = template.send("direct:import", (Exchange obj) -> {
                    obj.getIn().setBody(is,InputStream.class);
                });

                // (5) 処理結果を取得する
                Message out = exchange.getOut();
                String status = out.getHeader("status",String.class);
                if(status.equals("OK")){
                    log.info("import OK");
                }
                // (省略)
            }
        }
        // (省略)
    }
}

@RequestMapping("/admin/zipcode")
public class AdminController {

    //  PUTでのファイルアップロード処理
    //  curlを使ったファイルアップロード例 : curl -u  -X PUT http://127.0.0.1:8082/admin/zipcode/import -T import.csv
    @PutMapping("/import")
    public Response importAction(InputStream is){
        // 受信したデータを使ってApache Camelのルートを実行する
        ProducerTemplate template = camelContext.createProducerTemplate();
        Exchange exchange = template.send("direct:import", (Exchange obj) -> {
            obj.getIn().setBody(is,InputStream.class);
        });
        // (省略)
    }
}