ElasticSearch（十）：springboot集成ElasticSearch集群完成数据的增，删，改

前言

之前介绍了使用devTools进行索引库数据的crud，这里使用的是java程序，使用中间件activeMQ进行数据库和索引库数据的同步。主要是用来完成对数据库的修改来完成对索引库的同步。

正文

前提准备：

1. 索引信息：

结构化的索引，在索引的setting中，使用的是ik分词器，级别是ik-max-word。

mapping映射信息中，使用的dynamic = false，如果不能匹配到结构化索引的字段，则不进行数据的添加和更新。这样的好处是：不添加多余的不需要索引的字段，并且如果添加的字段多的话可以过滤掉无用的而不报错。对数据库添加的很多字段，只添加需要索引的结构化的映射信息。

2. elasticsearch信息

使用的是一台机器上的三个elasticsearch服务端的集群，分别使用的是9301,9300，9302的tcp端口。

创建项目进行数据库的操作

1. 对数据的删除

boolean flag = bookMapper.deleteByPrimaryKey(book.getId()) > 0 ? true : false;
        logger.info("删除数据返回的结果：" + flag);
        //将消息放入队列中，esQueueDelete：发送消息的类型，消息内容:book.getId().toString()
        if (flag) {
            producer.sendMessage(esQueueDelete, book.getId().toString());
        }
        return flag;

View Code