

learn and grow up

spring-data-es抽象service集成简单增删查改之三

learn and grow up

spring-data-es抽象service集成简单增删查改之三

elasticsearch

字数统计: 2.5k阅读时长: 14 min

 2020/02/29   Share

• 
• 
• 
• 
• 

写在前面

接二

代码

继续整理了后续的实现类，注释已经比较清楚了，不在此赘述

本次主要更新了基于ElasticsearchTemplate来进行操作，主要是实现了批量的操作

//EsTemplateBaseService.java
import org.elasticsearch.action.bulk.BulkProcessor;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.script.Script;

import java.util.List;

/**
 * es java api操作接口类，基于es template实现
 * @author yyt
 * @param <T>
 */
public interface EsTemplateBaseService<T extends BaseDoc> extends EsDocService<T> {
    /**
     * 获取index name
     * @return
     */
    String getIndexName();

    /**
     * 获取type name
     * @return
     */
    String getTypeName();


    List<T> bulkSaveOrUpdate(List<T> ts);

    /**
     * bulk save
     * @param ts doc集合
     * @param listener 自定义监听类
     * @return
     */
    List<T> bulkSaveOrUpdate(List<T> ts, BulkProcessor.Listener listener);
    List<T> bulkDeleteByDocPrimaryKey(List<T> ts);

    /**
     * bulk delete
     * @param ts doc集合
     * @param listener 自定义监听类
     * @return
     */
    List<T> bulkDeleteByDocPrimaryKey(List<T> ts, BulkProcessor.Listener listener);

    /**
     * scroll 查询
     * @param var1 查询条件
     * @return
     */
    List<T> scrollSearch(QueryBuilder var1);

    /**
     * scroll 查询
     * @param var1 查询条件
     * @param callBack 自定义的原始数据处理回调函数
     * @return
     */
    List<T> scrollSearch(QueryBuilder var1, ScrollDataCallBack callBack);

    <E extends BaseDto> List<T> bulkDelete(List<E> ts);
    /**
     * 根据单个dto bulk delete
     * @param e
     * @param <E>
     * @return
     */
    <E extends BaseDto> List<T> bulkDelete(E e);

    /**
     * 根据dto更新，
     * @param e dto
     * @param script 更新内容
     * @param <E>
     * @return
     */
    <E extends BaseDto> Long updateByQueryRequest(E e, Script script);

    /**
     * 根据boolQueryBuilder更新，
     * @param boolQueryBuilder boolQueryBuilder
     * @param script 更新内容
     * @return
     */
    Long updateByQueryRequest(QueryBuilder boolQueryBuilder, Script script);
    /**
     * 根据dto删除，逻辑删除
     * @param e dto
     * @param <E>
     * @return
     */
    <E extends BaseDto> Long deleteByQueryRequest(E e);

    /**
     * 根据boolQueryBuilders删除，逻辑删除
     * @param boolQueryBuilder boolQueryBuilder
     * @return
     */
    Long deleteByQueryRequest(QueryBuilder boolQueryBuilder);

}


import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.collections4.IterableUtils;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.action.bulk.BulkProcessor;
import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.search.ClearScrollRequest;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.Client;
import org.elasticsearch.common.unit.ByteSizeUnit;
import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.reindex.UpdateByQueryAction;
import org.elasticsearch.index.reindex.UpdateByQueryRequestBuilder;
import org.elasticsearch.script.Script;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.sort.SortOrder;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.core.ElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.mapping.ElasticsearchPersistentProperty;
import org.springframework.data.elasticsearch.core.query.IndexQuery;
import org.springframework.data.elasticsearch.core.query.IndexQueryBuilder;
import org.springframework.data.elasticsearch.core.query.SearchQuery;
import org.springframework.data.elasticsearch.core.query.UpdateQueryBuilder;
import org.springframework.data.mapping.MappingException;
import org.springframework.stereotype.Component;
import org.springframework.util.Assert;

import java.io.IOException;
import java.lang.reflect.ParameterizedType;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;

