SpringBoot 2.x 集成ElasticSearch6.x

朱雀 2023-10-10 10:37 214阅读 0赞

任务要求：SpringBoot集成ElasticSearch6.x ，并且封装相关功能.

核心pom.xml 文件:

  1. <parent>
  2.         <groupId>org.springframework.boot</groupId>
  3.         <artifactId>spring-boot-starter-parent</artifactId>
  4.         <version>2.1.1.RELEASE</version>
  5.     </parent>
  7.     <properties>
  8.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  9.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  10.         <java.version>1.8</java.version>
  11.         <mybatis-spring-boot-starter.version>1.3.2</mybatis-spring-boot-starter.version>
  12.         <mysql-connector-java.version>8.0.11</mysql-connector-java.version>
  13.         <com.alibaba.druid.version>1.1.9</com.alibaba.druid.version>
  14.         <commons-lang.version>2.6</commons-lang.version>
  15.         <commons-codec.version>1.10</commons-codec.version>
  16.         <commons-lang3.version>3.8.1</commons-lang3.version>
  17.         <commons-net.version>3.6</commons-net.version>
  18.         <commons-io.version>2.6</commons-io.version>
  19.         <commons-collections.version>3.2.1</commons-collections.version>
  20.         <common-fileupload.version>1.3.1</common-fileupload.version>
  21.         <fastjson.version>1.2.48</fastjson.version>
  22.         <jasperreports.version>6.10.0</jasperreports.version>
  23.     </properties>
  26.     <dependencies>
  27.         <!-- SpringWeb模块 -->
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-web</artifactId>
  31.             <!-- 移除springboot 自带日志框架log-back  -->
  32.              <exclusions>
  33.                 <exclusion>
  34.                     <groupId>org.springframework.boot</groupId>
  35.                     <artifactId>spring-boot-starter-logging</artifactId>
  36.                 </exclusion>
  37.             </exclusions>
  38.         </dependency>
  40.         <!--springboot 集成测试框架 -->
  41.         <dependency>
  42.             <groupId>org.springframework.boot</groupId>
  43.             <artifactId>spring-boot-starter-test</artifactId>
  44.             <scope>test</scope>
  45.         </dependency>
  48.         <!--lombok插件 -->
  49.         <dependency>
  50.             <groupId>org.projectlombok</groupId>
  51.             <artifactId>lombok</artifactId>
  52.             <version>${lombok.version}</version>
  53.             <scope>provided</scope>
  54.         </dependency>
  57.         <!-- mysql 连接 -->
  58.         <dependency>
  59.             <groupId>org.mybatis.spring.boot</groupId>
  60.             <artifactId>mybatis-spring-boot-starter</artifactId>
  61.             <version>${mybatis-spring-boot-starter.version}</version>
  62.         </dependency>
  63.         <dependency>
  64.             <groupId>mysql</groupId>
  65.             <artifactId>mysql-connector-java</artifactId>
  66.             <version>${mysql-connector-java.version}</version>
  67.             <scope>runtime</scope>
  68.         </dependency>
  69.         <dependency>
  70.             <groupId>com.alibaba</groupId>
  71.             <artifactId>druid-spring-boot-starter</artifactId>
  72.             <version>${com.alibaba.druid.version}</version>
  73.         </dependency>
  74.         <!-- 分页控件 -->
  75.         <dependency>
  76.             <groupId>com.github.pagehelper</groupId>
  77.             <artifactId>pagehelper</artifactId>
  78.             <version>4.1.6</version>
  79.         </dependency>
  81.         <!--common-lang 常用工具包 -->
  82.         <dependency>
  83.             <groupId>commons-lang</groupId>
  84.             <artifactId>commons-lang</artifactId>
  85.             <version>${commons-lang.version}</version>
  86.         </dependency>
  87.         <!--commons-lang3 工具包 -->
  88.         <dependency>
  89.             <groupId>org.apache.commons</groupId>
  90.             <artifactId>commons-lang3</artifactId>
  91.             <version>${commons-lang3.version}</version>
  92.         </dependency>
  94.         <!--commons-codec 加密工具包 -->
  95.         <dependency>
  96.             <groupId>commons-codec</groupId>
  97.             <artifactId>commons-codec</artifactId>
  98.             <version>${commons-codec.version}</version>
  99.         </dependency>
  100.         <!--commons-net 网络工具包 -->
  101.         <dependency>
  102.             <groupId>commons-net</groupId>
  103.             <artifactId>commons-net</artifactId>
  104.             <version>${commons-net.version}</version>
  105.         </dependency>
  106.         <!--common-io 工具包 -->
  107.         <dependency>
  108.             <groupId>commons-io</groupId>
  109.             <artifactId>commons-io</artifactId>
  110.             <version>${commons-io.version}</version>
  111.         </dependency>
  112.         <!--common-collection 工具包 -->
  113.         <dependency>
  114.             <groupId>commons-collections</groupId>
  115.             <artifactId>commons-collections</artifactId>
  116.             <version>${commons-collections.version}</version>
  117.         </dependency>
  118.         <!--common-fileupload 工具包 -->
  119.         <dependency>
  120.             <groupId>commons-fileupload</groupId>
  121.             <artifactId>commons-fileupload</artifactId>
  122.             <version>${common-fileupload.version}</version>
  123.         </dependency>
  125.         <!-- Swagger2 -->
  126.         <dependency>
  127.             <groupId>io.springfox</groupId>
  128.             <artifactId>springfox-swagger2</artifactId>
  129.             <version>2.7.0</version>
  130.         </dependency>
  131.         <dependency>
  132.             <groupId>io.springfox</groupId>
  133.             <artifactId>springfox-swagger-ui</artifactId>
  134.             <version>2.7.0</version>
  135.         </dependency>
  137.         <!-- fastjson -->
  138.         <dependency>
  139.             <groupId>com.alibaba</groupId>
  140.             <artifactId>fastjson</artifactId>
  141.             <version>${fastjson.version}</version>
  142.         </dependency>
  144.         <!-- 集成elasticsearch 框架 -->
  145.         <dependency>
  146.             <groupId>org.springframework.boot</groupId>
  147.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  148.         </dependency>

