经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » Java相关 » Java » 查看文章
Amazon S3 对象存储Java API操作记录（Minio与S3 SDK两种实现）
来源：cnblogs　　作者：东北小狐狸　　时间：2023/4/28 9:28:19　　对本文有异议

缘起

今年(2023年) 2月的时候做了个适配Amazon S3对象存储接口的需求，由于4月份自学考试临近，一直在备考就拖着没总结记录下，开发联调过程中也出现过一些奇葩的问题，最近人刚从考试缓过来顺手记录一下。

S3对象存储的基本概念

S3是什么？

Amazon S3(Simple Storage Service)对象存储出现得比较早且使用简单的RESTful API，于是成为了对象存储服务(Object Storage Service，OSS)业内的标准接口规范。

S3的逻辑模型

如下图，我们可以把S3的存储空间想象成无限的，想存储一个任意格式的文件到S3服务中，只需要知道要把它放到哪个桶(Bucket)中，它的名字（Object Id）应该是什么。

按图中的模型，可简单理解为S3是由若干个桶（Bucket）组成，每个桶中包含若干个不同标识的对象（Object），还有就是统一的访问入口(RESTful API)，这样基本就足够了。

Minio客户端方式操作S3

详细API文档：https://min.io/docs/minio/linux/developers/java/API.html

以下代码异常处理做了简化，真实使用时请注意捕获异常做处理。

引入依赖

Maven:

  1. <dependency>
  2.     <groupId>io.minio</groupId>
  3.     <artifactId>minio</artifactId>
  4.     <version>8.5.2</version>
  5. </dependency>

Gradle:

  1. dependencies {
  2.     implementation("io.minio:minio:8.5.2")
  3. }

初始化客户端

  1. private static final String HTTP_PROTOCOL = "http";
  3. private MinioClient minioClient;
  4. private String endpoint = "http://192.168.0.8:9200";
  5. private String accessKey = "testKey";
  6. private String secretKey = "testSecretKey";
  8. public void init() throws MalformedURLException {
  9.     URL endpointUrl = new URL(endpoint);
  10.     try {
  11.         // url上无端口号时，识别http为80端口，https为443端口
  12.         int port = endpointUrl.getPort() != -1 ? endpointUrl.getPort() : endpointUrl.getDefaultPort();
  13.         boolean security = HTTP_PROTOCOL.equals(endpointUrl.getProtocol()) ? false : true;
  14.         //@formatter:off
  15.         this.minioClient = MinioClient.builder().endpoint(endpointUrl.getHost(), port, security)
  16.             .credentials(accessKey, secretKey).build();
  17.         //@formatter:on
  18.         // 忽略证书校验，防止自签名证书校验失败导致无法建立连接
  19.         this.minioClient.ignoreCertCheck();
  20.     } catch (Exception e) {
  21.         e.printStackTrace();
  22.     }
  23. }

建桶

  1. public boolean createBucket(String bucket) {
  2.     try {
  3.         minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());
  4.     } catch (Exception e) {
  5.         e.printStackTrace();
  6.         return false;
  7.     }
  8.     return true;
  9. }

删桶

  1. public boolean deleteBucket(String bucket) {
  2.     try {
  3.         minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucket).build());
  4.         logger.info("删除桶[{}]成功", bucket);
  5.     } catch (Exception e) {
  6.         e.printStackTrace();
  7.         return false;
  8.     }
  9.     return true;
  10. }

判断桶是否存在

  1. public boolean bucketExists(String bucket) {
  2.     try {
  3.         return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());
  4.     } catch (Exception e) {
  5.         e.printStackTrace();
  6.         return false;
  7.     }
  8. }

上传对象

  1. public void upload(String bucket, String objectId, InputStream input) {
  2.     try {
  3.         //@formatter:off
  4.         minioClient.putObject(PutObjectArgs.builder().bucket(bucket).object(objectId)
  5.                               .stream(input, input.available(), -1)
  6.                               .build());
  7.         //@formatter:on
  8.     } catch (Exception e) {
  9.         e.printStackTrace();
  10.     }
  11. }

下载对象