/**
 * 用es template操作的抽象类，提供了大部分常用功能
 * @author yyt
 * @param <T>
 */
@Slf4j
@Component
public abstract class EsAbstractTemplateService<T extends BaseDoc> implements EsTemplateBaseService<T>, InitializingBean {
    @Autowired
    private ElasticsearchTemplate elasticsearchTemplate;
    private BulkProcessor bulkProcessor;
    private Client client;

    private String indexName;
    private String typeName;

    /**
     * T的主键，注解为@Id的属性
     */
    private ElasticsearchPersistentProperty idProperty;

    private Class<T> Tcls;
    private int batchSize = 1000;

    /**
     * 新增或者修改
     * 新增的话会将id设置到doc的@id字段中
     * @param t
     * @return
     */
    @Override
    public T saveOrUpdate(T t){
        //保存前逻辑处理
        prepareSave(t);
        String id=findIdValue(t);
        if(StringUtils.isNotBlank(id)){
            UpdateRequest updateRequest = new UpdateRequest();
            updateRequest.doc(JSON.toJSONString(t),XContentType.JSON);
            UpdateQueryBuilder updateQuery = new UpdateQueryBuilder()
                    .withIndexName(getIndexName()).withType(getTypeName())
                    .withId(id)
                    .withUpdateRequest(updateRequest);
            elasticsearchTemplate.update(updateQuery.build());
        }else{
            IndexQuery indexQuery= new IndexQueryBuilder().withIndexName(getIndexName()).withType(getTypeName())
                    .withObject(t)
                    .build();

            elasticsearchTemplate.index(indexQuery);
        }

        return t;
    }

    /**
     * 根据主键id删除。不用bulk，直接DeleteRequest
     * @param id
     * @return
     */
    @Override
    public T delete(String id){
        if(StringUtils.isNotBlank(id)){
            bulkDeleteByPrimaryKey(this.bulkProcessor,indexName, typeName, id);
        }
        return null;
    }

    /**
     * 根据query scroll全量查询
     * @param var1
     * @return
     */
    @Override
    public Iterable<T> search(QueryBuilder var1){
        return scrollSearch(var1);
    }

    /**
     * 根据dto分页查询，由于之前业务限制，不能使用scroll分页。
     * @param dto
     * @param <E>
     * @return
     */
    @Override
    public <E extends BaseDto> Map<String,Object> searchByPage(E dto){
        QueryBuilder qbs=getQueryBuilderByDto(dto);
        SearchQuery sq=buildCommonPageSearch(qbs,dto);
        /*Page<T> rep= elasticsearchTemplate.startScroll(3000,sq,Tcls);*/
        Page<T> rep = elasticsearchTemplate.queryForPage(sq,Tcls);
        Map<String,Object> rem=new HashMap<>(2);

        rem.put("total",rep.getTotalElements());
        rem.put("data",rep.getContent());

        /*elasticsearchTemplate.clearScroll(((ScrolledPage)rep).getScrollId());*/
        return rem;
    }

    /**
     * 根据dto全量scroll搜索
     * @param t
     * @param <E>
     * @return
     */
    @Override
    public <E extends BaseDto> Iterable<T> search(E t){
        QueryBuilder qbs=getQueryBuilderByDto(t);
        return scrollSearch(qbs);
    }

    protected <E extends BaseDto> QueryBuilder getQueryBuilderByDto(E t){
        QueryBuilder qbs=buildCommonQuery(t);

        buildOwnQuery(qbs,t);
        return qbs;
    }

    /**
     * 根据业务主键判断是否已经有业务数据，有的话则填充es的id
     * @param s
     */
    protected abstract void prepareSave(T s);

    /**
     * 自己的分页查询,自己实现
     * @param query
     * @return
     */
    /*protected abstract Page<T> ownPageSearch(SearchQuery query);*/

