经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » Elasticsearch » 查看文章
关于注解式的分布式Elasticsearch的封装案例
来源：jb51　　时间：2021/1/25 12:19:50　　对本文有异议

原生的Rest Level Client不好用，构建检索等很多重复操作。

对bboss-elasticsearch进行了部分增强：通过注解配合实体类进行自动构建索引和自动刷入文档，复杂的业务检索需要自己在xml中写Dsl。用法与mybatis-plus如出一辙。

依赖

  1. <dependency>
  2. 			<groupId>org.elasticsearch</groupId>
  3. 			<artifactId>elasticsearch</artifactId>
  4. 		</dependency>
  5. 		<dependency>
  6. 			<groupId>com.bbossgroups.plugins</groupId>
  7. 			<artifactId>bboss-elasticsearch-spring-boot-starter</artifactId>
  8. 			<version>5.9.5</version>
  9. 			<exclusions>
  10. 				<exclusion>
  11. 					<artifactId>slf4j-log4j12</artifactId>
  12. 					<groupId>org.slf4j</groupId>
  13. 				</exclusion>
  14. 			</exclusions>
  15. 		</dependency>
  16. 		<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
  17. 		<dependency>
  18. 			<groupId>org.projectlombok</groupId>
  19. 			<artifactId>lombok</artifactId>
  20. 			<version>1.18.6</version>
  21. 			<scope>provided</scope>
  22. 		</dependency>

配置：

  1.  
  2. import com.rz.config.ElsConfig;
  3. import org.frameworkset.elasticsearch.boot.ElasticSearchBoot;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.boot.ApplicationArguments;
  6. import org.springframework.boot.ApplicationRunner;
  7. import org.springframework.core.annotation.Order;
  8. import org.springframework.stereotype.Component; 
  9. import java.util.HashMap;
  10. import java.util.Map;
  11.  
  12. /**
  13.  * 启动时初始化bBoss
  14.  *
  15.  * @author sunziwen
  16.  * @version 1.0
  17.  * @date 2019/12/12 16:54
  18.  **/
  19. @Component
  20. @Order(value = 1)
  21. public class StartElastic implements ApplicationRunner {
  22.  @Autowired
  23.  private ElsConfig config;
  24.  
  25.  @Override
  26.  public void run(ApplicationArguments args) throws Exception {
  27.  Map properties = new HashMap();
  28.  properties.put("elasticsearch.rest.hostNames", config.getElsClusterNodes());
  29.  ElasticSearchBoot.boot(properties);
  30.  }
  31. }