提供两个下载方法，一个将输入流返回，另一个用参数输出流写出

  1. public InputStream download(String bucket, String objectId) {
  2.     try {
  3.         return minioClient.getObject(GetObjectArgs.builder().bucket(bucket).object(objectId).build());
  4.     } catch (Exception e) {
  5.         e.printStackTrace();
  6.     }
  7.     return null;
  8. }
  10. public void download(String bucket, String objectId, OutputStream output) {
  11.     //@formatter:off
  12.     try (InputStream input = minioClient.getObject(
  13.         GetObjectArgs.builder().bucket(bucket).object(objectId).build())) {
  14.         IOUtils.copyLarge(input, output);
  15.     } catch (Exception e) {
  16.         e.printStackTrace();
  17.     }
  18.     //@formatter:on
  19. }

删除对象

  1. public boolean deleteObject(String bucket, String objectId) {
  2.     //@formatter:off
  3.     try {
  4.         minioClient.removeObject(RemoveObjectArgs.builder()
  5.                                  .bucket(bucket).object(objectId).build());
  6.     } catch (Exception e) {
  7.         e.printStackTrace();
  8.     }
  9.     //@formatter:on
  10.     return true;
  11. }

判断对象是否存在

  1. public boolean objectExists(String bucket, String key) {
  2.     //@formatter:off
  3.     try {
  4.         // minio客户端未提供判断对象是否存在的方法，此方法中调用出现异常时说明对象不存在
  5.         minioClient.statObject(StatObjectArgs.builder()
  6.                                .bucket(bucket).object(key).build());
  7.     } catch (Exception e) {
  8.         return false;
  9.     }
  10.     //@formatter:on
  11.     return true;
  12. }

