devbox
羊村懒王
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

使用RestHighLevelClient-6.4.0客户端实现ES增删改查-操作工具类简单封装_es 6.4 resthighlevelclient 配置

作者：羊村懒王 | 2024-02-08 10:59:59

赞

踩

es 6.4 resthighlevelclient 配置

maven依赖，使用了RestHighLevelClient6.4.0版本

  1.         <dependency>
  2.             <groupId>org.elasticsearch.client</groupId>
  3.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
  4.             <version>6.4.0</version>
  5.         </dependency>

首先RestHighLevelClient配置，采用注入方式，启动就注册客户端bean

  1. @Configuration
  2. public class ESHighLevelRestClient {
  3.  
  4.     public static final int CONNECT_TIMEOUT = 5000;
  5.     public static final int SOCKET_TIMEOUT = 60000;
  6.     public static final int MAX_RETRY_TIMEOUT = 60000;
  7.     public static final int WORK_THREADS = Runtime.getRuntime().availableProcessors();
  8.     private final String authEnable = "enable";
  9.     // 配置类，里面配置了es的地址，用户，密码
  10.     @Autowired
  11.     private ElasticsearchConfig elasticsearchConfig;
  12.  
  13.     @Bean
  14.     public RestHighLevelClient restHighLevelClient() throws UnsupportedEncodingException {
  15.  
  16.         ArrayList<HttpHost> httpHosts = Lists.newArrayList();
  17.  
  18.         Map<String, String> hostsMap = Splitter.on(',').trimResults().omitEmptyStrings()
  19.                 .withKeyValueSeparator(":")
  20.                 .split(elasticsearchConfig.getHosts());
  21.  
  22.         hostsMap.entrySet().stream().forEach(x -> {
  23.             httpHosts.add(new HttpHost(x.getKey(), Integer.valueOf(x.getValue()), "http"));
  24.         });
  25.  
  26.         RestClientBuilder restClientBuilder = RestClient.builder(httpHosts.toArray(new HttpHost[httpHosts.size()]));
  27.  
  28.         // set es connection timeout
  29.         restClientBuilder.setRequestConfigCallback(new RestClientBuilder.RequestConfigCallback() {
  30.             @Override
  31.             public RequestConfig.Builder customizeRequestConfig(RequestConfig.Builder requestConfigBuilder) {
  32.                 return requestConfigBuilder
  33.                         .setConnectTimeout(CONNECT_TIMEOUT)
  34.                         .setSocketTimeout(SOCKET_TIMEOUT);
  35.             }
  36.         }).setMaxRetryTimeoutMillis(MAX_RETRY_TIMEOUT);
  37.  
  38.         // set es client works numbers
  39.         restClientBuilder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
  40.             @Override
  41.             public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
  42.                 return httpClientBuilder.setDefaultIOReactorConfig(
  43.                         IOReactorConfig.custom().setIoThreadCount(WORK_THREADS).build());
  44.             }
  45.         });
  46.  
  47.         if (authEnable.equalsIgnoreCase(elasticsearchConfig.getAuth())) {
  48.             Header[] defaultHeaders = new Header[]{new BasicHeader("Authorization", getToken(elasticsearchConfig.getUsername(), elasticsearchConfig.getPassword()))};
  49.             restClientBuilder.setDefaultHeaders(defaultHeaders);
  50.         }
  51.  
  52.         return new RestHighLevelClient(restClientBuilder);
  53.     }
  54.  
  55.     private String getToken(String username, String password) throws UnsupportedEncodingException {
  56.         StringBuilder tokenBuilder = new StringBuilder();
  57.         tokenBuilder.append(username);
  58.         tokenBuilder.append(":");
  59.         tokenBuilder.append(password);
  60.         String token = new String(Base64.getEncoder().encode(tokenBuilder.toString().getBytes()), StandardCharsets.UTF_8);
  61.         return "Basic " + token;
  62.     }
  63. }