配置类：

  1. package com.zzg.search.config;
  3. import java.util.HashMap;
  4. import java.util.Map;
  6. import org.springframework.boot.web.servlet.FilterRegistrationBean;
  7. import org.springframework.boot.web.servlet.ServletRegistrationBean;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.context.annotation.Configuration;
  11. import com.alibaba.druid.support.http.StatViewServlet;
  12. import com.alibaba.druid.support.http.WebStatFilter;
  13. /**
  14.  * druid 监控配置
  15.  * @author zzg
  16.  *
  17.  */
  18. @Configuration
  19. public class DruidConfig {
  20.          @Bean
  21.         public ServletRegistrationBean druidServletRegistrationBean() {
  22.             ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean();
  23.             servletRegistrationBean.setServlet(new StatViewServlet());
  24.             servletRegistrationBean.addUrlMappings("/druid/*");
  25.             servletRegistrationBean.addInitParameter("allow", "");
  26.             servletRegistrationBean.addInitParameter("deny", "");
  27.             servletRegistrationBean.addInitParameter("loginUsername", "admin");
  28.             servletRegistrationBean.addInitParameter("loginPassword", "admin");
  29.             return servletRegistrationBean;
  30.         }
  32.         /**
  33.          * 注册DruidFilter拦截
  34.          *
  35.          * @return
  36.          */
  37.         @Bean
  38.         public FilterRegistrationBean duridFilterRegistrationBean() {
  39.             FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
  40.             filterRegistrationBean.setFilter(new WebStatFilter());
  41.             Map<String, String> initParams = new HashMap<String, String>();
  42.             //设置忽略请求
  43.             initParams.put("exclusions", "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*");
  44.             filterRegistrationBean.setInitParameters(initParams);
  45.             filterRegistrationBean.addUrlPatterns("/*");
  46.             return filterRegistrationBean;
  47.         }
  48. }
  50. package com.zzg.search.config;
  52. import java.util.Properties;
  54. import org.springframework.context.annotation.Bean;
  55. import org.springframework.context.annotation.Configuration;
  57. import com.github.pagehelper.PageHelper;
  59. /**
  60.  * mybatis 配置对象
  61.  * @author zzg
  62.  *
  63.  */
  64. @Configuration
  65. public class MyBatisConfig {
  66.     /**
  67.      * 分页对象实列化
  68.      * @return
  69.      */
  70.     @Bean
  71.     public PageHelper pageHelper() {
  72.         PageHelper pageHelper = new PageHelper();
  73.         Properties p = new Properties();
  74.         p.setProperty("offsetAsPageNum", "true");
  75.         p.setProperty("rowBoundsWithCount", "true");
  76.         p.setProperty("reasonable", "true");
  77.         p.setProperty("dialect", "mysql");
  78.         pageHelper.setProperties(p);
  79.         return pageHelper;
  80.     }
  81. }
  83. package com.zzg.search.config;
  85. import java.util.ArrayList;
  86. import java.util.List;
  88. import org.springframework.context.annotation.Bean;
  89. import org.springframework.context.annotation.Configuration;
  91. import io.swagger.annotations.ApiOperation;
  92. import springfox.documentation.builders.ApiInfoBuilder;
  93. import springfox.documentation.builders.ParameterBuilder;
  94. import springfox.documentation.builders.PathSelectors;
  95. import springfox.documentation.builders.RequestHandlerSelectors;
  96. import springfox.documentation.schema.ModelRef;
  97. import springfox.documentation.service.ApiInfo;
  98. import springfox.documentation.service.Contact;
  99. import springfox.documentation.service.Parameter;
  100. import springfox.documentation.spi.DocumentationType;
  101. import springfox.documentation.spring.web.plugins.Docket;
  102. import springfox.documentation.swagger2.annotations.EnableSwagger2;
  104. @Configuration
  105. @EnableSwagger2
  106. public class SwaggerConfig {
  107.     @Bean
  108.     public Docket buildDocket() {
  110.         ParameterBuilder tokenPar = new ParameterBuilder();
  111.         List<Parameter> pars = new ArrayList<Parameter>();
  112.         tokenPar.name("X-CSRF-TOKEN").description("令牌").modelRef(new ModelRef("string")).parameterType("header")
  113.                 .required(false).build();
  114.         pars.add(tokenPar.build());
  116.         return new Docket(DocumentationType.SWAGGER_2).select()
  117.                 .apis(RequestHandlerSelectors.withMethodAnnotation(ApiOperation.class)).paths(PathSelectors.any())
  118.                 .build().globalOperationParameters(pars).apiInfo(buildApiInf());
  119.     }
  121.     private ApiInfo buildApiInf() {
  122.         return new ApiInfoBuilder().title("****").termsOfServiceUrl("http://www.baidu.cn/")
  123.                 .description("API接口")
  124.                 .contact(new Contact("baidu", "http://www.baidu.cn/", "zhouzhiwengang@163.com"))
  125.                 .version("2.0").build();
  127.     }
  128. }

