oss存储

<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.10.2</version>
</dependency>
导入依赖

  1. package com.zax.appmanage.util;
  3. import com.aliyun.oss.ClientException;
  4. import com.aliyun.oss.OSS;
  5. import com.aliyun.oss.OSSClientBuilder;
  6. import com.aliyun.oss.OSSException;
  7. import com.aliyun.oss.model.CannedAccessControlList;
  8. import com.aliyun.oss.model.GetObjectRequest;
  10. import java.io.ByteArrayInputStream;
  11. import java.io.File;
  13. /**
  14.  * @author HMB-XS
  15.  * @date 2022年07月03日 12:01:26
  16.  * 阿里云OSS工具类
  17.  * 属性必须配置否则出错,第一次使用先初始化存储桶
  18.  * 目前只提供了上传和下删除的方法
  19.  * 如果要修改文件只需要重新上传同名文件即可，新文件覆盖旧文件
  20.  * 使用该工具类需要在pom.xml中添加依赖：
  21.  *
  22.  * <dependency>
  23.  *             <groupId>com.aliyun.oss</groupId>
  24.  *             <artifactId>aliyun-sdk-oss</artifactId>
  25.  *             <version>3.10.2</version>
  26.  *</dependency>
  27.  **/
  28. public class OssAliyunUtil {
  29.     /**Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。*/
  30.     private static  String endpoint = "oss-cn-hangzhou.aliyuncs.com";
  31.     /**阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维，
  32.      请登录RAM控制台创建RAM用户。*/
  33.     private static final   String accessKeyId = "LTAI5tAxfhT9VuogVAq1JkTu";
  34.     private static final String accessKeySecret = "OQxDr5xZXnjQlqHXC8MT8vKi8xaUfV";
  35.     /**填写Bucket名称，例如examplebucket。*/
  36.     private static final String bucketName = "zax2517";
  37.     /**创建OSSClient实例。*/
  38.     private static OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret);
  39.     //文件地址
  40.     private static final String filePath="https://zax2517.oss-cn-hangzhou.aliyuncs.com/";
  41.     /**
  42.      * 创建存储桶初始化(只需要执行一次，请不要重复执行)
  43.      */
  44.     public static void newBucket(){
  45.         try {
  46.             // 创建存储空间。
  47.             ossClient.createBucket(bucketName);
  48.             // 设置存储空间的读写权限。例如将examplebucket的读写权限ACL设置为公开读PublicRead
  49.             ossClient.setBucketAcl(bucketName, CannedAccessControlList.PublicRead);
  50.         } catch (OSSException oe) {
  51.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  52.                     + "but was rejected with an error response for some reason.");
  53.             System.out.println("Error Message:" + oe.getErrorMessage());
  54.             System.out.println("Error Code:" + oe.getErrorCode());
  55.             System.out.println("Request ID:" + oe.getRequestId());
  56.             System.out.println("Host ID:" + oe.getHostId());
  57.         } catch (ClientException ce) {
  58.             System.out.println("Caught an ClientException, which means the client encountered "
  59.                     + "a serious internal problem while trying to communicate with OSS, "
  60.                     + "such as not being able to access the network.");
  61.             System.out.println("Error Message:" + ce.getMessage());
  62.         }
  63.     }
  65.     /**
  66.      * 上传文件功能
  67.      * @param objectName 文件全名称，包含文件后缀
  68.      * @param file 文件对象Byte[]
  69.      */
  70.     public static void uploadFile(String objectName,byte[] file){
  71.         try {
  72.             ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(file));
  73.         } catch (OSSException oe) {
  74.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  75.                     + "but was rejected with an error response for some reason.");
  76.             System.out.println("Error Message:" + oe.getErrorMessage());
  77.             System.out.println("Error Code:" + oe.getErrorCode());
  78.             System.out.println("Request ID:" + oe.getRequestId());
  79.             System.out.println("Host ID:" + oe.getHostId());
  80.         } catch (ClientException ce) {
  81.             System.out.println("Caught an ClientException, which means the client encountered "
  82.                     + "a serious internal problem while trying to communicate with OSS, "
  83.                     + "such as not being able to access the network.");
  84.             System.out.println("Error Message:" + ce.getMessage());
  85.         }
  86.     }
  90.     /**
  91.      * 文件下载
  92.      * 参数一：objectName:文件在bucket中的位置
  93.      * 参数二：pathName:下载到本地的保存路径
  94.      * File file(pathName)
  95.      */
  96.     public static void exportOssFile(String objectName){
  97.         try {
  98.             // 下载Object到本地文件，并保存到指定的本地路径中。如果指定的本地文件存在会覆盖，不存在则新建。
  99.             // 如果未指定本地路径，则下载后的文件默认保存到示例程序所属项目对应本地路径中。
  100.             ossClient.getObject(new GetObjectRequest(bucketName, objectName));
  101.         } catch (OSSException oe) {
  102.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  103.                     + "but was rejected with an error response for some reason.");
  104.             System.out.println("Error Message:" + oe.getErrorMessage());
  105.             System.out.println("Error Code:" + oe.getErrorCode());
  106.             System.out.println("Request ID:" + oe.getRequestId());
  107.             System.out.println("Host ID:" + oe.getHostId());
  108.         } catch (ClientException ce) {
  109.             System.out.println("Caught an ClientException, which means the client encountered "
  110.                     + "a serious internal problem while trying to communicate with OSS, "
  111.                     + "such as not being able to access the network.");
  112.             System.out.println("Error Message:" + ce.getMessage());
  113.         }
  114.     }
  117.     /**
  118.      * 文件删除功能
  119.      * @param objectName 文件全名称，包含文件后缀
  120.      */
  121.     public static void deleteFile(String objectName){
  122.         try {
  123.             // 删除文件。
  124.             ossClient.deleteObject(bucketName, objectName);
  125.         } catch (OSSException oe) {
  126.             System.out.println("Caught an OSSException, which means your request made it to OSS, "
  127.                     + "but was rejected with an error response for some reason.");
  128.             System.out.println("Error Message:" + oe.getErrorMessage());
  129.             System.out.println("Error Code:" + oe.getErrorCode());
  130.             System.out.println("Request ID:" + oe.getRequestId());
  131.             System.out.println("Host ID:" + oe.getHostId());
  132.         } catch (ClientException ce) {
  133.             System.out.println("Caught an ClientException, which means the client encountered "
  134.                     + "a serious internal problem while trying to communicate with OSS, "
  135.                     + "such as not being able to access the network.");
  136.             System.out.println("Error Message:" + ce.getMessage());
  137.         }
  138.     }
  140.     /**
  141.      * 断开连接池，关机
  142.      */
  143.     public static void shutdown(){
  144.         if (ossClient != null) {
  145.                 ossClient.shutdown();
  146.             }
  147.     }
  149.     /**
  150.      * 获取地域信息
  151.      * @return String
  152.      */
  153.     public static String getEndpoint() {
  154.         return endpoint;
  155.     }
  157.     /**
  158.      * 获取存储桶信息
  159.      * @return String
  160.      */
  161.     public static String getBucketName() {
  162.         return bucketName;
  163.     }
  164.     public static String getFilePath(){
  165.         return filePath;
  166.     }
  167. }

