SpringBoot+Elasticsearch按日期实现动态创建索引(分表)-Toy模板网

这篇具有很好参考价值的文章主要介绍了SpringBoot+Elasticsearch按日期实现动态创建索引(分表)。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

😊 @ 作者：一恍过去

💖 @ 主页： https://blog.csdn.net/zhuocailing3390

🎊 @ 社区： Java技术栈交流

🎉 @ 主题： SpringBoot+Elasticsearch按日期实现动态创建索引(分表)

⏱️ @ 创作时间： 2023年02月19日

前言

SpringBoot+Elasticsearch，通过@Document注解，利用EL表达式指定到配置文件，实现动态生成IndexName值，比如：

@Document(indexName = "product_#{@esIndex}")

1、创建动态索引配置文件

在配置文件中按照yyyy_MM_dd格式返回索引值的后缀，并且通过定时任务对索引值实现更新操作，定时任务是通过重建Bean对象实现对esIndex值进行更新。

重建Bean原因：Bean默认只有在服务启动时加载，若需动态改变Bean就要先销毁这个Bean之后再重新加载。


@Configuration
public class EsIndexConfig {

    @Resource
    private ApplicationContext applicationContext;

    @Resource
    private ElasticsearchRestTemplate elasticsearchRestTemplate;

    @Bean(name = "esIndex")
    public static String esIndex() {
        // 此处模拟按日期创建索引
        // 由于方便测试，索引直接返回时间戳，作为索引名称，时间可以为yyyy-MM-dd
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy_MM_dd");
        String date = sdf.format(new Date());
        System.out.println(date);

        date = System.currentTimeMillis() / 1000 + "";
        System.out.println("date:" + date);
        return date;
    }

    // 每天0点
    @Scheduled(cron = "0 0 0 * * ?")
    public void updateEsIndex() {
        DefaultListableBeanFactory defaultListableBeanFactory = (DefaultListableBeanFactory) applicationContext.getAutowireCapableBeanFactory();
        // 销毁指定实例
        defaultListableBeanFactory.destroySingleton("esIndex");
        String index = EsIndexConfig.esIndex();
        // 重新注册
        defaultListableBeanFactory.registerSingleton("esIndex", index);

        // 对索引进行一次手动创建(因为自动创建会丢失shards参数)
        IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(ProductEntity.class);
        if (!indexOperations.exists()) {
            indexOperations.create();
        }
    }
}

其他做法：
也可以不通过定时任务更新索引值，可以在操作save方法前，判断索引是否存在，如果不存在再进行重建Bean更新索引值，如下实例：
IndexOperations indexOperations = elasticsearchRestTemplate.indexOps(ProductEntity.class);
       if (!indexOperations.exists()) {
           索引不存在，则重建Bean更新索引值
       }

SpringBoot+Elasticsearch按日期实现动态创建索引(分表)

2、创建实体

创建的实体类，需要关闭自动创建index属性(createIndex = false)，通过配置文件来创建索引值，原> 因：如果开启自动索引，在项目启动时的第一个索引会完整创建成功，但是后续通过定时任务创建的索引会缺失配置的shards、replicas参数；

默认情况下：createIndex属性值为true，在项目启动时就会按照@Document注解中的配置进行索引的创建，为了包装每次创建索引的完整性，需要将createIndex属性值为false

@Document(indexName = "product_#{@esIndex}", createIndex = false, shards = 3, replicas = 2)
@Data
public class ProductEntity implements Serializable {

    @Id
    private String id;

    /**
     * 文本类型，使用ik分词器
     */
    @Field(type = FieldType.Text, analyzer = "ik_max_word")
    private String name;

    /**
     * 价格
     */
    @Field(type = FieldType.Double)
    private BigDecimal money;

    /**
     * 时间戳
     */
    @Field(type = FieldType.Long)
    private Long time;

    /**
     * 颜色
     */
    @Field(type = FieldType.Keyword)
    private String color;
}

3、Repository对象

Repository接口用于定义Elasticsearch数据访问操作的标准化方法。它提供了一组内置的CRUD（创建、读取、更新、删除）操作，以及其他一些常见的查询方法。

要使用Repository对象，首先需要定义一个继承自ElasticsearchRepository接口的自定义接口，用于操作指定的实体类型。该自定义接口通常称为Repository接口，其中的方法会映射到相应的Elasticsearch数据操作。
比如创建ProductEntity实体对应的Repository接口：

public interface ProductRepository extends ElasticsearchRepository<ProductEntity, String> {
    
}

4、Controller对象

测试时，可以将索引动态更新的定时任务时间设置为一分钟，并且返回的索引值由yyyy_MM_dd修改为一个随机数；调用save方法后，过一分钟后再次进行调用，通过head/kibana观察是否生成了新的索引。

@RestController
@RequestMapping("es")
@Slf4j
public class ProductController {

    @Resource
    private ProductRepository productRepository;

    @PostMapping
    public void save() {
        String[] colors = {"red", "purple", "blue"};
        String[] name = {"手机", "电脑", "微波炉", "电视"};
        // 新增列表数据
        List<ProductEntity> testList = new ArrayList<>();
        long sys = System.currentTimeMillis();
        for (int i = 0; i < 10; i++) {
            // 模拟随机数
            double random = Math.random() * 1000;

            ProductEntity productEntity = new ProductEntity();
            productEntity.setId(i + "");
            productEntity.setName(name[i % 4]);
            productEntity.setMoney(new BigDecimal(random));
            productEntity.setTime(sys + i % 3);
            productEntity.setColor(colors[i % 3]);
            testList.add(productEntity);
        }
        // 新增成功后，在head或者kibana中就可以看到相应数据，如果save时数据Id存在则更新操作
        // 批量新增
        productRepository.saveAll(testList);

        // 单个新增
        ProductEntity productEntity = testList.get(9);
        productEntity.setId("11");
        productRepository.save(productEntity);
    }
}