注解和枚举：

  1. package com.rz.szwes.annotations;
  2.  
  3. import java.lang.annotation.*;
  4.  
  5. /**
  6.  * 标识实体对应的索引信息
  7.  *
  8.  * @author sunziwen
  9.  * 2019/12/13 10:14
  10.  * @version 1.0
  11.  **/
  12. @Target({ElementType.TYPE})
  13. @Retention(RetentionPolicy.RUNTIME)
  14. @Documented
  15. public @interface ESDsl {
  16.  /**
  17.  * xml的位置
  18.  */
  19.  String value();
  20.  
  21.  String indexName();
  22.  
  23.  /**
  24.  * elasticsearch7.x版本已经删除该属性
  25.  */
  26.  String indexType() default "";
  27. }
  1. package com.rz.szwes.annotations;
  2.  
  3.  
  4. import java.lang.annotation.*;
  5.  
  6. /**
  7.  * 为字段指定映射类型
  8.  *
  9.  * @author sunziwen
  10.  * 2019/12/14 10:06
  11.  * @version 1.0
  12.  **/
  13. @Target({ElementType.FIELD})
  14. @Retention(RetentionPolicy.RUNTIME)
  15. @Documented
  16. public @interface ESMapping {
  17.  //映射类型
  18.  ESMappingType value();
  19.  
  20.  //加权
  21.  int boost() default 1;
  22.  
  23.  //分词标识analyzed、not_analyzed
  24.  String index() default "analyzed";
  25.  
  26.  //分词器ik_max_word、standard
  27.  String analyzer() default "ik_max_word";
  28.  
  29.  //String作为分组聚合字段的时候需要设置为true
  30.  boolean fildData() default false;
  31. }
  1. package com.rz.szwes.annotations;
  2.  
  3. /**
  4.  * Es映射类型枚举（定义了大部分，有缺失请使用者补全）当前版本基于elasticsearch 6.8
  5.  *
  6.  * @author sunziwen
  7.  * 2019/12/14 10:09
  8.  * @version 1.0
  9.  **/
  10. public enum ESMappingType {
  11.  /**
  12.  * 全文搜索。
  13.  */
  14.  text("text"),
  15.  /**
  16.  * keyword类型适用于索引结构化(排序、过滤、聚合)，只能通过精确值搜索到。
  17.  */
  18.  keyword("keyword"),
  19.  
  20.  /
  21.  
  22.  /**
  23.  * -128~127 在满足需求的情况下，尽可能选择范围小的数据类型。
  24.  */
  25.  _byte("byte"),
  26.  /**
  27.  * -32768~32767
  28.  */
  29.  _short("short"),
  30.  /**
  31.  * -2^31~2^31-1
  32.  */
  33.  _integer("integer"),
  34.  /**
  35.  * -2^63~2^63-1
  36.  */
  37.  _long("long"),
  38.  
  39.  /
  40.  /**
  41.  * 64位双精度IEEE 754浮点类型
  42.  */
  43.  _doule("doule"),
  44.  /**
  45.  * 32位单精度IEEE 754浮点类型
  46.  */
  47.  _float("float"),
  48.  /**
  49.  * 16位半精度IEEE 754浮点类型
  50.  */
  51.  half_float("half_float"),
  52.  /**
  53.  * 缩放类型的的浮点数
  54.  */
  55.  scaled_float("scaled_float"),
  56.  
  57.  /
  58.  /**
  59.  * 时间类型
  60.  */
  61.  date("date"),
  62.  
  63.  _boolean("boolean"),
  64.  /**
  65.  * 范围类型
  66.  */
  67.  range("range"),
  68.  /**
  69.  * 嵌套类型
  70.  */
  71.  nested("nested"),
  72.  /**
  73.  * 地理坐标
  74.  */
  75.  geo_point("geo_point"),
  76.  /**
  77.  * 地理地图
  78.  */
  79.  geo_shape("geo_shape"),
  80.  /**
  81.  * 二进制类型
  82.  */
  83.  binary("binary"),
  84.  /**
  85.  * ip 192.168.1.2
  86.  */
  87.  ip("ip");
  88.  
  89.  private String value;
  90.  
  91.  ESMappingType(String value) {
  92.  this.value = value;
  93.  }
  94.  
  95.  public String getValue() {
  96.  return value;
  97.  }
  98. }

工具类：对HashMap进行了增强

  1. package com.rz.szwes.util; 
  2. import java.util.HashMap;
  3. import java.util.function.Supplier;
  4.  
  5. /**
  6.  * 原始HashMap不支持Lambda表达式，特此包装一个
  7.  *
  8.  * @author sunziwen
  9.  * @version 1.0
  10.  * @date 2019/12/13 11:09
  11.  **/
  12. public class LambdaHashMap<K, V> extends HashMap<K, V> { 
  13.  public static <K, V> LambdaHashMap<K, V> builder() {
  14.  return new LambdaHashMap<>();
  15.  }
  16.  
  17.  public LambdaHashMap<K, V> put(K key, Supplier<V> supplier) {
  18.  super.put(key, supplier.get());
  19.  //流式
  20.  return this;
  21.  }
  22. }