上传功能

  1.  @Transactional
  2.     @RequestMapping("/Add_version")
  3.     public String addVersion(AppVersion appVersion, MultipartFile photo){
  4.         System.out.println(appVersion.getInfoId());
  5.         String filename = photo.getOriginalFilename();
  6.         appVersion.setApkFileName(filename);
  7.         if (appVersion.getVersionNo()==null||appVersion.getVersionSize()==null){
  8.             return "/";
  9.         }
  10.         if (!StringUtils.isBlank(filename)) {
  11.             //获取上传的文件名
  12.             //截取文件后缀名
  13.             String hzm = filename.substring(filename.lastIndexOf("."));
  14.             //根据时间戳生成的唯一文件名
  15.             String finalName = System.currentTimeMillis() + hzm;
  16.             try {
  17.                 OssAliyunUtil.uploadFile(finalName, photo.getBytes());
  18.                 appVersion.setDownloadLink(OssAliyunUtil.getFilePath()+finalName);
  19.             } catch (Exception e) {
  20.                 e.printStackTrace();
  21.             }
  22.         }
  23.         int i1 = appVersionService.insertVersion(appVersion);
  24.         int i = iAppInfoService.updateVersion(appVersion.getInfoId());
  25.         return "redirect:/index";
  26.     }

分页导航栏

  1. //新建一个数组，用来存放分页导航栏
  2.         List<Integer> pages = new ArrayList<>();
  3.         //将当前页放入数组
  4.         pages.add(pageNum);//pageNum为当前页
  5.         for (int i = 1; i <= 5; i++) {//当数据里的数只有1-3个
  6.             //左边的元素
  7.             if (pageNum - i > 0) {
  8.                 pages.add(0, pageNum - i);
  9.             }
  10.             //右边的元素
  11.             if (pageNum + i <= page.getPages()) {// questions.getPages()从MybatisPlus分页插件中查出分页条数
  12.                 pages.add(pageNum + i);
  13.             }
  14.         }