封装abstract类，想要操作ES的实体需要继承这个类，重写packageElasticSearchBody()方法，封装查询条件

  1. @Getter
  2. @Setter
  3. public abstract class BaseElasticSearchEntity {
  4.  
  5.     /**
  6.      * ES的INDEX
  7.      */
  8.     private String esIndex;
  9.     /**
  10.      * ES的TYPE
  11.      */
  12.     private String esType;
  13.     /**
  14.      * ES唯一值ID
  15.      */
  16.     private String esId;
  17.  
  18.     protected BaseElasticSearchEntity() {
  19.     }
  20.  
  21.     protected BaseElasticSearchEntity(String esIndex, String esType) {
  22.         this.esIndex = esIndex;
  23.         this.esType = esType;
  24.     }
  25.  
  26.     protected BaseElasticSearchEntity(String esIndex, String esType, String esId) {
  27.         this.esIndex = esIndex;
  28.         this.esType = esType;
  29.         this.esId = esId;
  30.     }
  31.  
  32.     /**
  33.      * 供子类封装查询条件
  34.      *
  35.      * @param boolQueryBuilder bool条件
  36.      */
  37.     public abstract void packageElasticSearchBody(BoolQueryBuilder boolQueryBuilder);
  38. }

操作ES的mapper

  1. public interface ElasticSearchMapper<T extends BaseElasticSearchEntity> {
  2.  
  3.     /**
  4.      * 创建ES索引库
  5.      *
  6.      * @param index   index
  7.      * @param type    type
  8.      * @param mapping 映射，为json字符串，
  9.      *                例如：{\"properties\":{\"name\":{\"type\":\"keyword\"},\"date1\":{\"type\":\"date\"},\"date2\":{\"type\":\"date\"},\"updateTime\":{\"type\":\"date\"}}}
  10.      * @return 是否创建成功
  11.      * @throws IOException 异常
  12.      */
  13.     boolean createIndex(String index, String type, String mapping) throws IOException;
  14.  
  15.     /**
  16.      * 删除索引
  17.      *
  18.      * @param index index
  19.      * @return 是否删除成功
  20.      * @throws IOException 异常
  21.      */
  22.     boolean deleteIndex(String index) throws IOException;
  23.  
  24.     /**
  25.      * 根据id查询数据是否存在于ES中
  26.      *
  27.      * @param entry index和type和id
  28.      * @return 是否存在
  29.      */
  30.     boolean isExists(T entry);
  31.  
  32.     /**
  33.      * 插入ES，指定id
  34.      *
  35.      * @param entry 实体
  36.      * @return 插入结果
  37.      */
  38.     String insert(T entry);
  39.  
  40.     /**
  41.      * 更新ES，指定id
  42.      *
  43.      * @param entry 实体
  44.      * @return 更新结果
  45.      */
  46.     String update(T entry);
  47.  
  48.     /**
  49.      * 删除ES，指定id
  50.      *
  51.      * @param entry index和type和id
  52.      * @return 删除结果
  53.      */
  54.     String delete(T entry);
  55.  
  56.     /**
  57.      * 根据id查询ES
  58.      *
  59.      * @param entry index和type和id
  60.      * @return 查询数据结果json字符串
  61.      */
  62.     String selectById(T entry);
  63.  
  64.     /**
  65.      * 多条件查询，正序排序
  66.      *
  67.      * @param entry     封装的查询条件
  68.      * @param sortField 排序字段的字段名，如：updateTime
  69.      * @param page 页码
  70.      * @param length 每页条数
  71.      * @return 查询结果，es封装
  72.      */
  73.     ElasticSearchResponseEntity selectByMultiConditionAsc(T entry, String sortField, Integer page, Integer length);
  74.  
  75.     /**
  76.      * 多条件查询，倒序排序
  77.      *
  78.      * @param entry     封装的查询条件
  79.      * @param sortField 排序字段的字段名，如：updateTime
  80.      * @param page 页码
  81.      * @param length 每页条数
  82.      * @return 查询结果，es封装
  83.      */
  84.     ElasticSearchResponseEntity selectByMultiConditionDesc(T entry, String sortField, Integer page, Integer length);
  85.  
  86. }