核心类两个：

  1. package com.rz.szwes.core; 
  2. import cn.hutool.core.util.ClassUtil;
  3. import com.alibaba.fastjson.JSON;
  4. import com.frameworkset.orm.annotation.ESId;
  5. import com.rz.szwes.annotations.ESDsl;
  6. import com.rz.szwes.annotations.ESMapping;
  7. import com.rz.szwes.util.LambdaHashMap;
  8. import org.springframework.util.StringUtils; 
  9. import java.lang.reflect.Field;
  10. import java.lang.reflect.ParameterizedType;
  11. import java.time.LocalDate;
  12. import java.time.LocalDateTime;
  13. import java.time.LocalTime;
  14. import java.util.ArrayList;
  15. import java.util.Arrays;
  16. import java.util.Collections;
  17. import java.util.Date;
  18.  
  19. /**
  20.  * 抽象类解析泛型
  21.  *
  22.  * @author sunziwen
  23.  * 2019/12/14 16:04
  24.  * @version 1.0
  25.  **/
  26. public abstract class AbstractElasticBase<T> {
  27.  { //初始化解析
  28.  ParameterizedType pt = (ParameterizedType) this.getClass().getGenericSuperclass();
  29.  // 获取第一个类型参数的真实类型
  30.  Class<T> clazz = (Class<T>) pt.getActualTypeArguments()[0];
  31.  parseMapping(clazz);
  32.  }
  33.  
  34.  /**
  35.  * 索引名称
  36.  */
  37.  protected String indexName;
  38.  /**
  39.  * 索引类型
  40.  */
  41.  protected String indexType;
  42.  /**
  43.  * es写dsl的文件路径
  44.  */
  45.  protected String xmlPath;
  46.  /**
  47.  * 索引映射
  48.  */
  49.  protected String mapping;
  50.  
  51.  //将Class解析成映射JSONString
  52.  private void parseMapping(Class<T> clazz) {
  53.  if (clazz.isAnnotationPresent(ESDsl.class)) {
  54.   ESDsl esDsl = clazz.getAnnotation(ESDsl.class);
  55.   this.xmlPath = esDsl.value();
  56.   this.indexName = esDsl.indexName();
  57.   //如果类型为空,则采用索引名作为其类型
  58.   this.indexType = StringUtils.isEmpty(esDsl.indexType()) ? esDsl.indexName() : esDsl.indexType();
  59.  } else {
  60.   throw new RuntimeException(clazz.getName() + "缺失注解[@ESDsl]");
  61.  }
  62.  //构建索引映射
  63.  LambdaHashMap<Object, Object> put = LambdaHashMap.builder()
  64.         .put("mappings", () -> LambdaHashMap.builder()
  65.             .put(indexType, () -> LambdaHashMap.builder()
  66.                 .put("properties", () -> {
  67.                  Field[] fields = clazz.getDeclaredFields();
  68.                  LambdaHashMap<Object, Object> builder = LambdaHashMap.builder();
  69.                  for (Field field : fields) {
  70.                  builder.put(field.getName(), () -> toEsjson(field));
  71.                  }
  72.                  return builder;
  73.                 })))
  74.  ;
  75.  this.mapping = JSON.toJSONString(put);
  76.  }
  77.  
  78.  private LambdaHashMap<Object, Object> toEsjson(Field field) {
  79.  //基本数据类型
  80.  if (ClassUtil.isSimpleTypeOrArray(field.getType())) {
  81.   //对字符串做大小限制、分词设置
  82.   if (new ArrayList<Class>(Collections.singletonList(String.class)).contains(field.getType())) {
  83.   LambdaHashMap<Object, Object> put = LambdaHashMap.builder()
  84.          .put("type", () -> "text")
  85.          .put("fields", () -> LambdaHashMap.builder()
  86.              .put("keyword", () -> LambdaHashMap.builder()
  87.                  .put("type", () -> "keyword")
  88.                  .put("ignore_above", () -> 256)));
  89.   if (field.isAnnotationPresent(ESMapping.class)) {
  90.    ESMapping esMapping = field.getAnnotation(ESMapping.class);
  91.    //设置聚合分组
  92.    if (esMapping.fildData()) {
  93.    put.put("fildData", () -> true);
  94.    }
  95.    //设置加权
  96.    if (esMapping.boost() != 1) {
  97.    put.put("boost", esMapping::boost);
  98.    }
  99.    //设置是否进行分词
  100.    if (!"analyzed".equals(esMapping.index())) {
  101.    put.put("analyzed", esMapping::analyzer);
  102.    }
  103.    //分词器
  104.    put.put("analyzer", esMapping::analyzer);
  105.   }
  106.   return put;
  107.   }
  108.   //设置默认类型
  109.   return LambdaHashMap.builder().put("type", () -> {
  110.   if (field.isAnnotationPresent(ESMapping.class)) {
  111.    ESMapping esMapping = field.getAnnotation(ESMapping.class);
  112.    return esMapping.value().getValue();
  113.   }
  114.   if (new ArrayList<Class>(Arrays.asList(byte.class, Byte.class, short.class, Short.class, int.class, Integer.class, long.class, Long.class)).contains(field.getType())) {
  115.    return "long";
  116.   } else if (new ArrayList<Class>(Arrays.asList(double.class, Double.class, float.class, Float.class)).contains(field.getType())) {
  117.    return "double";
  118.   } else if (new ArrayList<Class>(Arrays.asList(Date.class, java.sql.Date.class, LocalDate.class, LocalDateTime.class, LocalTime.class)).contains(field.getType())) {
  119.    return "date";
  120.   } else if (new ArrayList<Class>(Arrays.asList(boolean.class, Boolean.class)).contains(field.getType())) {
  121.    return "boolean";
  122.   }
  123.   return "text";
  124.   });
  125.  } else {
  126.   //设置对象类型
  127.   LambdaHashMap<Object, Object> properties = LambdaHashMap.builder()
  128.          .put("properties", () -> {
  129.          Field[] fields = field.getType().getDeclaredFields();
  130.          LambdaHashMap<Object, Object> builder = LambdaHashMap.builder();
  131.          for (Field field01 : fields) {
  132.           builder.put(field01.getName(), toEsjson(field01));
  133.          }
  134.          return builder;
  135.          });
  136.   if (field.isAnnotationPresent(ESMapping.class)) {
  137.   ESMapping esMapping = field.getAnnotation(ESMapping.class);
  138.   properties.put("type", esMapping.value().getValue());
  139.   }
  140.   return properties;
  141.  }
  142.  } 
  143. }
  1. package com.rz.szwes.core; 
  2. import lombok.extern.slf4j.Slf4j;
  3. import org.frameworkset.elasticsearch.boot.BBossESStarter;
  4. import org.frameworkset.elasticsearch.client.ClientInterface;
  5. import org.frameworkset.elasticsearch.client.ClientUtil;
  6. import org.springframework.beans.factory.annotation.Autowired; 
  7. import java.util.*;
  8.  
  9. /**
  10.  * Elastic基础函数
  11.  *
  12.  * @author sunziwen
  13.  * @version 1.0
  14.  * @date 2019/12/13 9:56
  15.  **/
  16. @Slf4j
  17. public class ElasticBaseService<T> extends AbstractElasticBase<T> {
  18.  
  19.  @Autowired
  20.  private BBossESStarter starter;
  21.  
  22.  /**
  23.  * Xml创建索引
  24.  */
  25.  protected String createIndexByXml(String xmlName) {
  26.  ClientInterface restClient = starter.getConfigRestClient(xmlPath);
  27.  boolean existIndice = restClient.existIndice(this.indexName);
  28.  if (existIndice) {
  29.   restClient.dropIndice(indexName);
  30.  }
  31.  return restClient.createIndiceMapping(indexName, xmlName);
  32.  }
  33.  
  34.  /**
  35.  * 自动创建索引
  36.  */
  37.  protected String createIndex() {
  38.  ClientInterface restClient = starter.getRestClient();
  39.  boolean existIndice = restClient.existIndice(this.indexName);
  40.  if (existIndice) {
  41.   restClient.dropIndice(indexName);
  42.  }
  43.  log.debug("创建索引：" + this.mapping);
  44.  return restClient.executeHttp(indexName, this.mapping, ClientUtil.HTTP_PUT);
  45.  }
  46.  
  47.  /**
  48.  * 删除索引
  49.  */
  50.  protected String delIndex() {
  51.  return starter.getRestClient().dropIndice(this.indexName);
  52.  }
  53.  
  54.  /**
  55.  * 添加文档
  56.  *
  57.  * @param t 实体类
  58.  * @param refresh 是否强制刷新
  59.  */
  60.  protected String addDocument(T t, Boolean refresh) {
  61.  return starter.getRestClient().addDocument(indexName, indexType, t, "refresh=" + refresh);
  62.  }
  63.  
  64.  /**
  65.  * 添加文档
  66.  *
  67.  * @param ts 实体类集合
  68.  * @param refresh 是否强制刷新
  69.  */
  70.  protected String addDocuments(List<T> ts, Boolean refresh) {
  71.  return starter.getRestClient().addDocuments(indexName, indexType, ts, "refresh=" + refresh);
  72.  }
  73.  
  74.  /**
  75.  * 分页-添加文档集合
  76.  *
  77.  * @param ts 实体类集合
  78.  * @param refresh 是否强制刷新
  79.  */
  80.  protected void addDocumentsOfPage(List<T> ts, Boolean refresh) {
  81.  this.delIndex();
  82.  this.createIndex();
  83.  int start = 0;
  84.  int rows = 100;
  85.  Integer size;
  86.  do {
  87.   List<T> list = pageDate(start, rows);
  88.   if (list.size() > 0) {
  89.   //批量同步信息
  90.   starter.getRestClient().addDocuments(indexName, indexType, ts, "refresh=" + refresh);
  91.   }
  92.   size = list.size();
  93.   start += size;
  94.  } while (size > 0);
  95.  }
  96.  
  97.  /**
  98.  * 使用分页添加文档必须重写该类
  99.  *
  100.  * @param start 起始
  101.  * @param rows 项数
  102.  * @return
  103.  */
  104.  protected List<T> pageDate(int start, int rows) {
  105.  return null;
  106.  }
  107.  
  108.  /**
  109.  * 删除文档
  110.  *
  111.  * @param id id
  112.  * @param refresh 是否强制刷新
  113.  * @return
  114.  */
  115.  protected String delDocument(String id, Boolean refresh) {
  116.  return starter.getRestClient().deleteDocument(indexName, indexType, id, "refresh=" + refresh);
  117.  }
  118.  
  119.  /**
  120.  * 删除文档
  121.  *
  122.  * @param ids id集合
  123.  * @param refresh 是否强制刷新
  124.  * @return
  125.  */
  126.  protected String delDocuments(String[] ids, Boolean refresh) {
  127.  return starter.getRestClient().deleteDocumentsWithrefreshOption(indexName, indexType, "refresh=" + refresh, ids);
  128.  }
  129.  
  130.  /**
  131.  * id获取文档
  132.  *
  133.  * @param id
  134.  * @return
  135.  */
  136.  protected T getDocument(String id, Class<T> clazz) {
  137.  return starter.getRestClient().getDocument(indexName, indexType, id, clazz);
  138.  }
  139.  
  140.  /**
  141.  * id更新文档
  142.  *
  143.  * @param t 实体
  144.  * @param refresh 是否强制刷新
  145.  * @return
  146.  */
  147.  protected String updateDocument(String id, T t, Boolean refresh) {
  148.  return starter.getRestClient().updateDocument(indexName, indexType, id, t, "refresh=" + refresh);
  149.  }
  150. }