完整代码

  1. import java.io.InputStream;
  2. import java.io.OutputStream;
  3. import java.net.MalformedURLException;
  4. import java.net.URL;
  6. import org.apache.tomcat.util.http.fileupload.IOUtils;
  7. import org.slf4j.Logger;
  8. import org.slf4j.LoggerFactory;
  10. import io.minio.BucketExistsArgs;
  11. import io.minio.GetObjectArgs;
  12. import io.minio.MakeBucketArgs;
  13. import io.minio.MinioClient;
  14. import io.minio.PutObjectArgs;
  15. import io.minio.RemoveBucketArgs;
  16. import io.minio.RemoveObjectArgs;
  17. import io.minio.StatObjectArgs;
  19. public class S3MinioClientDemo {
  20.     private static final Logger logger = LoggerFactory.getLogger(S3MinioClientDemo.class);
  21.     private static final String HTTP_PROTOCOL = "http";
  23.     private MinioClient minioClient;
  24.     private String endpoint = "http://192.168.0.8:9200";
  25.     private String accessKey = "testKey";
  26.     private String secretKey = "testSecretKey";
  28.     public void init() throws MalformedURLException {
  29.         URL endpointUrl = new URL(endpoint);
  30.         try {
  31.             // url上无端口号时，识别http为80端口，https为443端口
  32.             int port = endpointUrl.getPort() != -1 ? endpointUrl.getPort() : endpointUrl.getDefaultPort();
  33.             boolean security = HTTP_PROTOCOL.equals(endpointUrl.getProtocol()) ? false : true;
  34.             //@formatter:off
  35.             this.minioClient = MinioClient.builder().endpoint(endpointUrl.getHost(), port, security)
  36.                     .credentials(accessKey, secretKey).build();
  37.             //@formatter:on
  38.             // 忽略证书校验，防止自签名证书校验失败导致无法建立连接
  39.             this.minioClient.ignoreCertCheck();
  40.         } catch (Exception e) {
  41.             e.printStackTrace();
  42.         }
  43.     }
  45.     public boolean createBucket(String bucket) {
  46.         try {
  47.             boolean found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());
  48.             if (found) {
  49.                 logger.info("桶名[{}]已存在", bucket);
  50.                 return false;
  51.             }
  52.             minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());
  53.         } catch (Exception e) {
  54.             e.printStackTrace();
  55.         }
  56.         return true;
  57.     }
  59.     public boolean deleteBucket(String bucket) {
  60.         try {
  61.             minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucket).build());
  62.             logger.info("删除桶[{}]成功", bucket);
  63.         } catch (Exception e) {
  64.             e.printStackTrace();
  65.             return false;
  66.         }
  67.         return true;
  68.     }
  70.     public boolean bucketExists(String bucket) {
  71.         try {
  72.             return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());
  73.         } catch (Exception e) {
  74.             e.printStackTrace();
  75.             return false;
  76.         }
  77.     }
  79.     public void upload(String bucket, String objectId, InputStream input) {
  80.         try {
  81.           //@formatter:off
  82.           minioClient.putObject(PutObjectArgs.builder().bucket(bucket).object(objectId)
  83.                      .stream(input, input.available(), -1)
  84.                      .build());
  85.           //@formatter:on
  86.         } catch (Exception e) {
  87.             e.printStackTrace();
  88.         }
  89.     }
  91.     public InputStream download(String bucket, String objectId) {
  92.         try {
  93.             return minioClient.getObject(GetObjectArgs.builder().bucket(bucket).object(objectId).build());
  94.         } catch (Exception e) {
  95.             e.printStackTrace();
  96.         }
  97.         return null;
  98.     }
  100.     public void download(String bucket, String objectId, OutputStream output) {
  101.         //@formatter:off
  102.         try (InputStream input = minioClient.getObject(
  103.                 GetObjectArgs.builder().bucket(bucket).object(objectId).build())) {
  104.             IOUtils.copyLarge(input, output);
  105.         } catch (Exception e) {
  106.             e.printStackTrace();
  107.         }
  108.         //@formatter:on
  109.     }
  111.     public boolean objectExists(String bucket, String objectId) {
  112.         //@formatter:off
  113.         try {
  114.             // minio客户端未提供判断对象是否存在的方法，此方法中调用出现异常时说明对象不存在
  115.             minioClient.statObject(StatObjectArgs.builder()
  116.                     .bucket(bucket).object(objectId).build());
  117.         } catch (Exception e) {
  118.             return false;
  119.         }
  120.         //@formatter:on
  121.         return true;
  122.     }
  124.     public boolean deleteObject(String bucket, String objectId) {
  125.         //@formatter:off
  126.         try {
  127.             minioClient.removeObject(RemoveObjectArgs.builder()
  128.                     .bucket(bucket).object(objectId).build());
  129.         } catch (Exception e) {
  130.             e.printStackTrace();
  131.         }
  132.         //@formatter:on
  133.         return true;
  134.     }
  136.     public void close() {
  137.         minioClient = null;
  138.     }
  140. }

Amazon S3 SDK方式操作S3

官方API文档：https://docs.aws.amazon.com/AmazonS3/latest/userguide/Welcome.html

这里由于项目上提供的SDK和文档都是1.x的，这里就暂时只提供1.x的代码

引入依赖

Maven:

  1. <dependency>
  2.     <groupId>com.amazonaws</groupId>
  3.     <artifactId>aws-java-sdk-s3</artifactId>
  4.     <version>1.11.300</version>
  5. </dependency>

Gradle:

  1. dependencies {   
  2.     implementation 'com.amazonaws:aws-java-sdk-s3:1.11.300'
  3. }

初始化客户端

  1. private static final Logger logger = LoggerFactory.getLogger(S3SdkDemo.class);
  3. private AmazonS3 s3client;
  4. private String endpoint = "http://192.168.0.8:9200";
  5. private String accessKey = "testKey";
  6. private String secretKey = "testSecretKey";
  8. public void init() throws MalformedURLException {
  9.     URL endpointUrl = new URL(endpoint);
  10.     String protocol = endpointUrl.getProtocol();
  11.     int port = endpointUrl.getPort() == -1 ? endpointUrl.getDefaultPort() : endpointUrl.getPort();
  13.     ClientConfiguration clientConfig = new ClientConfiguration();
  14.     clientConfig.setSignerOverride("S3SignerType");
  15.     clientConfig.setProtocol(Protocol.valueOf(protocol.toUpperCase()));
  17.     // 禁用证书检查，避免https自签证书校验失败
  18.     System.setProperty("com.amazonaws.sdk.disableCertChecking", "true");
  19.     // 屏蔽 AWS 的 MD5 校验，避免校验导致的下载抛出异常问题
  20.     System.setProperty("com.amazonaws.services.s3.disableGetObjectMD5Validation", "true");
  21.     AWSCredentials awsCredentials = new BasicAWSCredentials(accessKey, secretKey);
  22.     // 创建 S3Client 实例
  23.     AmazonS3 s3client = new AmazonS3Client(awsCredentials, clientConfig);
  24.     s3client.setEndpoint(endpointUrl.getHost() + ":" + port);
  25.     s3client.setS3ClientOptions(S3ClientOptions.builder().setPathStyleAccess(true).build());
  26.     this.s3client = s3client;
  27. }