mapper的实现类，具体增删改查方法

  1. @Slf4j
  2. @Repository("elasticSearchMapperImpl")
  3. public class ElasticSearchMapperImpl<T extends BaseElasticSearchEntity> implements ElasticSearchMapper<T> {
  4.  
  5.     @Autowired
  6.     private RestHighLevelClient restClient;
  7.  
  8.     @Override
  9.     public boolean createIndex(String index, String type, String mapping) throws IOException {
  10.         CreateIndexRequest indexRequest = new CreateIndexRequest(index);
  11.         indexRequest.mapping(type, mapping, XContentType.JSON);
  12.         IndicesClient indicesClient = restClient.indices();
  13.         CreateIndexResponse createIndexResponse = indicesClient.create(indexRequest, RequestOptions.DEFAULT);
  14.         return createIndexResponse.isAcknowledged();
  15.     }
  16.  
  17.     @Override
  18.     public boolean deleteIndex(String index) throws IOException {
  19.         DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(index);
  20.         IndicesClient indicesClient = restClient.indices();
  21.         AcknowledgedResponse delete = indicesClient.delete(deleteIndexRequest, RequestOptions.DEFAULT);
  22.         return delete.isAcknowledged();
  23.     }
  24.  
  25.     @Override
  26.     public boolean isExists(T entry) {
  27.         GetRequest getRequest = new GetRequest(entry.getEsIndex(), entry.getEsType(), entry.getEsId());
  28.         getRequest.fetchSourceContext(new FetchSourceContext(false));
  29.         getRequest.storedFields("_none_");
  30.         try {
  31.             boolean exists = restClient.exists(getRequest, RequestOptions.DEFAULT);
  32.             log.info("查询ES是否存在数据，isExists：{}，id：{}", exists, getRequest.id());
  33.             return exists;
  34.         } catch (IOException e) {
  35.             throw new RuntimeException(e);
  36.         }
  37.     }
  38.  
  39.     @Override
  40.     public String insert(T entry) {
  41.         IndexRequest request = new IndexRequest(entry.getEsIndex(), entry.getEsType(), entry.getEsId());
  42.         request.source(JSONObject.toJSONString(entry), XContentType.JSON);
  43.         request.create(true);
  44.         IndexResponse response;
  45.         try {
  46.             response = restClient.index(request, RequestOptions.DEFAULT);
  47.             String name = response == null ? null : response.getResult().name();
  48.             log.info("ES执行插入：index：{}，type：{}，id：{}", request.index(), request.type(), request.id());
  49.             return name;
  50.         } catch (IOException e) {
  51.             throw new RuntimeException(e);
  52.         }
  53.     }
  54.  
  55.     @Override
  56.     public String update(T entry) {
  57.         UpdateRequest request = new UpdateRequest(entry.getEsIndex(), entry.getEsType(), entry.getEsId());
  58.         request.doc(JSONObject.toJSONString(entry), XContentType.JSON);
  59.         UpdateResponse response;
  60.         try {
  61.             response = restClient.update(request, RequestOptions.DEFAULT);
  62.             String name = response == null ? null : response.getResult().name();
  63.             log.info("ES执行更新：index：{}，type：{}，id：{}", request.index(), request.type(), request.id());
  64.             return name;
  65.         } catch (IOException e) {
  66.             throw new RuntimeException(e);
  67.         }
  68.     }
  69.  
  70.     @Override
  71.     public String delete(T entry) {
  72.         DeleteRequest request = new DeleteRequest(entry.getEsIndex(), entry.getEsType(), entry.getEsId());
  73.         try {
  74.             DeleteResponse response = restClient.delete(request, RequestOptions.DEFAULT);
  75.             String name = response == null ? null : response.getResult().name();
  76.             log.info("ES执行删除：index：{}，type：{}，id：{}", request.index(), request.type(), request.id());
  77.             return name;
  78.         } catch (IOException e) {
  79.             e.printStackTrace();
  80.         }
  81.         return null;
  82.     }
  83.  
  84.     @Override
  85.     public String selectById(T entry) {
  86.         GetRequest request = new GetRequest(entry.getEsIndex(), entry.getEsType(), entry.getEsId());
  87.         try {
  88.             GetResponse response = restClient.get(request, RequestOptions.DEFAULT);
  89.             if (response.isExists()) {
  90.                 return response.getSourceAsString();
  91.             } else {
  92.                 return null;
  93.             }
  94.         } catch (IOException e) {
  95.             throw new RuntimeException(e);
  96.         }
  97.     }
  98.  
  99.  
  100.     @Override
  101.     public ElasticSearchResponseEntity selectByMultiConditionDesc(T entry, String sortField, Integer page, Integer length) {
  102.         return packageSelectData(selectByMultiCondition(entry, sortField, SortOrder.DESC, page, length));
  103.     }
  104.  
  105.     @Override
  106.     public ElasticSearchResponseEntity selectByMultiConditionAsc(T entry, String sortField, Integer page, Integer length) {
  107.         return packageSelectData(selectByMultiCondition(entry, sortField, SortOrder.ASC, page, length));
  108.     }
  109.  
  110.     /**
  111.      * 封装成ElasticSearchResponseEntity返回
  112.      *
  113.      * @param searchHits es查询的数据
  114.      * @return ElasticSearchResponseEntity
  115.      */
  116.     private ElasticSearchResponseEntity packageSelectData(SearchHits searchHits) {
  117.         if (searchHits == null || searchHits.totalHits < 1) {
  118.             return new ElasticSearchResponseEntity(0L, new LinkedList<>());
  119.         }
  120.         List<String> list = new LinkedList<>();
  121.         Arrays.stream(searchHits.getHits()).forEach(hit -> {
  122.             String source = hit.getSourceAsString();
  123.             log.debug("ES查询数据：{}", source);
  124.             list.add(source);
  125.         });
  126.         return new ElasticSearchResponseEntity(searchHits.getTotalHits(), list);
  127.     }
  128.  
  129.     /**
  130.      * 多条件查询，包含排序规则和分页功能
  131.      *
  132.      * @param entry     封装的查询条件
  133.      * @param sortField 排序字段的字段名
  134.      *                  如果在mapping中未指定排序字段的类型为精确类型（如date或keyword），则此排序字段必须加上 .keyword 后缀，表示精准匹配，否则报错：[type=search_phase_execution_exception, reason=all shards failed]
  135.      *                  例如：username.keyword，如果mapping指定了字段类型为date或者keyword，则直接传字段名即可，例如：keywordName1、updateTime
  136.      * @param sortOrder 排序规则，正序还是倒序
  137.      * @return 查询结果，es封装
  138.      */
  139.     private SearchHits selectByMultiCondition(T entry, String sortField, SortOrder sortOrder, Integer page, Integer length) {
  140.         SearchRequest searchRequest = new SearchRequest(entry.getEsIndex());
  141.         searchRequest.types(entry.getEsType());
  142.         try {
  143.             BoolQueryBuilder boolBuilder = QueryBuilders.boolQuery();
  144.             entry.packageElasticSearchBody(boolBuilder);
  145.             SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
  146.             sourceBuilder.sort(new FieldSortBuilder(sortField).order(sortOrder));
  147.             sourceBuilder.query(boolBuilder);
  148.             setPaging(sourceBuilder, page, length);
  149.             searchRequest.source(sourceBuilder);
  150.             SearchResponse searchResponse = restClient.search(searchRequest, RequestOptions.DEFAULT);
  151.             return searchResponse.getHits();
  152.         } catch (Exception e) {
  153.             log.error("===》 es【多条件】查询，报错！entry={}", searchRequest.source().toString(), e);
  154.             return null;
  155.         }
  156.     }
  157.  
  158.     /**
  159.      * 设置es查询的分页配置
  160.      *
  161.      * ElasticSearchConstant.MAX_SIZE = ES默认10000条，这个自定义的常量无法超过默认值
  162.      * @param sourceBuilder builder
  163.      * @param page          页码
  164.      * @param length        每页条数
  165.      */
  166.     private void setPaging(SearchSourceBuilder sourceBuilder, Integer page, Integer length) {
  167.         if (page != null && length != null) {
  168.             length = Math.min(length, ElasticSearchConstant.MAX_SIZE);
  169.             int from = (page - 1) * length;
  170.             sourceBuilder.from(from);
  171.             sourceBuilder.size(length);
  172.         }
  173.     }
  174. }