写复杂Dsl的xml：（如何写Dsl请参考bBoss-elasticsearch文档，用法类似mybatis标签）

  1. <properties> 
  2. </properties>

框架集成完毕，以下是使用示例：

定义数据模型：

  1. package com.rz.dto;
  2.  
  3. import com.frameworkset.orm.annotation.ESId;
  4. import com.rz.szwes.annotations.ESDsl;
  5. import com.rz.szwes.annotations.ESMapping;
  6. import com.rz.szwes.annotations.ESMappingType;
  7. import lombok.Data; 
  8. import java.util.List;
  9.  
  10. /**
  11.  * 对应elasticsearch服务器的数据模型
  12.  *
  13.  * @author sunziwen
  14.  * @version 1.0
  15.  * @date 2019/12/16 11:08
  16.  **/
  17. @ESDsl(value = "elasticsearch/zsInfo.xml", indexName = "zsInfo")
  18. @Data
  19. public class ElasticZsInfoDto {
  20.  @ESMapping(ESMappingType._byte)
  21.  private int least_hit;
  22.  private int is_must_zz;
  23.  private int zs_level;
  24.  private int cur_zs_ct;
  25.  private int least_score_yy;
  26.  private int least_score_yw;
  27.  private int area_id;
  28.  private String coll_name;
  29.  private String coll_code;
  30.  private long coll_pro_id;
  31.  private int is_must_wl;
  32.  private int cur_year;
  33.  private int is_two;
  34.  private long logo;
  35.  @ESId
  36.  private int id;
  37.  private String area;
  38.  private int college_id;
  39.  private String is_must_yy;
  40.  private int is_double;
  41.  private int least_score_zz;
  42.  private int least_score_wl;
  43.  private String grade;
  44.  private int is_nine;
  45.  private String pro_name;
  46.  private int least_score_sx;
  47.  private int relevanceSort;
  48.  private int pre_avg;
  49.  private String is_must_dl;
  50.  private String profession_code;
  51.  private int least_score_sw;
  52.  private String is_must_ls;
  53.  private int grade_zk;
  54.  private int least_score_wy;
  55.  private int is_must_hx;
  56.  private int profession_id;
  57.  private String is_grad;
  58.  private String is_must_yw;
  59.  private int is_must_sw;
  60.  private int least_score_ls;
  61.  private int least_score_dl;
  62.  private String zs_memo;
  63.  private String is_must_sx;
  64.  private String introduce;
  65.  private int is_must_wy;
  66.  private int grade_bk;
  67.  private String pre_name;
  68.  private int least_score_hx;
  69.  private String coll_domain;
  70.  private int pre_wch;
  71.  private List<String> courses;
  72. }

