SpringBootでバッチアプリ

SpringBootでバッチアプリが簡単に作れます

プロパティファイルなどを共有できるので1つのプロジェクトに両方入れちゃう事ができます。
スモールビジネスの場合に大活躍です。

サンプル

1.CommandLineRunnerを継承します。

2.@EnableAutoConfigurationを追加します。
(他のやつはなくても動くかも・・・・)

3.ApplicationContextを@Autowiredしておきます。
new しなくても勝手に中身が入ってます。

@Autowired
private ApplicationContext context;

4.自クラスをSpringApplicationにぶち込みます。

SpringApplication application = new SpringApplication(MongExample.class);

5.内蔵ウェブサーバーの立ち上げをOFFにします。

application.setWebEnvironment(false);

6.コンテキストを渡して処理を走らせます

ApplicationContext context = application.run();

7.処理が終わったらEXITします

SpringApplication.exit(context);

別スレッドでrunメソッドが走ってるので、ここはシンクロナイズドしないといけないかも？？？
Handlerで終了を受け取ってもいいと思います。
ただ、exitしないとずっとjarが起動したまんま終了しないんですね。
その代わり、この中でタイマー回しておく事ができるので、数分に1回処理をしないといけないとか監視系の処理は立ち上げっぱなしでOK！

MongExample.java

@EnableAutoConfiguration
@EnableBatchProcessing
@EnableConfigurationProperties
public class MongExample implements CommandLineRunner {

    //  get Applicateion context Example2
    @Autowired
    private ApplicationContext context;

    @Autowired
    private Environment env;

    public static void main(String[] args) {
        //SpringApplication.run(MongExample.class, args);

        SpringApplication application = new SpringApplication(MongExample.class);
        application.setWebEnvironment(false);
        ApplicationContext context = application.run();
        SpringApplication.exit(context);


    }

    @Override
    public void run(String... args) throws Exception {
        //  get mongo Template
        MongoOperations mongoOperation = (MongoOperations) context.getBean("mongoTemplate");

        //  Data Object this structure can be a table
        User user = new User("mkyong", "password123");

        // save
        mongoOperation.save(user);

        // now user object got the created id.
        System.out.println("1. user : " + user);

        // query to search user
        Query searchUserQuery = new Query(Criteria.where("username").is("mkyong"));

        // find the saved user again.
        User savedUser = mongoOperation.findOne(searchUserQuery, User.class);
        System.out.println("2. find - savedUser : " + savedUser);

        // update password
        mongoOperation.updateFirst(searchUserQuery, 
                            Update.update("password", "new password"),User.class);

        // find the updated user object
        User updatedUser = mongoOperation.findOne(searchUserQuery, User.class);

        System.out.println("3. updatedUser : " + updatedUser);

        // delete
        //mongoOperation.remove(searchUserQuery, User.class);

        // List, it should be empty now.
        List<User> listUser = mongoOperation.findAll(User.class);
        System.out.println("4. Number of user = " + listUser.size());

    }
}