从一个监控项目谈Spring Boot 的简约

前言

近期刚上线一个搜索的功能，是基于elasticsearch，我们需要将mysql的数据实时同步到elasticsearch，如果同步失败，或者延迟都会造成程序无法使用。所以需要一个监控项目去监控数据，发现异常后发送邮件报警。一个简单而又可行的思路就是定时任务去查mysql和elasticsearch，然后对比数据条数是否相等。以前的思路我们会创建一个spring的项目，然后用maven管理spring各种依赖。还要去配置mybaits和elasticsearch。其实我们一个很简单的功能，却要将90%的时间花费到项目搭建和配置中去。so，no way。这时候Spring Boot出现了

项目搭建

先从项目搭建谈起，我们需要连接mysql、elasticsearch、mongodb，所以说我们需要配置mybatis(也可以选择其他)、spring-data-elasticsearch、spring-data-mongodb。我们用spring initializr 帮我们创建项目，如图

Paste_Image.png

选择spring initializr ，点击next

Paste_Image.png

请看红框圈出的部分，首先我们创建的是一个web项目，数据库用的到的是mysql、NoSql部分用了mongodb和elasticsearch。然后一路next后查看下我们项目结构

Paste_Image.png

Spring Boot会帮我们生成一个带有main方法的类xxxApplication 和 一个测试类
xxxApplicationTests
目前为止我们已经完成了百分之80的工作量，什么？你不信？ok，打开Application.properties,增加mysql、es、mongo的连接信息

spring.datasource.url=jdbc:mysql://xxx:3306/gym
spring.datasource.username=
spring.datasource.password=
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

#mongodb config
spring.data.mongodb.uri=mongodb://hotbody_mongo:Password4Hotbody@xxx/gym?replicaSet=rs

#elasticsearch config
spring.data.elasticsearch.cluster-name=
spring.data.elasticsearch.cluster-nodes=xxx:9300
spring.data.elasticsearch.local=false
spring.data.elasticsearch.repositories.enabled=true

然后运行xxxApplication的main方法

Paste_Image.png

可以看到spring boot 帮我们内嵌了tomcat，项目启动的时候也去初始化了mysql、mongo、es的连接池，那么到目前为止，项目搭建的工作已经完成了
接下来回归到我们的需求上，我们需要一个定时器,那么需要这样配置

@EnableScheduling
@ComponentScan("com.me")
@SpringBootApplication
public class DemoApplication {

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

这样就开启了，定时任务，然后我们创建定时任务的类

@Component
public class Task {
    
    @Scheduled(cron = "0 0 0/1 * * ?")
    public void scheduler() throws Exception{
       
    }
}

定时任务就配置完了，现在我们需要一个dao层，去完成对mysql、es、mongo的查询功能，先看mysql，我们只需要创建一个接口

@Mapper
public interface xxxMapper {
    @Select("select count(*) from xxx")
    Long count();
}

不用担心，当我们用的时候，框架会自动帮我们注入xxxMapper的实现的。
同理mongo：

public interface xxxMongoRepository extends MongoRepository<xxx,Long>{
}

elasticsearch：

public interface xxxElasticSearchRepository extends ElasticsearchRepository<xxx,Long>{
}

只需要两个空的接口。同样框架帮我们注入实现类

同时不要忘记在main方法开启这两项配置

@Configuration
@EnableAutoConfiguration
@SpringBootApplication
@ComponentScan("com.pampas")
@EnableMongoRepositories("com.pampas.repository")
@EnableElasticsearchRepositories("com.pampas.repository")
@MapperScan("com.pampas.repository")
@EnableScheduling
public class MonitorApplication implements EmbeddedServletContainerCustomizer{

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

目前就完成了所有的工作。接下来部署项目了。在服务器上执行

mvn package

在target目录下会生成一个jar

java -jar xxx.jar

ok! finish