elasticsearch6.x 检索组件封装：

  1. package com.zzg.search.component;
  3. import java.net.InetAddress;
  4. import java.net.UnknownHostException;
  5. import java.util.ArrayList;
  6. import java.util.Iterator;
  7. import java.util.List;
  8. import java.util.Map;
  10. import org.apache.commons.collections.map.HashedMap;
  11. import org.apache.commons.lang.StringUtils;
  12. import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
  13. import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse;
  14. import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequest;
  15. import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse;
  16. import org.elasticsearch.action.bulk.BulkRequestBuilder;
  17. import org.elasticsearch.action.bulk.BulkResponse;
  18. import org.elasticsearch.action.delete.DeleteResponse;
  19. import org.elasticsearch.action.index.IndexResponse;
  20. import org.elasticsearch.action.search.SearchRequestBuilder;
  21. import org.elasticsearch.action.search.SearchResponse;
  22. import org.elasticsearch.action.update.UpdateRequest;
  23. import org.elasticsearch.client.transport.TransportClient;
  24. import org.elasticsearch.common.settings.Settings;
  25. import org.elasticsearch.common.transport.TransportAddress;
  26. import org.elasticsearch.index.query.QueryBuilders;
  27. import org.elasticsearch.search.SearchHit;
  28. import org.elasticsearch.search.SearchHits;
  29. import org.elasticsearch.search.aggregations.AggregationBuilder;
  30. import org.elasticsearch.search.aggregations.AggregationBuilders;
  31. import org.elasticsearch.search.aggregations.bucket.terms.Terms;
  32. import org.elasticsearch.search.aggregations.bucket.terms.Terms.Bucket;
  33. import org.elasticsearch.search.sort.SortOrder;
  34. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  35. import org.slf4j.Logger;
  36. import org.slf4j.LoggerFactory;
  37. import com.zzg.search.component.builder.impl.ESQueryProduce;
  38. import com.zzg.search.component.exception.ESFailedException;
  39. import com.zzg.search.component.exception.ESIndexException;
  41. /**
  42.  * ES 工具类
  43.  * @author zzg
  44.  *
  45.  */
  46. public class ESService {
  47.     //日志记录
  48.     private Logger logger = LoggerFactory.getLogger(ESService.class);
  50.     private final static int MAX = 10000;
  52.     TransportClient client;
  54.     public ESService(String clusterName, String ip, int port){
  55.         try {
  56.             Settings settings = Settings.builder()
  57.                     .put("cluster.name", clusterName).build();
  59.             this.client = new PreBuiltTransportClient(settings)
  60.                     .addTransportAddress(new TransportAddress(InetAddress.getByName(ip), port));
  61.         } catch (UnknownHostException e) {
  62.             logger.error(e.getMessage());
  63.             throw new ESFailedException("es init failed!", e);
  64.         }
  65.     }
  67.     /**
  68.      * 功能描述：新建索引
  69.      * @param indexName 索引名
  70.      */
  71.     public void createIndex(String indexName) {
  72.         client.admin().indices().create(new CreateIndexRequest(indexName))
  73.                 .actionGet();
  74.     }
  76.     /**
  77.      * 功能描述：新建索引
  78.      * @param index 索引名
  79.      * @param type 类型
  80.      */
  81.     public void createIndex(String index, String type) {
  82.         client.prepareIndex(index, type).setSource().get();
  83.     }
  85.     /**
  86.      * 功能描述：删除索引
  87.      * @param index 索引名
  88.      */
  89.     public void deleteIndex(String index) {
  90.         if (indexExist(index)) {
  91.             DeleteIndexResponse dResponse = client.admin().indices().prepareDelete(index)
  92.                     .execute().actionGet();
  93.             if (!dResponse.isAcknowledged()) {
  94.                 throw new ESIndexException("failed to delete index.");
  95.             }
  96.         } else {
  97.             throw new ESIndexException("index name not exists");
  98.         }
  99.     }
  101.     /**
  102.      * 功能描述：验证索引是否存在
  103.      * @param index 索引名
  104.      */
  105.     public boolean indexExist(String index) {
  106.         IndicesExistsRequest inExistsRequest = new IndicesExistsRequest(index);
  107.         IndicesExistsResponse inExistsResponse = client.admin().indices()
  108.                 .exists(inExistsRequest).actionGet();
  109.         return inExistsResponse.isExists();
  110.     }
  112.     /**
  113.      * 功能描述：插入数据
  114.      * @param index 索引名
  115.      * @param type 类型
  116.      * @param json 数据
  117.      */
  118.     public void insertData(String index, String type, String json) {
  119.         IndexResponse response = client.prepareIndex(index, type)
  120.                 .setSource(json)
  121.                 .get();
  122.     }
  124.     /**
  125.      * 功能描述：插入数据
  126.      * @param index 索引名
  127.      * @param type 类型
  128.      * @param _id 数据id
  129.      * @param json 数据
  130.      */
  131.     public void insertData(String index, String type, String _id, String json) {
  132.         IndexResponse response = client.prepareIndex(index, type).setId(_id)
  133.                 .setSource(json)
  134.                 .get();
  135.     }
  137.     /**
  138.      * 功能描述：更新数据
  139.      * @param index 索引名
  140.      * @param type 类型
  141.      * @param _id 数据id
  142.      * @param json 数据
  143.      */
  144.     public void updateData(String index, String type, String _id, String json) throws Exception {
  145.         try {
  146.             UpdateRequest updateRequest = new UpdateRequest(index, type, _id)
  147.                     .doc(json);
  148.             client.update(updateRequest).get();
  149.         } catch (Exception e) {
  150.             logger.error(e.getMessage());
  151.             throw new ESIndexException("update data failed.", e);
  152.         }
  153.     }
  155.     /**
  156.      * 功能描述：删除数据
  157.      * @param index 索引名
  158.      * @param type 类型
  159.      * @param _id 数据id
  160.      */
  161.     public void deleteData(String index, String type, String _id) {
  162.         DeleteResponse response = client.prepareDelete(index, type, _id)
  163.                 .get();
  164.     }
  166.     /**
  167.      * 功能描述：批量插入数据
  168.      * @param index 索引名
  169.      * @param type 类型
  170.      * @param data (_id 主键, json 数据)
  171.      */
  172.     public void bulkInsertData(String index, String type, Map<String, String> data) {
  173.         BulkRequestBuilder bulkRequest = client.prepareBulk();
  174.         data.forEach((param1, param2) -> {
  175.             bulkRequest.add(client.prepareIndex(index, type, param1)
  176.                     .setSource(param2)
  177.             );
  178.         });
  179.         BulkResponse bulkResponse = bulkRequest.get();
  180.     }
  182.     /**
  183.      * 功能描述：批量插入数据
  184.      * @param index 索引名
  185.      * @param type 类型
  186.      * @param jsonList 批量数据
  187.      */
  188.     public void bulkInsertData(String index, String type, List<String> jsonList) {
  189.         BulkRequestBuilder bulkRequest = client.prepareBulk();
  190.         jsonList.forEach(item -> {
  191.             bulkRequest.add(client.prepareIndex(index, type)
  192.                     .setSource(item)
  193.             );
  194.         });
  195.         BulkResponse bulkResponse = bulkRequest.get();
  196.     }
  198.     /**
  199.      * 功能描述：查询
  200.      * @param index 索引名
  201.      * @param type 类型
  202.      * @param constructor 查询构造
  203.      */
  204.     public List<Map<String, Object>> search(String index, String type, ESQueryProduce constructor) {
  205.         List<Map<String, Object>> result = new ArrayList<>();
  206.         SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index).setTypes(type);
  207.         //排序
  208.         if (StringUtils.isNotEmpty(constructor.getAsc()))
  209.             searchRequestBuilder.addSort(constructor.getAsc(), SortOrder.ASC);
  210.         if (StringUtils.isNotEmpty(constructor.getDesc()))
  211.             searchRequestBuilder.addSort(constructor.getDesc(), SortOrder.DESC);
  212.         //设置查询体
  213.         searchRequestBuilder.setQuery(constructor.getBoolQueryBuilder());
  214.         //返回条目数
  215.         int size = constructor.getSize();
  216.         if (size < 0) {
  217.             size = 0;
  218.         }
  219.         if (size > MAX) {
  220.             size = MAX;
  221.         }
  222.         //返回条目数
  223.         searchRequestBuilder.setSize(size);
  225.         searchRequestBuilder.setFrom(constructor.getFrom() < 0 ? 0 : constructor.getFrom());
  227.         SearchResponse searchResponse = searchRequestBuilder.execute().actionGet();
  229.         SearchHits hits = searchResponse.getHits();
  230.         SearchHit[] searchHists = hits.getHits();
  231.         for (SearchHit sh : searchHists) {
  232.             result.add(sh.getSourceAsMap());
  233.         }
  234.         return result;
  235.     }
  237.     /**
  238.      * 功能描述：统计查询
  239.      * @param index 索引名
  240.      * @param type 类型
  241.      * @param constructor 查询构造
  242.      * @param groupBy 统计字段
  243.      */
  244.     public Map<Object, Object> statSearch(String index, String type, ESQueryProduce constructor, String groupBy) {
  245.         Map<Object, Object> map = new HashedMap();
  246.         SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index).setTypes(type);
  247.         //排序
  248.         if (StringUtils.isNotEmpty(constructor.getAsc()))
  249.             searchRequestBuilder.addSort(constructor.getAsc(), SortOrder.ASC);
  250.         if (StringUtils.isNotEmpty(constructor.getDesc()))
  251.             searchRequestBuilder.addSort(constructor.getDesc(), SortOrder.DESC);
  252.         //设置查询体
  253.         if (null != constructor) {
  254.             searchRequestBuilder.setQuery(constructor.getBoolQueryBuilder());
  255.         } else {
  256.             searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
  257.         }
  258.         int size = constructor.getSize();
  259.         if (size < 0) {
  260.             size = 0;
  261.         }
  262.         if (size > MAX) {
  263.             size = MAX;
  264.         }
  265.         //返回条目数
  266.         searchRequestBuilder.setSize(size);
  268.         searchRequestBuilder.setFrom(constructor.getFrom() < 0 ? 0 : constructor.getFrom());
  269.         SearchResponse sr = searchRequestBuilder.addAggregation(
  270.                 AggregationBuilders.terms("agg").field(groupBy)
  271.         ).get();
  273.         Terms stateAgg = sr.getAggregations().get("agg");
  274.         Iterator<Terms.Bucket> iter = (Iterator<Bucket>) stateAgg.getBuckets().iterator();
  276.         while (iter.hasNext()) {
  277.             Terms.Bucket gradeBucket = iter.next();
  278.             map.put(gradeBucket.getKey(), gradeBucket.getDocCount());
  279.         }
  281.         return map;
  282.     }
  284.     /**
  285.      * 功能描述：统计查询
  286.      * @param index 索引名
  287.      * @param type 类型
  288.      * @param constructor 查询构造
  289.      * @param agg 自定义计算
  290.      */
  291.     public Map<Object, Object> statSearch(String index, String type, ESQueryProduce constructor, AggregationBuilder agg) {
  292.         if (agg == null) {
  293.             return null;
  294.         }
  295.         Map<Object, Object> map = new HashedMap();
  296.         SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index).setTypes(type);
  297.         //排序
  298.         if (StringUtils.isNotEmpty(constructor.getAsc()))
  299.             searchRequestBuilder.addSort(constructor.getAsc(), SortOrder.ASC);
  300.         if (StringUtils.isNotEmpty(constructor.getDesc()))
  301.             searchRequestBuilder.addSort(constructor.getDesc(), SortOrder.DESC);
  302.         //设置查询体
  303.         if (null != constructor) {
  304.             searchRequestBuilder.setQuery(constructor.getBoolQueryBuilder());
  305.         } else {
  306.             searchRequestBuilder.setQuery(QueryBuilders.matchAllQuery());
  307.         }
  308.         int size = constructor.getSize();
  309.         if (size < 0) {
  310.             size = 0;
  311.         }
  312.         if (size > MAX) {
  313.             size = MAX;
  314.         }
  315.         //返回条目数
  316.         searchRequestBuilder.setSize(size);
  318.         searchRequestBuilder.setFrom(constructor.getFrom() < 0 ? 0 : constructor.getFrom());
  319.         SearchResponse sr = searchRequestBuilder.addAggregation(
  320.                 agg
  321.         ).get();
  323.         Terms stateAgg = sr.getAggregations().get("agg");
  324.         Iterator<Terms.Bucket> iter = (Iterator<Bucket>) stateAgg.getBuckets().iterator();
  326.         while (iter.hasNext()) {
  327.             Terms.Bucket gradeBucket = iter.next();
  328.             map.put(gradeBucket.getKey(), gradeBucket.getDocCount());
  329.         }
  331.         return map;
  332.     }
  335.     /**
  336.      * 功能描述：关闭链接
  337.      */
  338.     public void close() {
  339.         client.close();
  340.     }
  343. }
  345. package com.zzg.search.component.builder;
  347. import org.elasticsearch.index.query.BoolQueryBuilder;
  349. /**
  350.  * es 查询构建工具类
  351.  * 
  352.  * @author zzg
  353.  *
  354.  */
  355. public interface IESQueryBuilders {
  356.     /**
  357.      * term 查询
  358.      * @param name
  359.      * @param valve
  360.      * @return
  361.      * @throws Exception
  362.      */
  363.     IESQueryBuilders termQuery(String name, String... values) throws Exception;
  365.     /**
  366.      * wildcard 查询
  367.      * @param name
  368.      * @param values
  369.      * @return
  370.      * @throws Exception
  371.      */
  372.     IESQueryBuilders wildcardQuery(String name, String... values) throws Exception;
  374.     /**
  375.      * rang 查询
  376.      * @param name
  377.      * @param from
  378.      * @param to
  379.      * @return
  380.      * @throws Exception
  381.      */
  382.     IESQueryBuilders rangeQuery(String name, String from, String to) throws Exception;
  384.     /**
  385.      * bool 查询
  386.      * @return
  387.      */
  388.     BoolQueryBuilder getBoolQueryBuilder();
  390. }
  392. package com.zzg.search.component.builder;
  394. import org.elasticsearch.index.query.BoolQueryBuilder;
  396. /**
  397.  * es 查询 生成类
  398.  * @author zzg
  399.  *
  400.  */
  401. public interface IESQueryProduce {
  405.     /**
  406.      * bool 查询
  407.      * @return
  408.      */
  409.     BoolQueryBuilder getBoolQueryBuilder();
  411.     /**
  412.      * es 生成核心方法
  413.      * @param esQueryBuilders
  414.      * @return
  415.      */
  416.     IESQueryProduce getProduct(IESQueryBuilders esQueryBuilders);
  418. }
  420. package com.zzg.search.component.builder.factory;
  422. import com.zzg.search.component.builder.IESQueryBuilders;
  423. import com.zzg.search.component.builder.model.ESQueryMode;
  425. public class ESQueryBuilderFactory {
  426.     public static IESQueryBuilders creatESQueryBuilder(ESQueryMode mode)
  427.             throws ClassNotFoundException, IllegalAccessException, InstantiationException {
  428.         Class<?> clazz = Class.forName(mode.mode());
  429.         return (IESQueryBuilders) clazz.newInstance();
  430.     }
  432. }
  434. package com.zzg.search.component.builder.impl;
  436. import org.elasticsearch.index.query.BoolQueryBuilder;
  437. import org.elasticsearch.index.query.QueryBuilders;
  438. import com.zzg.search.component.builder.IESQueryBuilders;
  440. public class ESFilter implements IESQueryBuilders {
  441.     private BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
  443.     @Override
  444.     public IESQueryBuilders termQuery(String name, String... values) throws Exception {
  445.         // TODO Auto-generated method stub
  446.         boolQueryBuilder.filter(QueryBuilders.termsQuery(name, values));
  447.         return this;
  449.     }
  451.     @Override
  452.     public IESQueryBuilders wildcardQuery(String name, String... values) throws Exception {
  453.         // TODO Auto-generated method stub
  454.          for (String value : values){
  455.                 boolQueryBuilder.filter(QueryBuilders.wildcardQuery(name, "*" + value + "*"));
  456.             }
  457.          return this;
  458.     }
  460.     @Override
  461.     public IESQueryBuilders rangeQuery(String name, String from, String to) throws Exception {
  462.         // TODO Auto-generated method stub
  463.         return null;
  464.     }
  466.     @Override
  467.     public BoolQueryBuilder getBoolQueryBuilder() {
  468.         // TODO Auto-generated method stub
  469.         return boolQueryBuilder;
  470.     }
  472. }
  474. package com.zzg.search.component.builder.impl;
  476. import org.elasticsearch.index.query.BoolQueryBuilder;
  477. import org.elasticsearch.index.query.QueryBuilders;
  479. import com.zzg.search.component.builder.IESQueryBuilders;
  482. public class ESMust implements IESQueryBuilders {
  484.     private BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
  486.     @Override
  487.     public IESQueryBuilders termQuery(String name, String... values) throws Exception {
  488.         // TODO Auto-generated method stub
  489.         boolQueryBuilder.must(QueryBuilders.termsQuery(name, values));
  490.         return this;
  491.     }
  493.     @Override
  494.     public IESQueryBuilders wildcardQuery(String name, String... values) throws Exception {
  495.         // TODO Auto-generated method stub
  496.         for (String value : values){
  497.             boolQueryBuilder.must(QueryBuilders.wildcardQuery(name, "*" + value + "*"));
  498.         }
  499.         return this;
  500.     }
  502.     @Override
  503.     public IESQueryBuilders rangeQuery(String name, String from, String to) throws Exception {
  504.         // TODO Auto-generated method stub
  505.          boolQueryBuilder.must(QueryBuilders.rangeQuery(name).from(from, true).to(to, true));
  506.             return this;
  507.     }
  509.     @Override
  510.     public BoolQueryBuilder getBoolQueryBuilder() {
  511.         // TODO Auto-generated method stub
  512.         return boolQueryBuilder;
  513.     }
  515. }
  517. package com.zzg.search.component.builder.impl;
  519. import org.elasticsearch.index.query.BoolQueryBuilder;
  520. import org.elasticsearch.index.query.QueryBuilders;
  522. import com.zzg.search.component.builder.IESQueryBuilders;
  524. public class ESMustNot implements IESQueryBuilders {
  525.     private BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
  527.     @Override
  528.     public IESQueryBuilders termQuery(String name, String... values) throws Exception {
  529.         // TODO Auto-generated method stub
  530.         boolQueryBuilder.mustNot(QueryBuilders.termQuery(name, values));
  531.         return this;
  532.     }
  534.     @Override
  535.     public IESQueryBuilders wildcardQuery(String name, String... values) throws Exception {
  536.         // TODO Auto-generated method stub
  537.         for (String value : values){
  538.             boolQueryBuilder.mustNot(QueryBuilders.wildcardQuery(name, "*" + value + "*"));
  539.         }
  540.         return this;
  542.     }
  544.     @Override
  545.     public IESQueryBuilders rangeQuery(String name, String from, String to) throws Exception {
  546.         // TODO Auto-generated method stub
  547.         return null;
  548.     }
  550.     @Override
  551.     public BoolQueryBuilder getBoolQueryBuilder() {
  552.         // TODO Auto-generated method stub
  553.         return boolQueryBuilder;
  554.     }
  556. }
  558. package com.zzg.search.component.builder.impl;
  560. import org.elasticsearch.index.query.BoolQueryBuilder;
  561. import com.zzg.search.component.builder.IESQueryBuilders;
  562. import com.zzg.search.component.builder.IESQueryProduce;
  564. public class ESQueryProduce implements IESQueryProduce{
  566.     private BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
  568.     private int size = Integer.MAX_VALUE;
  570.     private String asc;
  572.     private String desc;
  574.     private int from = 0;
  576.     @Override
  577.     public BoolQueryBuilder getBoolQueryBuilder() {
  578.         // TODO Auto-generated method stub
  579.         return boolQueryBuilder;
  580.     }
  582.     @Override
  583.     public IESQueryProduce getProduct(IESQueryBuilders esQueryBuilders) {
  584.         // TODO Auto-generated method stub
  585.         boolQueryBuilder.must(esQueryBuilders.getBoolQueryBuilder());
  586.         return this;
  587.     }
  589.     public String getAsc() {
  590.         return asc;
  591.     }
  593.     public void setAsc(String asc) {
  594.         this.asc = asc;
  595.     }
  597.     public String getDesc() {
  598.         return desc;
  599.     }
  601.     public void setDesc(String desc) {
  602.         this.desc = desc;
  603.     }
  605.     public int getSize() {
  606.         return size;
  607.     }
  609.     public void setSize(int size) {
  610.         this.size = size;
  611.     }
  613.     public int getFrom() {
  614.         return from;
  615.     }
  617.     public void setFrom(int from) {
  618.         this.from = from;
  619.     }
  620. }
  622. package com.zzg.search.component.builder.impl;
  624. import org.elasticsearch.index.query.BoolQueryBuilder;
  625. import org.elasticsearch.index.query.QueryBuilders;
  627. import com.zzg.search.component.builder.IESQueryBuilders;
  629. public class ESShould implements IESQueryBuilders {
  630.     private BoolQueryBuilder boolQueryBuilder = new BoolQueryBuilder();
  632.     @Override
  633.     public IESQueryBuilders termQuery(String name, String... values) throws Exception {
  634.         // TODO Auto-generated method stub
  635.         boolQueryBuilder.should(QueryBuilders.termsQuery(name, values));
  636.         return this;
  637.     }
  639.     @Override
  640.     public IESQueryBuilders wildcardQuery(String name, String... values) throws Exception {
  641.         // TODO Auto-generated method stub
  642.          for (String value : values){
  643.                 boolQueryBuilder.should(QueryBuilders.wildcardQuery(name, "*" + value + "*"));
  644.             }
  645.             return this;
  646.     }
  648.     @Override
  649.     public IESQueryBuilders rangeQuery(String name, String from, String to) throws Exception {
  650.         // TODO Auto-generated method stub
  651.         return null;
  652.     }
  654.     @Override
  655.     public BoolQueryBuilder getBoolQueryBuilder() {
  656.         // TODO Auto-generated method stub
  657.         return boolQueryBuilder;
  658.     }
  660. }
  662. package com.zzg.search.component.builder.model;
  664. import java.io.Serializable;
  666. public enum ESQueryMode implements Serializable {
  667.     MUST("com.zzg.search.component.builder.impl.ESMust"), MUST_NOT("com.zzg.search.component.builder.impl.ESMustNot"), SHOULD(
  668.             "com.zzg.search.component.builder.impl.ESShould"), FILTER("com.zzg.search.component.builder.impl.ESFilter");
  670.     private String mode;
  672.     ESQueryMode(String mode) {
  673.         this.mode = mode;
  674.     }
  676.     public String mode() {
  677.         return mode;
  678.     }
  680. }
  682. package com.zzg.search.component.exception;
  684. import org.apache.commons.lang3.StringUtils;
  686. @SuppressWarnings("serial")
  687. public class ESFailedException extends RuntimeException  {
  688.      /** The code. */
  689.     private String code;
  691.     /** The params. */
  692.     private String[] params;
  694.     /**
  695.      * Gets the code.
  696.      * 
  697.      * @return the code
  698.      */
  699.     public String getCode() {
  700.         return code;
  701.     }
  703.     /**
  704.      * Sets the code.
  705.      * 
  706.      * @param code
  707.      *            the new code
  708.      */
  709.     public void setCode(String code) {
  710.         this.code = code;
  711.     }
  713.     /**
  714.      * Gets the params.
  715.      * 
  716.      * @return the params
  717.      */
  718.     public String[] getParams() {
  719.         return params;
  720.     }
  722.     /**
  723.      * Sets the params.
  724.      * 
  725.      * @param params
  726.      *            the new params
  727.      */
  728.     public void setParams(String[] params) {
  729.         this.params = params;
  730.     }
  732.     /**
  733.      * Instantiates a new base runtime exception.
  734.      */
  735.     public ESFailedException() {
  736.         super();
  737.     }
  739.     /**
  740.      * Instantiates a new base runtime exception.
  741.      * 
  742.      * @param message
  743.      *            the message
  744.      * @param e
  745.      *            the e
  746.      */
  747.     public ESFailedException(String message, Exception e) {
  748.         super(message, e);
  749.     }
  751.     /**
  752.      * Instantiates a new base runtime exception.
  753.      * 
  754.      * @param message
  755.      *            the message
  756.      */
  757.     public ESFailedException(String message) {
  758.         super(message);
  759.     }
  761.     /**
  762.      * Instantiates a new base runtime exception.
  763.      * 
  764.      * @param e
  765.      *            the e
  766.      */
  767.     public ESFailedException(Exception e) {
  768.         super(e);
  769.     }
  771.     /**
  772.      * Instantiates a new base runtime exception.
  773.      * 
  774.      * @param code
  775.      *            the code
  776.      * @param params
  777.      *            the params
  778.      */
  779.     public ESFailedException(String code, String[] params) {
  780.         super(code);
  781.         this.setCode(code);
  782.         this.setParams(params);
  783.     }
  785.     /**
  786.      * Instantiates a new base runtime exception.
  787.      * 
  788.      * @param code
  789.      *            the code
  790.      * @param params
  791.      *            the params
  792.      * @param e
  793.      *            the e
  794.      */
  795.     public ESFailedException(String code, String[] params, Exception e) {
  796.         super(e);
  797.         this.setCode(code);
  798.         this.setParams(params);
  799.     }
  801.     /*
  802.      * (non-Javadoc)
  803.      * 
  804.      * @see java.lang.Throwable#getMessage()
  805.      */
  806.     @Override
  807.     public String getMessage() {
  808.         if (code == null || code.length() == 0) {
  809.             return super.getMessage();
  810.         }
  811.         String paramsStr = "NA";
  812.         if (params != null) {
  813.             paramsStr = StringUtils.join(params, ",");
  814.         }
  815.         String codeMessage = "code:" + code + ";parameters:" + paramsStr;
  816.         return codeMessage;
  817.     }
  819.     /*
  820.      * (non-Javadoc)
  821.      * 
  822.      * @see java.lang.Throwable#toString()
  823.      */
  824.     @Override
  825.     public String toString() {
  826.         String s = getClass().getName();
  827.         String message = this.getMessage();
  828.         return (message != null) ? (s + ": " + message) : s;
  829.     }
  830. }
  832. package com.zzg.search.component.exception;
  834. import org.apache.commons.lang3.StringUtils;
  836. @SuppressWarnings("serial")
  837. public class ESIndexException extends RuntimeException {
  838.      /** The code. */
  839.     private String code;
  841.     /** The params. */
  842.     private String[] params;
  844.     /**
  845.      * Gets the code.
  846.      * 
  847.      * @return the code
  848.      */
  849.     public String getCode() {
  850.         return code;
  851.     }
  853.     /**
  854.      * Sets the code.
  855.      * 
  856.      * @param code
  857.      *            the new code
  858.      */
  859.     public void setCode(String code) {
  860.         this.code = code;
  861.     }
  863.     /**
  864.      * Gets the params.
  865.      * 
  866.      * @return the params
  867.      */
  868.     public String[] getParams() {
  869.         return params;
  870.     }
  872.     /**
  873.      * Sets the params.
  874.      * 
  875.      * @param params
  876.      *            the new params
  877.      */
  878.     public void setParams(String[] params) {
  879.         this.params = params;
  880.     }
  882.     /**
  883.      * Instantiates a new base runtime exception.
  884.      */
  885.     public ESIndexException() {
  886.         super();
  887.     }
  889.     /**
  890.      * Instantiates a new base runtime exception.
  891.      * 
  892.      * @param message
  893.      *            the message
  894.      * @param e
  895.      *            the e
  896.      */
  897.     public ESIndexException(String message, Exception e) {
  898.         super(message, e);
  899.     }
  901.     /**
  902.      * Instantiates a new base runtime exception.
  903.      * 
  904.      * @param message
  905.      *            the message
  906.      */
  907.     public ESIndexException(String message) {
  908.         super(message);
  909.     }
  911.     /**
  912.      * Instantiates a new base runtime exception.
  913.      * 
  914.      * @param e
  915.      *            the e
  916.      */
  917.     public ESIndexException(Exception e) {
  918.         super(e);
  919.     }
  921.     /**
  922.      * Instantiates a new base runtime exception.
  923.      * 
  924.      * @param code
  925.      *            the code
  926.      * @param params
  927.      *            the params
  928.      */
  929.     public ESIndexException(String code, String[] params) {
  930.         super(code);
  931.         this.setCode(code);
  932.         this.setParams(params);
  933.     }
  935.     /**
  936.      * Instantiates a new base runtime exception.
  937.      * 
  938.      * @param code
  939.      *            the code
  940.      * @param params
  941.      *            the params
  942.      * @param e
  943.      *            the e
  944.      */
  945.     public ESIndexException(String code, String[] params, Exception e) {
  946.         super(e);
  947.         this.setCode(code);
  948.         this.setParams(params);
  949.     }
  951.     /*
  952.      * (non-Javadoc)
  953.      * 
  954.      * @see java.lang.Throwable#getMessage()
  955.      */
  956.     @Override
  957.     public String getMessage() {
  958.         if (code == null || code.length() == 0) {
  959.             return super.getMessage();
  960.         }
  961.         String paramsStr = "NA";
  962.         if (params != null) {
  963.             paramsStr = StringUtils.join(params, ",");
  964.         }
  965.         String codeMessage = "code:" + code + ";parameters:" + paramsStr;
  966.         return codeMessage;
  967.     }
  969.     /*
  970.      * (non-Javadoc)
  971.      * 
  972.      * @see java.lang.Throwable#toString()
  973.      */
  974.     @Override
  975.     public String toString() {
  976.         String s = getClass().getName();
  977.         String message = this.getMessage();
  978.         return (message != null) ? (s + ": " + message) : s;
  979.     }
  980. }