    /**
     * 默认初始化
     */
    /*protected IiapAbstractTemplateDocService(){
        init();
    }*/
    /**
     * 由子类确定es-template并初始化
     */
    /*@Autowired
    protected IiapAbstractTemplateDocService(ElasticsearchTemplate elasticsearchTemplate){
        this.elasticsearchTemplate=elasticsearchTemplate;
        init();
    }*/

    @Override
    public List<T> scrollSearch(QueryBuilder queryBuilder, ScrollDataCallBack callBack){
        List<T> result=new ArrayList();
        SearchRequestBuilder search = client.prepareSearch(indexName).setTypes(typeName);
        search.addSort("_doc", SortOrder.ASC);
        // 批量读取条数
        search.setSize(batchSize);

        search.setQuery(queryBuilder);
        // 设置search context 快照维护20sec有效期
        search.setScroll(TimeValue.timeValueSeconds(20));
        // 获得首次查询结果
        SearchResponse scrollResp = search.get();
        Long totalHits=scrollResp.getHits().getTotalHits();


        log.debug("scroll query count " + totalHits);
        if(totalHits>0){
            int count = 1;
            do {
                log.debug("scroll query times: " + count);
                List<Map<String, Object>> subResult= readHits(scrollResp.getHits().getHits());
                if(callBack!=null){
                    callBack.handleData(subResult);
                }
                addAllSub(result,subResult);
                count++;
                scrollResp = client.prepareSearchScroll(scrollResp.getScrollId())
                        .setScroll(TimeValue.timeValueSeconds(20))
                        .execute().actionGet();
            } while (scrollResp.getHits().getHits().length != 0);
        }

        // 清除
        ClearScrollRequest scrollRequest = new ClearScrollRequest();
        scrollRequest.addScrollId(scrollResp.getScrollId());
        client.clearScroll(scrollRequest);
        return result;
    }


    @Override
    public List<T> scrollSearch(QueryBuilder queryBuilder){
        return scrollSearch(queryBuilder,null);
    }

    /**
     * 将es返回的默认结构解析并放入result
     * 个性化的doc需要子类重写
     * @param result
     * @param subResult
     */
    protected void addAllSub(List<T> result, List<Map<String, Object>> subResult) {
        if(CollectionUtils.isEmpty(subResult)){
            return;
        }
        subResult.forEach(e->{
            T t=JSONObject.parseObject(JSONObject.toJSONString(e),Tcls);
            putIdValue(t,(String) e.get("_idValue"));
            result.add(t);
        });
    }


    private List<Map<String, Object>> readHits(SearchHit[] searchHits){
        List<Map<String, Object>> list = new ArrayList<>();
        for (SearchHit hit: searchHits){
            Map<String, Object> map = hit.getSource();
            map.put("_idValue", hit.getId());
            list.add(map);
        }
        return list;
    }

    private BulkProcessor buildBulkProcessor(BulkProcessor.Listener listener){
       return BulkProcessor.builder(this.client, listener)
               // 每n个action flush一次
                .setBulkActions(getBatchSize())
               // bulk数据每达到nMB flush一次
                .setBulkSize(new ByteSizeValue(4, ByteSizeUnit.MB))
                .setConcurrentRequests(0)
                .setFlushInterval(TimeValue.timeValueSeconds(3))
                .build();
    }

    /**
     * bulk新增或者修改
     * @param ts
     * @return
     */
    @Override
    public List<T> bulkSaveOrUpdate(List<T> ts){
        if(CollectionUtils.isNotEmpty(ts)){
            ts.forEach(e->{
                prepareSave(e);
                bulkSaveOrUpdate(this.bulkProcessor,indexName, typeName, e);
            });
        }
        return ts;
    }