建桶

  1. public boolean createBucket(String bucket)  {
  2.     String bucketName = parseBucketName(bucket);
  3.     try {
  4.         if (s3client.doesBucketExist(bucketName)) {
  5.             logger.warn("bucket[{}]已存在", bucketName);
  6.             return false;
  7.         }
  8.         s3client.createBucket(bucketName);
  9.     } catch (Exception e) {
  10.         e.printStackTrace();
  11.     }
  12.     return true;
  13. }

删桶

  1. public boolean deleteBucket(String bucket)  {
  2.     try {
  3.         s3client.deleteBucket(bucket);
  4.         logger.info("删除bucket[{}]成功", bucket);
  5.     } catch (Exception e) {
  6.         e.printStackTrace();
  7.         return false;
  8.     }
  9.     return true;
  10. }

判断桶是否存在

  1. public boolean bucketExists(String bucket)  {
  2.     try {
  3.         return s3client.doesBucketExist(bucket);
  4.     } catch (Exception e) {
  5.         e.printStackTrace();
  6.     }
  7.     return false;
  8. }

上传对象

  1. public void upload(String bucket, String objectId, InputStream input)  {
  2.     try {
  3.         // 创建文件上传的元数据
  4.         ObjectMetadata meta = new ObjectMetadata();
  5.         // 设置文件上传长度
  6.         meta.setContentLength(input.available());
  7.         // 上传
  8.         s3client.putObject(bucket, objectId, input, meta);
  9.     } catch (Exception e) {
  10.         e.printStackTrace();
  11.     }
  12. }

下载对象

  1. public InputStream download(String bucket, String objectId)  {
  2.     try {
  3.         S3Object o = s3client.getObject(bucket, objectId);
  4.         return o.getObjectContent();
  5.     } catch (Exception e) {
  6.         e.printStackTrace();
  7.     }
  8.     return null;
  9. }
  11. public void download(String bucket, String objectId, OutputStream out)  {
  12.     S3Object o = s3client.getObject(bucket, objectId);
  13.     try (InputStream in = o.getObjectContent()) {
  14.         IOUtils.copyLarge(in, out);
  15.     } catch (Exception e) {
  16.         e.printStackTrace();
  17.     }
  18. }

删除对象

  1. public boolean deleteObject(String bucket, String objectId)  {
  2.     try {
  3.         s3client.deleteObject(bucket, objectId);
  4.     } catch (Exception e) {
  5.         e.printStackTrace();
  6.         return false;
  7.     }
  8.     return true;
  9. }

判断对象是否存在

  1. public boolean existObject(String bucket, String objectId)  {
  2.     try {
  3.         return s3client.doesObjectExist(bucket, objectId);
  4.     } catch (Exception e) {
  5.         e.printStackTrace();
  6.         return false;
  7.     }
  8. }