定义服务

  1. package com.rz.service; 
  2. import com.rz.dto.ElasticZsInfoDto;
  3. import com.rz.szwes.core.ElasticBaseService; 
  4.  
  5. /**
  6.  * 招生索引操作服务
  7.  *
  8.  * @author sunziwen
  9.  * @version 1.0
  10.  * @date 2019/12/16 11:02
  11.  **/
  12. public class ElasticZsInfoService extends ElasticBaseService<ElasticZsInfoDto> { 
  13. }

完毕。

已经可以进行索引和文档的crud操作了，至于复杂的检索操作就需要在xml中定义了。这里只介绍了我增强的功能，大部分功能都在bBoss中定义好了，读者可以去看bBoss文档（笔者认为的他的唯一缺陷是不能通过实体配合注解实现自动索引，还要每次手动指定xml位置，手动写mapping是很痛苦的事情，特此进行了增强）。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持w3xue。如有错误或未考虑完全的地方，望不吝赐教。

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Elasticsearch热门文章

  • ES 14 - (底层原理) Elasticsearch内部如何处理不同type的数据
  • ES 15 - Elasticsearch中的数据类型 (text、keyword、date、geo等)
  • java中elasticsearch7.x关于nested类型的api使用，新增+更新
  • Elasticsearch 映射参数详解 fields
  • [Elasticsearch] ES聚合场景下部分结果数据未返回问题分析
  • ES 22 - Elasticsearch中如何进行日期(数值)范围查询
  • Elasticsearch查询之Term?Query示例解析
  • ElasticSearch 实现分词全文检索 - SpringBoot 完整实现 Demo 附源码【完结篇】
  • ElasticStack学习（十）：深入ElasticSearch搜索之QueryFiltering、多/单字符串的多字段查询
  • ElasticSearch7 设置外网访问

    • Elasticsearch推荐文章

  • 利用Elasticsearch实现地理位置、城市搜索服务
  • 日志采集/分析
  • ELKF（elasticsearch、logstash、kibana、filebeat）搭建及收集nginx日志特昂糖-
  • ElasticSearch性能原理拆解
  • Elasticsearch使用实战以及代码详解
  • 使用 Docker Compose V2 快速搭建日志分析平台 ELK (Elasticsearch、Logstash 和 Kibana)
  • 【解决方案】MySQL5.7 百万数据迁移到 ElasticSearch7.x 的思考
  • K8s部署轻量级日志收集系统EFK（elasticsearch + filebeat + kibana）
  • Docker下elasticsearch8部署、扩容、基本操作实战(含kibana)
  • Elasticsearch 保姆级入门篇

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号