    /**
     * bulk新增或者修改
     * @param ts
     * @param listener 自定义的监听器
     * @return
     */
    @Override
    public List<T> bulkSaveOrUpdate(List<T> ts,BulkProcessor.Listener listener){
        BulkProcessor own=buildBulkProcessor(listener);
        if(CollectionUtils.isNotEmpty(ts)){
            ts.forEach(e->{
                bulkSaveOrUpdate(own,indexName, typeName, e);
            });
        }
        return ts;
    }
    /**
     * bulk删除
     * @param ts
     * @param listener 自定义的监听器
     * @return
     */
    @Override
    public List<T> bulkDeleteByDocPrimaryKey(List<T> ts,BulkProcessor.Listener listener){
        BulkProcessor own=buildBulkProcessor(listener);
        if(CollectionUtils.isNotEmpty(ts)){
            ts.forEach(e->{
                bulkDeleteByPrimaryKey(own,indexName, typeName, findIdValue(e));
            });
        }
        return ts;
    }

    /**
     * 按照es的主键id删除
     * @param ts
     * @return
     */
    @Override
    public List<T> bulkDeleteByDocPrimaryKey(List<T> ts){
        if(CollectionUtils.isNotEmpty(ts)){
            ts.forEach(e->{
                bulkDeleteByPrimaryKey(this.bulkProcessor,indexName, typeName, findIdValue(e));
            });
        }
        return ts;
    }

    /**
     * 按照doc里的属性来删除
     * @param ts
     * @return
     */
    @Override
    public <E extends BaseDto> List<T> bulkDelete(List<E> ts){
        List<T> rs=new ArrayList<>();
        if(CollectionUtils.isNotEmpty(ts)){
            ts.forEach(e->{
                Iterable<T> es= search(e);
                if(!IterableUtils.isEmpty(es)){
                    es.forEach(t->{
                        rs.add(t);
                        bulkDeleteByPrimaryKey(this.bulkProcessor,indexName, typeName, findIdValue(t));
                    });
                }
            });
        }
        return rs;
    }

    /**
     * 根据单个dto bulk delete
     * @param e
     * @param <E>
     * @return
     */
    @Override
    public <E extends BaseDto> List<T> bulkDelete(E e){
        List<E> list=new ArrayList<>();
        list.add(e);
        return bulkDelete(list);
    }

    /**
     * bulk 新增或者修改
     * @param ownbulkProcessor bulk processor
     * @param indexName
     * @param typeName
     * @param obj
     */
    private void bulkSaveOrUpdate(BulkProcessor ownbulkProcessor,String indexName, String typeName, T obj){
        String id=findIdValue(obj);
        if(StringUtils.isNotBlank(id)){
            UpdateRequest indexRequest = new UpdateRequest()
                    .index(indexName)
                    .type(typeName).id(id)
                    .doc(JSON.toJSONString(obj), XContentType.JSON);
            ownbulkProcessor.add(indexRequest);
        }else{
            IndexRequest indexRequest = new IndexRequest()
                    .index(indexName)
                    .type(typeName)
                    .source(JSON.toJSONString(obj), XContentType.JSON);
            ownbulkProcessor.add(indexRequest);
        }
    }

    /**
     * 根据主键bulk删除
     * @param ownbulkProcessor
     * @param indexName
     * @param typeName
     * @param id es的主键id
     */
    private void bulkDeleteByPrimaryKey(BulkProcessor ownbulkProcessor,String indexName, String typeName, String id){
        if(StringUtils.isNotBlank(id)){
            /*DeleteRequest indexRequest = new DeleteRequest()
                    .index(indexName)
                    .type(typeName).id(id);
            ownbulkProcessor.add(indexRequest);*/
            UpdateRequest updateRequest= null;
            try {
                updateRequest = new UpdateRequest().index(indexName).type(typeName).id(id).doc(jsonBuilder().startObject()
                        // 对没有的字段添加, 对已有的字段替换
                        .field("deleted", BaseConstant.FILED_DELETED).endObject());
                ownbulkProcessor.add(updateRequest);
            } catch (IOException e) {
                log.error("bulkDeleteByPrimaryKey jsonBuilder error:{}-{}-{}",indexName,typeName,id);
                throw new CustomBusinessException(ErrorCodeUtils.CommonErrorCode.ERROR_SERVER_INTERNAL,"bulkDeleteByPrimaryKey jsonBuilder error");
            }
        }
    }

