1、前言

在之前操作mongo的过程中，都是自动创建，几乎没有手动创建过表。

这次开发中有张表数据量大，并且不是特别重要，数据表维护一个常见的问题是过期数据没有被及时清理，导致数据量过大，查询变得缓慢。为了解决这个问题，我们可以通过创建过期索引来定期清理过期数据。

数据过期的原理可以看下之前的文章：我屮艸芔茻，mongo居然可以自动删除数据

2、直接上代码

逻辑很简单，在服务器启动之后去检查索引

1.先检查存不存在这个索引

2.然后创建索引

3.在每个entity中增加了一个save_time的字段

package com.tyjt.ccpparking.mgr;import com.tyjt.ccpparking.domain.entity.ParkingHBEntity;
import com.tyjt.ccpparking.domain.entity.ParkingRestInfoEntity;
import com.tyjt.ccpparking.msg.EmqxHBHandler;
import com.tyjt.ccpparking.service.ParkingService;
import lombok.Data;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.index.Index;
import org.springframework.data.mongodb.core.index.IndexDefinition;
import org.springframework.data.mongodb.core.index.IndexInfo;
import org.springframework.stereotype.Component;import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;@Component
@Data
public class Mgr implements ApplicationRunner {private static Logger logger = LoggerFactory.getLogger(Mgr.class);@ResourceMongoTemplate mongoTemplate;public Mgr() {mgr = this;}private static Mgr mgr;public static Mgr getInstance() {return mgr;}@Overridepublic void run(ApplicationArguments args) throws Exception {createMongoIndex(ParkingHBEntity.class);createMongoIndex(ParkingRestInfoEntity.class);}/*** 创建mongo的索引** @param clazz*/public void createMongoIndex(Class clazz) {try {if (isIndexExists(clazz)) {return;}Index index = new Index();index.on("save_time", Sort.Direction.DESC);index.expire(7, TimeUnit.DAYS);mongoTemplate.indexOps(clazz).ensureIndex(index);} catch (Exception e) {logger.error("create index fail {}", clazz.getName(), e);}}public boolean isIndexExists(Class clazz) {List<IndexInfo> indexInfos = mongoTemplate.indexOps(clazz).getIndexInfo();for (IndexInfo indexInfo : indexInfos) {if ("save_time_-1".equals(indexInfo.getName())) {return true;}}return false;}
}

注：这里可以直接接写collection name，

也可以使用实体的class，因为mongo的entity的注解有@Document(collection = "parking_HB")