业务逻辑模块domain、mapper、service 和serviceImpl 相关代码省略。

elasticsearch6.x controller 代码：

  1. package com.zzg.search.controller;
  3. import java.util.List;
  4. import java.util.Map;
  6. import org.springframework.stereotype.Controller;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RequestMethod;
  9. import org.springframework.web.bind.annotation.ResponseBody;
  11. import com.zzg.jreport.response.JreportResponse;
  12. import com.zzg.search.component.ESService;
  13. import com.zzg.search.component.builder.IESQueryBuilders;
  14. import com.zzg.search.component.builder.factory.ESQueryBuilderFactory;
  15. import com.zzg.search.component.builder.impl.ESQueryProduce;
  16. import com.zzg.search.component.builder.model.ESQueryMode;
  18. import io.swagger.annotations.Api;
  19. import io.swagger.annotations.ApiOperation;
  21. @Controller
  22. @RequestMapping("/api/es")
  23. @Api(value = "搜索引擎Controlle", tags = "搜索引擎操作服务")
  24. public class ESController {
  26.     @ApiOperation(httpMethod = "POST", value = "ES检索")
  27.     @RequestMapping(value = "/search", method = { RequestMethod.POST }, produces = "application/json;charset=UTF-8")
  28.     @ResponseBody
  29.     public JreportResponse search() {
  30.         ESService util = new ESService("my-application","192.168.1.74", 9300);
  32.         // 验证索引文件是否存在
  33.         boolean target = util.indexExist("username");
  34.         if(target){
  35.             System.out.println("指定索引是否存在:" + target);
  36.             util.deleteIndex("username");
  37.             System.out.println("指定索引删除成功");
  38.         }
  39.         return JreportResponse.ok(null);
  40.     }
  42.     @ApiOperation(httpMethod = "POST", value = "ES检索")
  43.     @RequestMapping(value = "/find", method = { RequestMethod.POST }, produces = "application/json;charset=UTF-8")
  44.     @ResponseBody
  45.     public JreportResponse find() {
  46.         ESService util = new ESService("my-application","192.168.1.74", 9300);
  48.         ESQueryProduce produce = new ESQueryProduce();
  49.         // 构建查询条件
  50.         IESQueryBuilders must = null;
  51.         try {
  52.             must = ESQueryBuilderFactory.creatESQueryBuilder(ESQueryMode.MUST);
  53.             must.termQuery("author", "somebody");
  54.             must.rangeQuery("postdate", "2015-01-01", "2019-01-01");
  55.         } catch (Exception e) {
  56.             // TODO Auto-generated catch block
  57.             e.printStackTrace();
  58.         } 
  59.         produce.getProduct(must);
  61.         List<Map<String,Object>> list = util.search("website", "blog", produce);
  63.         return JreportResponse.ok(list);
  64.     }
  66. }