    @Override
    public <E extends BaseDto> Long updateByQueryRequest(E e, Script script){
        QueryBuilder qbs=getQueryBuilderByDto(e);
        return updateByQueryRequest(qbs,script);
    }

    @Override
    public Long updateByQueryRequest(QueryBuilder queryBuilder, Script script){
        Long count=doCount(queryBuilder);
        if(count==0){
            return 0L;
        }

        UpdateByQueryRequestBuilder updateByQuery = UpdateByQueryAction.INSTANCE.newRequestBuilder(client)
                //为了防止版本冲突导致updateByQuery中止，设置终止冲突为（false）
                .abortOnVersionConflict(false);
        updateByQuery.source(getIndexName())
                .filter(queryBuilder)
                .size(count.intValue())
                .script(script);
        long updated = updateByQuery.get().getUpdated();
        log.debug("update success:{}-{}",queryBuilder,updated);
        return updated;
    }

    private Long doCount(QueryBuilder queryBuilder){
        SearchRequestBuilder countRequestBuilder = this.client.prepareSearch(getIndexName());
        countRequestBuilder.setSize(0);
        countRequestBuilder.setQuery(queryBuilder);
        return (countRequestBuilder.execute().actionGet()).getHits().getTotalHits();
    }

    @Override
    public <E extends BaseDto> Long deleteByQueryRequest(E e){
        QueryBuilder qbs=getQueryBuilderByDto(e);
        Script script= new Script("ctx._source.deleted = '"+BaseConstant.FILED_DELETED+"'" +
                ";ctx._source.updatedTime='"+System.currentTimeMillis()+"'");
        return updateByQueryRequest(qbs,script);
    }

    @Override
    public Long deleteByQueryRequest(QueryBuilder queryBuilder){
        Script script= new Script("ctx._source.deleted = '"+BaseConstant.FILED_DELETED+"'" +
                ";ctx._source.updatedTime='"+System.currentTimeMillis()+"'");
        return updateByQueryRequest(queryBuilder,script);
    }

    protected void setIndexName(String writeIndexName){
        this.indexName=writeIndexName;
    }

    protected void setTypeName(String typeName){
        this.typeName=typeName;
    }

    @Override
    public String getIndexName(){
        return this.indexName;
    }
    @Override
    public String getTypeName(){
        return this.typeName;
    }

    @Override
    public void afterPropertiesSet() throws Exception{
        init();
    }

    /**
     * 确定bulkProcess index、 client,idProperty
     */
    protected void init(){
        this.client=this.elasticsearchTemplate.getClient();
        this.bulkProcessor = buildBulkProcessor(new BulkProcessor.Listener(){
            @Override
            public void beforeBulk(long l, BulkRequest bulkRequest) {
            }

            @Override
            public void afterBulk(long l, BulkRequest bulkRequest, Throwable throwable) {
                log.error(" bulk insert_error : {}", throwable);
            }

            @Override
            public void afterBulk(long l, BulkRequest bulkRequest, BulkResponse bulkResponse) {
                log.debug(" bulk insert success  size: {}",bulkRequest.numberOfActions());
            }
        });

        //根据泛型获取默认的index和type
        this.Tcls=(Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
        Assert.isTrue(Tcls.isAnnotationPresent(Document.class), "Unable to identify index name. " + Tcls.getSimpleName() + " is not a Document. Make sure the document class is annotated with @Document(indexName=\"foo\")");
        Document document = this.Tcls.getAnnotation(Document.class);
        setIndexName(document.indexName());
        setTypeName(document.type());
        this.idProperty= (ElasticsearchPersistentProperty)elasticsearchTemplate.getPersistentEntityFor(Tcls).getIdProperty();
        if(idProperty == null || !idProperty.getType().isAssignableFrom(String.class)){
            throw new MappingException(String.format("Couldn't find idProperty for type %s!", Tcls.getSimpleName()));
        }
    }

    /**
     * 获取T的主键的值
     * @return
     */
    protected String findIdValue(T t){
        return (String) elasticsearchTemplate.getPersistentEntityFor(Tcls).getPropertyAccessor(t).getProperty(idProperty);
    }

    /**
     * 设置主键的值
     * @param t
     * @param id
     */
    protected void putIdValue(T t,String id){
        elasticsearchTemplate.getPersistentEntityFor(Tcls).getPropertyAccessor(t).setProperty(idProperty,id);
    }

    /**
     * 获取批处理批次数
     * @return
     */
    protected int getBatchSize(){
        return this.batchSize;
    }
}

原文作者：styytNOTstop

原文链接：https://styyt.github.io/2020/02/29/spring-data-es%E6%8A%BD%E8%B1%A1service%E9%9B%86%E6%88%90%E7%AE%80%E5%8D%95%E5%A2%9E%E5%88%A0%E6%9F%A5%E6%94%B9%E4%B8%89/

发表日期：February 29th 2020, 10:45:21 am

更新日期：April 26th 2020, 6:34:38 pm

版权声明：本文采用知识共享署名-非商业性使用 4.0 国际许可协议进行许可

• Next Post
  spring-data-es抽象service集成简单增删查改之四
• Previous Post
  spring-data-es抽象service集成简单增删查改之二

Powered by Hexotheme Archer

PV: :)

