前言
近期刚上线一个搜索的功能，是基于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 帮我们创建项目，如图
选择spring initializr ，点击next
请看红框圈出的部分，首先我们创建的是一个web项目，数据库用的到的是mysql、NoSql部分用了mongodb和elasticsearch。然后一路next后查看下我们项目结构
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方法
可以看到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