完整代码

  1. import java.io.InputStream;
  2. import java.io.OutputStream;
  3. import java.net.MalformedURLException;
  4. import java.net.URL;
  6. import org.apache.tomcat.util.http.fileupload.IOUtils;
  7. import org.slf4j.Logger;
  8. import org.slf4j.LoggerFactory;
  10. import com.amazonaws.ClientConfiguration;
  11. import com.amazonaws.Protocol;
  12. import com.amazonaws.auth.AWSCredentials;
  13. import com.amazonaws.auth.BasicAWSCredentials;
  14. import com.amazonaws.services.s3.AmazonS3;
  15. import com.amazonaws.services.s3.AmazonS3Client;
  16. import com.amazonaws.services.s3.S3ClientOptions;
  17. import com.amazonaws.services.s3.model.ObjectMetadata;
  18. import com.amazonaws.services.s3.model.S3Object;
  20. /**
  21.  * S3对象存储官方SDK实现
  22.  *
  23.  * @author ZhangChenguang
  24.  * @date 2023年2月2日
  25.  */
  26. @SuppressWarnings("deprecation")
  27. public class S3SdkDemo {
  28.     private static final Logger logger = LoggerFactory.getLogger(S3SdkDemo.class);
  30.     private AmazonS3 s3client;
  31.     private String endpoint = "http://192.168.0.8:9200";
  32.     private String accessKey = "testKey";
  33.     private String secretKey = "testSecretKey";
  34.     
  35.     public void init() throws MalformedURLException {
  36.         URL endpointUrl = new URL(endpoint);
  37.         String protocol = endpointUrl.getProtocol();
  38.         int port = endpointUrl.getPort() == -1 ? endpointUrl.getDefaultPort() : endpointUrl.getPort();
  40.         ClientConfiguration clientConfig = new ClientConfiguration();
  41.         clientConfig.setSignerOverride("S3SignerType");
  42.         clientConfig.setProtocol(Protocol.valueOf(protocol.toUpperCase()));
  44.         // 禁用证书检查，避免https自签证书校验失败
  45.         System.setProperty("com.amazonaws.sdk.disableCertChecking", "true");
  46.         // 屏蔽 AWS 的 MD5 校验，避免校验导致的下载抛出异常问题
  47.         System.setProperty("com.amazonaws.services.s3.disableGetObjectMD5Validation", "true");
  48.         AWSCredentials awsCredentials = new BasicAWSCredentials(accessKey, secretKey);
  49.         // 创建 S3Client 实例
  50.         AmazonS3 s3client = new AmazonS3Client(awsCredentials, clientConfig);
  51.         s3client.setEndpoint(endpointUrl.getHost() + ":" + port);
  52.         s3client.setS3ClientOptions(S3ClientOptions.builder().setPathStyleAccess(true).build());
  53.         this.s3client = s3client;
  54.     }
  56.     public boolean createBucket(String bucket)  {
  57.         try {
  58.             s3client.createBucket(bucket);
  59.         } catch (Exception e) {
  60.             e.printStackTrace();
  61.         }
  62.         return true;
  63.     }
  65.     public boolean deleteBucket(String bucket)  {
  66.         try {
  67.             s3client.deleteBucket(bucket);
  68.             logger.info("删除bucket[{}]成功", bucket);
  69.         } catch (Exception e) {
  70.             e.printStackTrace();
  71.             return false;
  72.         }
  73.         return true;
  74.     }
  75.     
  76.     public boolean bucketExists(String bucket)  {
  77.         try {
  78.             return s3client.doesBucketExist(bucket);
  79.         } catch (Exception e) {
  80.            e.printStackTrace();
  81.         }
  82.         return false;
  83.     }
  85.     public void upload(String bucket, String objectId, InputStream input)  {
  86.         try {
  87.             // 创建文件上传的元数据
  88.             ObjectMetadata meta = new ObjectMetadata();
  89.             // 设置文件上传长度
  90.             meta.setContentLength(input.available());
  91.             // 上传
  92.             s3client.putObject(bucket, objectId, input, meta);
  93.         } catch (Exception e) {
  94.             e.printStackTrace();
  95.         }
  96.     }
  98.     public InputStream download(String bucket, String objectId)  {
  99.         try {
  100.             S3Object o = s3client.getObject(bucket, objectId);
  101.             return o.getObjectContent();
  102.         } catch (Exception e) {
  103.             e.printStackTrace();
  104.         }
  105.         return null;
  106.     }
  108.     public void download(String bucket, String objectId, OutputStream out)  {
  109.         S3Object o = s3client.getObject(bucket, objectId);
  110.         try (InputStream in = o.getObjectContent()) {
  111.             IOUtils.copyLarge(in, out);
  112.         } catch (Exception e) {
  113.             e.printStackTrace();
  114.         }
  115.     }
  117.     public boolean existObject(String bucket, String objectId)  {
  118.         try {
  119.             return s3client.doesObjectExist(bucket, objectId);
  120.         } catch (Exception e) {
  121.             e.printStackTrace();
  122.             return false;
  123.         }
  124.     }
  126.     public boolean deleteObject(String bucket, String objectId)  {
  127.         try {
  128.             s3client.deleteObject(bucket, objectId);
  129.         } catch (Exception e) {
  130.             e.printStackTrace();
  131.             return false;
  132.         }
  133.         return true;
  134.     }
  136.     public void close()  {
  137.         s3client = null;
  138.     }
  139. }