CATALOG

1. 1. 写在前面
2. 2. 代码



• Archive
• Tag
• Cate

Total : 84

2021

• 02/28快速切换服务bean配置或依赖的简单框架实现样例
• 02/13基础向-从三元运算符和字节码看java包装类的坑
• 02/06总结es的一些规范
• 01/23深入探讨innodb中exists、in、join查询之间的区别和使用场景
• 01/09快速在linux排查java中cpu飙升线程或代码位置的方法
• 01/02clickHouse中的采样浅谈

2020

• 12/26在mac的clion中快速调试openjdk
• 12/12flink中function注意事项
• 12/01mysql诡异死锁系列二之高并发删除下的死锁二
• 11/27mysql诡异死锁系列二之高并发删除下的死锁一
• 11/22es模糊搜索的注意点
• 11/08hbase倒叙scan可能会遇到的坑
• 10/24es嵌套查询的小误区
• 10/17mysql诡异的死锁问题排查及分析全过程记录四之分析
• 10/07mysql诡异的死锁问题排查及分析全过程记录三之重现
• 10/02mysql诡异的死锁问题排查及分析全过程记录二之RR的锁
• 09/27mysql诡异的死锁问题排查及分析全过程记录一之概述
• 09/05openjdk源码浅析之jni_registerNatives二
• 08/30openjdk源码浅析之jni_registerNatives
• 08/29habse中使用shell模相关命令
• 08/23hikari中用到的SPI思想
• 08/15mac下xcode调试openJDK
• 08/09mac下编译openjdk14u36
• 08/01SPI是否破坏了双亲委派？
• 07/26通过字节码简单解析i++和++i的区别
• 07/12class文件简单解析之二
• 07/05class文件简单解析
• 06/28自己写基于注解的参数级统一数据权限组件
• 06/20自己写基于注解的参数级统一数据权限组件
• 06/14解析springBean类的注解引发的一系列如AOP|cglib代理等问题四
• 06/07解析springBean类的注解引发的一系列如AOP|cglib代理等问题三
• 05/25解析springBean类的注解引发的一系列如AOP|cglib代理等问题二
• 05/24解析springBean类的注解引发的一系列如AOP|cglib代理等问题一
• 05/15自己封装模拟json全路径获取某个对象下某个变量的工具类
• 05/01macOS常用命令记录
• 04/19spring-data-elasticsearch-组件查询的bug跟踪
• 04/05canal使用中的陷阱用法
• 03/29关于Locale和ResourceBundle踩的坑
• 03/21高并发下使用java更新es同一条记录的问题及解决方案探索二
• 03/14高并发下使用java更新es同一条记录的问题及解决方案探索一
• 03/07spring-data-es抽象service集成简单增删查改之四
• 02/29spring-data-es抽象service集成简单增删查改之三
• 02/22spring-data-es抽象service集成简单增删查改之二
• 02/16spring-data-es抽象service集成简单增删查改之一
• 02/08FeignRequestInterceptor示例
• 02/02es修改索引中mapping的类型
• 01/25idea之CommandLineIsTooLong问题解决
• 01/18通过一次cannal监听问题浅读spring-data源码及其在es中的应用二
• 01/12通过一次cannal监听问题浅读spring-data源码及其在es中的应用一
• 01/05es的模糊搜索