application.properties 文件和log4j 文件

  1. # æå®æå¡ç«¯å£
  2. server.port=7090
  3. # æå®æå¡ å称
  4. # server.context-path=/jreport
  5. #mybatis xml æ件éç½®
  6. mybatis.mapper-locations=classpath*:mapper/search/*Mapper.xml
  7. mybatis.type-aliases-package=com.zzg.search.domain
  8. # MyBatis mysql8 éç½®
  9. spring.datasource.url=jdbc:mysql://192.168.*.**:3306/boot-security?serverTimezone=UTC&useSSL=false&allowPublicKeyRetrieval=true&allowMultiQueries=true&nullCatalogMeansCurrent=true
  10. spring.datasource.username=root
  11. spring.datasource.password=******
  12. spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
  13. # Druid éç½®
  14. # åå§åæ¶å»ºç«ç©çè¿æ¥ç个æ°
  15. spring.datasource.druid.initial-size=5
  16. # æ大è¿æ¥æ± æ°é
  17. spring.datasource.druid.max-active=30
  18. # æå°è¿æ¥æ± æ°é
  19. spring.datasource.druid.min-idle=5
  20. # è·åè¿æ¥æ¶æ大ç­å¾æ¶é´ï¼åä½æ¯«ç§
  21. spring.datasource.druid.max-wait=60000
  22. # éç½®é´éå¤ä¹æè¿è¡ä¸æ¬¡æ£æµï¼æ£æµéè¦å³é­ç空é²è¿æ¥ï¼åä½æ¯æ¯«ç§
  23. spring.datasource.druid.time-between-eviction-runs-millis=60000
  24. # è¿æ¥ä¿æ空é²èä¸è¢«é©±éçæå°æ¶é´
  25. spring.datasource.druid.min-evictable-idle-time-millis=300000
  26. # ç¨æ¥æ£æµè¿æ¥æ¯å¦ææçsqlï¼è¦æ±æ¯ä¸ä¸ªæ¥è¯¢è¯­å¥
  27. spring.datasource.druid.validation-query=SELECT 1 FROM DUAL
  28. # 建议é置为trueï¼ä¸å½±åæ§è½ï¼å¹¶ä¸ä¿è¯å®å¨æ§ãç³è¯·è¿æ¥çæ¶åæ£æµï¼å¦æ空é²æ¶é´å¤§äºtimeBetweenEvictionRunsMillisï¼æ§è¡validationQueryæ£æµè¿æ¥æ¯å¦ææã
  29. spring.datasource.druid.test-while-idle=true
  30. # ç³è¯·è¿æ¥æ¶æ§è¡validationQueryæ£æµè¿æ¥æ¯å¦ææï¼åäºè¿ä¸ªéç½®ä¼éä½æ§è½ã
  31. spring.datasource.druid.test-on-borrow=false
  32. # å½è¿è¿æ¥æ¶æ§è¡validationQueryæ£æµè¿æ¥æ¯å¦ææï¼åäºè¿ä¸ªéç½®ä¼éä½æ§è½ã
  33. spring.datasource.druid.test-on-return=false
  34. # æ¯å¦ç¼å­preparedStatementï¼ä¹å°±æ¯PSCacheãPSCache对æ¯æ游æ çæ°æ®åºæ§è½æå巨大ï¼æ¯å¦è¯´oracleãå¨mysqlä¸å»ºè®®å³é­ã
  35. spring.datasource.druid.pool-prepared-statements=true
  36. # è¦å¯ç¨PSCacheï¼å¿é¡»é置大äº0ï¼å½å¤§äº0æ¶ï¼poolPreparedStatementsèªå¨è§¦åä¿®æ¹ä¸ºtrueã
  37. spring.datasource.druid.max-pool-prepared-statement-per-connection-size=50
  38. # éç½®çæ§ç»è®¡æ¦æªçfiltersï¼å»æåçæ§çé¢sqlæ æ³ç»è®¡
  39. #spring.datasource.druid.filters=stat,wall
  40. # éè¿connectPropertieså±æ§æ¥æå¼mergeSqlåè½ï¼æ¢SQLè®°å½
  41. spring.datasource.druid.connection-properties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500
  42. # å并å¤ä¸ªDruidDataSourceççæ§æ°æ®
  43. spring.datasource.druid.use-global-data-source-stat=true
  44. # éç½®sql 注å¥æ¹å¼
  45. spring.datasource.druid.filters=stat
  46. # æ¥å¿æ件éç½®
  47. logging.config=classpath:logback.xml
  49. # elasticsearch éç½®å±æ§
  50. spring.data.elasticsearch.clusterName=my-application
  51. spring.data.elasticsearch.clusterNodes=192.168.1.74:9300

log4j.properties 配置文件：未编写。

项目整体结构：

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70

发表评论

表情：
评论列表 （有 0 条评论，214人围观）

还没有评论，来说两句吧...

相关阅读