遇到的问题

1、bucket名称必须是小写，不支持下划线

  • 处理方式：写方法转换下bucket名称，将大写转小写，将下划线替换为中划线。

2、minio客户端下载非官方S3存储的文件时，如果响应头的Content-Length与实际文件大小不符，会导致minio客户端包装的okhttp3报错

报错信息：

  1. Caused by: java.net.ProtocolException: unexpected end of stream
  2.         at okhttp3.internal.http1.Http1ExchangeCodec$FixedLengthSource.read(Http1ExchangeCodec.java:430) ~[okhttp-3.14.9.jar:?]
  3.         at okhttp3.internal.connection.Exchange$ResponseBodySource.read(Exchange.java:286) ~[okhttp-3.14.9.jar:?]
  4.         at okio.RealBufferedSource$1.read(RealBufferedSource.java:447) ~[okio-1.17.2.jar:?]
  5.         at com.jiuqi.nr.file.utils.FileUtils.writeInput2Output(FileUtils.java:83) ~[nr.file-2.5.7.jar:?]
  6.         at com.jiuqi.nr.file.impl.FileAreaServiceImpl.download(FileAreaServiceImpl.java:395) ~[nr.file-2.5.7.jar:?]
  7.         ... 122 more

抓包发现问题的图：

最终换成了S3官方SDK可用了。

PS：客户现场部署的S3是浪潮公司提供的，如果现场遇到这个情况，就不要固执去找对方对线了，完全没用。。

总结

S3存储的基本操作就记录到这里了，由于没有S3存储就没尝试官方SDK的V2版本，由于这些代码是总结时从业务代码里抽取出来的，可能会有点问题，但大体思路已经有了。

希望对读者有所用处，觉得写得不错和有帮到你，欢迎点个赞，您的支持就是我的鼓励！

原文链接：https://www.cnblogs.com/hellxz/p/17359828.html

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

Java热门文章

  • 【IDEA】Application context not configured for this file
  • [IDEA] chapter_reader - idea看小说插件 idea阅读插件 idea摸鱼插件
  • thrift常见异常及原因分析
  • Java 调用 PaddleDetection 模型
  • JVM 详解，大白话带你认识 JVM
  • spring-boot-2.0.3不一样系列之番外篇 - @Configuration、Condition与@Conditional
  • Java Comparator.comparing比较导致空指针异常的解决
  • Java使用EasyExcel进行单元格合并的问题详解
  • 死磕 java集合之ArrayBlockingQueue源码分析
  • Java基础之集合Set详解

    • Java推荐文章

  • 面试场景题：一次关于线程池使用场景的讨论。
  • 前端黑科技：使用 JavaScript 实现网页扫码功能
  • 聊一聊 Netty 数据搬运工 ByteBuf 体系的设计与实现
  • 简单设计一个JAVA并行处理工具类
  • 【杂谈】JPA乐观锁改悲观锁遇到的一些问题与思考
  • 认识netty的基本组件
  • Jenkins如何使用CrumbIssuer防御CSRF攻击
  • 如何平稳地从nacos迁移到r-nacos？
  • 线程池遇到父子任务，有大坑，要注意！
  • Java JVM——12. 垃圾回收理论概述

    • 本站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号