2019

• 12/28windows编译openJDK之c编译器找不到解决
• 12/21windows编译openJdk之二-freeType+VS+jdk
• 12/13windows编译openJdk之一-CYGWIN
• 12/07java的okhttp再封装
• 11/30lambda中的受检查异常
• 11/23Springboot test
• 11/16zuul转发请求后前缀问题
• 11/09mybatis_plus_generator with DDD
• 11/02SpringBoot启动报Failed to retrieve application JMX service URL
• 10/26再从volatile第二个特性看JVM内存模型(JMM)
• 10/16从volatile第一个特性看JVM内存模型(JMM)
• 10/07再度浅析jvm的四种垃圾收集器
• 09/28浅论战术编程tactical programming与战略编程strategic programming
• 09/20NIO之SocketChannel小实践-聊天程序mini版
• 09/16Thread.join会释放锁吗?释放的是什么锁?会死锁吗?
• 09/14浅析升级jdk8对jvm/GC（HotSpot）的影响
• 09/01mybatis-spring的mapper注入方式浅谈
• 08/29hibernate自动更新的坑
• 08/28springBoot自定义Controller的路径
• 08/27hive对表的增删改
• 08/23ThreadLocal内的小秘密-巧妙降低内存泄露风险
• 08/15hive从csv导入数据
• 08/08hibernate4监听器的实现简单解析
• 08/06hive存储换行符等特殊字符
• 08/02tomcat,jetty,jboss跨域配置
• 07/25springMVC获取content-type为form-data类型的参数和值解析
• 07/14ElasticSearch笔记
• 06/24mybatis字符串比较
• 05/22mybatis占位符的区别
• 05/13ORA-01722 invalid number

2017

• 06/15js、java、mysql字符串那长度判断的不同
• 01/28sql排序+分页的小问题

2016

• 09/26ajax的traditional作用
• 09/09自己写一个mysql动态查询树形结构的存储过程

ElasticSearch Oracle feign mybatis_plus_generator nio socket 多线程 SpringBoot threadLocal 内存泄露 ajax es spring canal springMVC form_data 源码解读 hive hibernate 源码解析 hibernate4 设计模式 idea js java mysql ORACLE http lambda mybatis sql注入 字符串比较 codeImpression spring-data-elasticsearch elasticsearch springBoot Springboot oracle jetty jboss tomcat CORS sringboot volatile jvm zuul JVM JMM gc Locale ResourceBundle openJDK tree history macOS Spring 数据权限 动态代理 hbase SPI innodb事务 flink openjdk clickHouse innodb



缺失模块。
1、请确保node版本大于6.2
2、在博客根目录（注意不是archer根目录）执行以下命令：
npm i hexo-generator-json-content --save
3、在根目录_config.yml里添加配置：

jsonContent:
  meta: false
  pages: false
  posts:
    title: true
    date: true
    path: true
    text: false
    raw: false
    content: false
    slug: false
    updated: false
    comments: false
    link: false
    permalink: false
    excerpt: false
    categories: true
    tags: true

ElasticSearch springboot mybatis-plus-generator 多线程 SpringBoot springboot/feign threadLocal ajax es canal springMVC源码解读 hive hibernate idea ORACLE java lambda mybatis codeImpression spring elasticsearch springBoot Springboot mysql CORS跨域 jvm zuul JMM gc Locale openJDK gc/jvm macOS Spring hbase SPI flink openjdk clickHouse innodb