返回值封装实体

  1. public class ElasticSearchResponseEntity {
  2.  
  3.     private Long total;// 查询总数
  4.     private List<String> list;// 数据集合
  5.  
  6.     public ElasticSearchResponseEntity(Long total, List<String> list) {
  7.         this.total = total;
  8.         this.list = list;
  9.     }
  10.  
  11.     public Long getTotal() {
  12.         return total;
  13.     }
  14.  
  15.     public void setTotal(Long total) {
  16.         this.total = total;
  17.     }
  18.  
  19.     public List<String> getList() {
  20.         return list;
  21.     }
  22.  
  23.     public void setList(List<String> list) {
  24.         this.list = list;
  25.     }
  26. }

使用：

0.ES查询所需的QueryBuilder的封装，简单封装一下，如有需要可以自行增减

  1. public class QueryBuilder {
  2.  
  3.     /**
  4.      * 大于等于
  5.      */
  6.     public static final String GTE = "gte";
  7.     /**
  8.      * 小于等于
  9.      */
  10.     public static final String LTE = "lte";
  11.     /**
  12.      * 大于
  13.      */
  14.     public static final String GT = "gt";
  15.     /**
  16.      * 小于
  17.      */
  18.     public static final String LT = "lt";
  19.  
  20.     /**
  21.      * 不会对搜索词进行分词处理，而是作为一个整体与目标字段进行匹配，若完全匹配，则可查询到。
  22.      *
  23.      * @param key
  24.      * @param value
  25.      * @return
  26.      */
  27.     public static TermQueryBuilder term(String key, Object value) {
  28.         return QueryBuilders.termQuery(key, value);
  29.     }
  30.  
  31.     /**
  32.      * 一次匹配多个值，即 in()查询
  33.      *
  34.      * @param key    key
  35.      * @param values 值集合
  36.      * @return TermsQueryBuilder
  37.      */
  38.     public static TermsQueryBuilder terms(String key, Collection<?> values) {
  39.         return QueryBuilders.termsQuery(key, values);
  40.     }
  41.  
  42.     /**
  43.      * 一次匹配多个值，即 in()查询，keyword全值匹配，精确查询
  44.      *
  45.      * @param key
  46.      * @param values
  47.      * @return
  48.      */
  49.     public static TermsQueryBuilder termsKeyword(String key, Collection<?> values) {
  50.         return QueryBuilders.termsQuery(key + ".keyword", values);
  51.     }
  52.  
  53.  
  54.     /**
  55.      * 会将搜索词分词，再与目标查询字段进行匹配，若分词中的任意一个词与目标字段匹配上，则可查询到。
  56.      *
  57.      * @param key
  58.      * @param value
  59.      * @return
  60.      */
  61.     public static MatchQueryBuilder match(String key, Object value) {
  62.         return QueryBuilders.matchQuery(key, value);
  63.     }
  64.  
  65.     /**
  66.      * 分词模糊查询
  67.      *
  68.      * @param key
  69.      * @param value
  70.      * @return
  71.      */
  72.     public static FuzzyQueryBuilder fuzzy(String key, Object value) {
  73.         return QueryBuilders.fuzzyQuery(key, value);
  74.     }
  75.  
  76.     /**
  77.      * 范围查询
  78.      *
  79.      * @param key
  80.      * @param value
  81.      * @return
  82.      */
  83.     public static RangeQueryBuilder range(String key, Object value, String rangeType) {
  84.         RangeQueryBuilder builder = QueryBuilders.rangeQuery(key);
  85.         switch (rangeType) {
  86.             case GTE:
  87.                 return builder.gte(value);
  88.             case LTE:
  89.                 return builder.lte(value);
  90.             case GT:
  91.                 return builder.gt(value);
  92.             case LT:
  93.                 return builder.lt(value);
  94.             default:
  95.                 return builder.gt(value);
  96.         }
  97.     }

1.定义数据实体类，继承BaseElasticSearchEntity，并重写父类方法，封装查询条件（省略getter/setter/toString/空参构造器等）

  1. public class Student extends BaseElasticSearchEntity {
  2.  
  3.     private Long id;
  4.     private String name;
  5.     private Date birth;
  6.     private String nikename;
  7.  
  8.     // 父类构造器，用来操作ES指定的索引和Type
  9.     public Student(String esIndex, String esType, String esId) {
  10.         super(esIndex, esType, esId);
  11.     }
  12.  
  13.     public Student(String esIndex, String esType) {
  14.         super(esIndex, esType);
  15.     }
  16.  
  17.     // 重写父类方法，封装查询的条件
  18.     @Override
  19.     public void packageElasticSearchBody(BoolQueryBuilder boolQueryBuilder) {
  20.         // 相当于IN查询
  21.         if (StringUtils.isNotEmpty(this.name)) {
  22.             List<String> nameList = new ArrayList<>(Arrays.asList(this.name.split(",")));
  23.             boolQueryBuilder.must(QueryBuilder.termsKeyword("name", nameList));
  24.         }
  25.         // 日期范围查询，日期存入yyyy-MM-dd HH:mm:ss格式时配置不当可能会报错，建议存入时间戳
  26.         if (StringUtils.isNotEmpty(this.startTime)) {
  27.             boolQueryBuilder.must(QueryBuilder.range("birth", DateUtil.convertTimeToLong(this.startTime, DateUtil.YYYY_MM_DD_HH_MM_SS), QueryBuilder.GTE));
  28.         }
  29.         if (StringUtils.isNotEmpty(this.endTime)) {
  30.             boolQueryBuilder.must(QueryBuilder.range("birth", DateUtil.convertTimeToLong(this.endTime, DateUtil.YYYY_MM_DD_HH_MM_SS), QueryBuilder.LTE));
  31.         }
  32.         // match精准查询
  33.         if (StringUtils.isNotEmpty(this.nikename)) {
  34.             boolQueryBuilder.must(QueryBuilder.match("nikename", this.carId));
  35.         }
  36.         // 其他查询要求可以自行百度
  37.  
  38.     }
  39. }

2.service层的操作，忽略了业务逻辑，省略接口，直接上实现类了

  1. @Slf4j
  2. @Service("studentElasticSearchService")
  3. public class StudentElasticSearchServiceImpl implements StudentElasticSearchService {
  4.  
  5.     @Autowired
  6.     @Qualifier("elasticSearchMapperImpl")
  7.     private ElasticSearchMapper<Student> elasticSearchMapper;
  8.  
  9.     private final String TYPE = "student_type";
  10.     private final String INDEX_NAME = "student_index";
  11.  
  12.     @Override
  13.     public boolean isExists(String id) {
  14.         return elasticSearchMapper.isExists(new Student(INDEX_NAME, TYPE, id));
  15.     }
  16.  
  17.     @Override
  18.     public String insert(Student entry) {
  19.         entry.setEsIndex(INDEX_NAME);
  20.         entry.setEsType(TYPE);
  21.         entry.setEsId(entry.getId());
  22.         return elasticSearchMapper.insert(entry);
  23.     }
  24.  
  25.     @Override
  26.     public Student selectById(String id) {
  27.         String jsonString = elasticSearchMapper.selectById(new Student(INDEX_NAME, TYPE, id));
  28.         return StringUtils.isEmpty(jsonString) ? null : JSONObject.parseObject(jsonString, Student.class);
  29.     }
  30.  
  31.     @Override
  32.     public String update(Student entry) {
  33.         entry.setEsIndex(INDEX_NAME);
  34.         entry.setEsType(TYPE);
  35.         entry.setEsId(entry.getId());
  36.         return elasticSearchMapper.update(entry);
  37.     }
  38.  
  39.     @Override
  40.     public String delete(String id) {
  41.         return elasticSearchMapper.delete(new Student(INDEX_NAME, TYPE, id));
  42.     }
  43.  
  44.     @Override
  45.     public ElasticSearchResponseEntity selectByMultiCondition(Student entry, Integer page, Integer length) {
  46.         try {
  47.             entry.setEsIndex(INDEX_NAME);
  48.             entry.setEsType(TYPE);
  49.             return elasticSearchMapper.selectByMultiConditionDesc(entry, "birth", page, length);
  50.         } catch (Exception e) {
  51.             log.error("出错！", e);
  52.         }
  53.         return null;
  54.     }
  55. }

3.直接调用service层的接口，传入封装的实体或者唯一id，即可操作ES的增删改查，代码就不用贴了，到这一步，傻子都会用了

 

如有更好的建议和写法，请告知我，先感谢能让我提升代码质量的任何朋友。

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/羊村懒王/article/detail/68698
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号