资源上传:对象存储切换到minio OS存储

resources/nacos-yaml/webchat-admin-service-dev.yaml

@@ -0,0 +1,11 @@
+spring:
+  servlet:
+    multipart:
+      max-file-size: 10MB
+      max-request-size: 10MB
+
+minio:
+  endpoint: http://127.0.0.1:9000
+  accessKey: BArEoI6PE8uGh13jHRuN
+  secretKey: eHRL9vpXUH6vGOGkL5Vth2ZQRpzh7AvdKzNlASko
+  bucketName: webchat

resources/nacos-yaml/webchat-client-chat-service-dev.yaml

@@ -0,0 +1,11 @@
+spring:
+  servlet:
+    multipart:
+      max-file-size: 10MB
+      max-request-size: 10MB
+
+minio:
+  endpoint: http://127.0.0.1:9000
+  accessKey: BArEoI6PE8uGh13jHRuN
+  secretKey: eHRL9vpXUH6vGOGkL5Vth2ZQRpzh7AvdKzNlASko
+  bucketName: webchat

webchat-admin/pom.xml

@@ -20,6 +20,13 @@
         <java.version>17</java.version>
     </properties>
     <dependencies>
+
+        <dependency>
+            <groupId>com.webchat</groupId>
+            <artifactId>webchat-remote</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>

webchat-admin/src/main/java/com/webchat/admin/WebchatAdminApplication.java

@@ -2,8 +2,10 @@ package com.webchat.admin;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
 
 @SpringBootApplication
+@ComponentScan("com.webchat")
 public class WebchatAdminApplication {
 
     public static void main(String[] args) {

webchat-admin/src/main/java/com/webchat/admin/controller/FileController.java

@@ -0,0 +1,46 @@
+package com.webchat.admin.controller;
+
+import com.webchat.common.bean.APIResponseBean;
+import com.webchat.common.bean.APIResponseBeanUtil;
+import com.webchat.common.service.MinioService;
+import com.webchat.common.util.DateUtils;
+import com.webchat.domain.dto.UploadResultDTO;
+import com.webchat.domain.vo.response.UploadResultVO;
+import jakarta.annotation.Resource;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.Assert;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.Date;
+
+@RestController
+@RequestMapping("/admin-service/file")
+public class FileController {
+
+    @Autowired
+    private MinioService minioService;
+    @Autowired
+    private HttpServletRequest request;
+
+    @PostMapping("/upload")
+    public APIResponseBean<UploadResultVO> upload(MultipartFile file) {
+        String path = request.getHeader("upload-path");
+        Assert.isTrue(StringUtils.isNotBlank(path), "上传路径不能为空");
+        String timePackage = DateUtils.getDate2String(DateUtils.YYYYMMDD, new Date());
+        UploadResultVO uploadResultDTO = minioService.upload(path + "/" + timePackage, file, true);
+        return APIResponseBeanUtil.success(uploadResultDTO);
+    }
+
+    @GetMapping("/download")
+    public void download(@RequestParam String filename, HttpServletResponse response) {
+        minioService.download(filename, response);
+    }
+}

webchat-admin/src/main/resources/application.properties

@@ -1 +0,0 @@
-spring.application.name=webchat-admin

webchat-admin/src/main/resources/application.yml

@@ -0,0 +1 @@
+server:
  port: 8081

webchat-pgc/target/classes/bootstrap.yml → webchat-admin/src/main/resources/bootstrap.yml

@@ -1,6 +1,6 @@
 spring:
   application:
-    name: webchat-pgc-service
+    name: webchat-admin-service
   profiles:
     active: dev
   cloud:

webchat-client-chat/pom.xml

@@ -20,6 +20,12 @@
         <java.version>17</java.version>
     </properties>
     <dependencies>
+
+        <dependency>
+            <groupId>com.webchat</groupId>
+            <artifactId>webchat-remote</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>

webchat-client-chat/src/main/java/com/webchat/client/FileController.java

@@ -0,0 +1,44 @@
+package com.webchat.client;
+
+import com.webchat.common.bean.APIResponseBean;
+import com.webchat.common.bean.APIResponseBeanUtil;
+import com.webchat.common.service.MinioService;
+import com.webchat.common.util.DateUtils;
+import com.webchat.domain.vo.response.UploadResultVO;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.util.Assert;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.Date;
+
+@RestController
+@RequestMapping("/client-service/chat/file")
+public class FileController {
+
+    @Autowired
+    private MinioService minioService;
+    @Autowired
+    private HttpServletRequest request;
+
+    @PostMapping("/upload")
+    public APIResponseBean<UploadResultVO> upload(MultipartFile file) {
+        String path = request.getHeader("upload-path");
+        Assert.isTrue(StringUtils.isNotBlank(path), "上传路径不能为空");
+        String timePackage = DateUtils.getDate2String(DateUtils.YYYYMMDD, new Date());
+        UploadResultVO uploadResultDTO = minioService.upload(path + "/" + timePackage, file, true);
+        return APIResponseBeanUtil.success(uploadResultDTO);
+    }
+
+    @GetMapping("/download")
+    public void download(@RequestParam String filename, HttpServletResponse response) {
+        minioService.download(filename, response);
+    }
+}

webchat-client-chat/src/main/java/com/webchat/client/WebchatClientApplication.java

@@ -2,8 +2,10 @@ package com.webchat.client;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
 
 @SpringBootApplication
+@ComponentScan("com.webchat")
 public class WebchatClientApplication {
 
     public static void main(String[] args) {

webchat-client-chat/src/main/resources/application.properties

@@ -1 +0,0 @@
-spring.application.name=webchat-client

webchat-client-chat/src/main/resources/application.yml

@@ -0,0 +1 @@
+server:
  port: 8082

webchat-connect/target/classes/bootstrap.yml → webchat-client-chat/src/main/resources/bootstrap.yml

@@ -1,6 +1,6 @@
 spring:
   application:
-    name: webchat-connect-service
+    name: webchat-client-chat-service
   profiles:
     active: dev
   cloud:

webchat-common/pom.xml

@@ -22,6 +22,11 @@
 
     <dependencies>
         <dependency>
+            <groupId>io.minio</groupId>
+            <artifactId>minio</artifactId>
+            <version>8.4.2</version>
+        </dependency>
+        <dependency>
             <groupId>com.webchat</groupId>
             <artifactId>webchat-domain</artifactId>
             <version>1.0-SNAPSHOT</version>

webchat-common/src/main/java/com/webchat/common/config/configuration/MinioConfig.java

@@ -0,0 +1,23 @@
+package com.webchat.common.config.configuration;
+
+
+import com.webchat.common.config.properties.MinioProperties;
+import io.minio.MinioClient;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class MinioConfig {
+
+    @Autowired
+    private MinioProperties properties;
+
+    @Bean
+    public MinioClient minioClient() {
+        return MinioClient.builder()
+                .endpoint(properties.getEndpoint())
+                .credentials(properties.getAccessKey(), properties.getSecretKey())
+                .build();
+    }
+}

webchat-common/src/main/java/com/webchat/common/config/properties/MinioProperties.java

@@ -0,0 +1,19 @@
+package com.webchat.common.config.properties;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Data
+@Configuration
+@ConfigurationProperties(prefix = "minio")
+public class MinioProperties {
+
+    private String endpoint = "http://localhost:9000";
+
+    private String accessKey = "BArEoI6PE8uGh13jHRuN";
+
+    private String secretKey = "eHRL9vpXUH6vGOGkL5Vth2ZQRpzh7AvdKzNlASko";;
+
+    private String bucketName = "webchat";
+}

webchat-common/src/main/java/com/webchat/common/service/MinioService.java

@@ -0,0 +1,183 @@
+package com.webchat.common.service;
+
+import com.webchat.common.config.properties.MinioProperties;
+import com.webchat.common.enums.FileTypeEnum;
+import com.webchat.domain.dto.UploadResultDTO;
+import com.webchat.domain.vo.response.UploadResultVO;
+import io.minio.GetObjectArgs;
+import io.minio.MinioClient;
+import io.minio.PutObjectArgs;
+import io.minio.UploadObjectArgs;
+import jakarta.servlet.ServletOutputStream;
+import jakarta.servlet.http.HttpServletResponse;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.File;
+import java.io.InputStream;
+import java.net.URLEncoder;
+import java.util.Arrays;
+import java.util.List;
+
+@Service
+public class MinioService {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(MinioService.class);
+
+    @Autowired
+    private MinioClient minioClient;
+
+    @Autowired
+    private MinioProperties properties;
+
+    /**
+     * 定义图片和视频的MIME类型列表
+     */
+    private static final List<String> IMAGE_MIME_TYPES = Arrays.asList("image/jpeg", "image/png", "image/gif", "image/bmp");
+    private static final List<String> VIDEO_MIME_TYPES = Arrays.asList("video/mp4", "video/quicktime", "video/x-msvideo", "video/3gpp", "video/3gpp2", "video/webm", "video/ogg");
+
+    /**
+     * 上传文件到Minio服务器
+     *
+     * @param file
+     * @return
+     */
+    public boolean upload(File file) {
+        String filename = file.getName();
+        try {
+            minioClient.uploadObject(UploadObjectArgs.builder()
+                    .bucket(properties.getBucketName())
+                    .object(filename)
+                    .filename(file.getAbsolutePath())
+                    .build());
+            return true;
+        } catch (Exception e) {
+            LOGGER.error("file upload minio exception, file name: {}", filename, e);
+            return false;
+        }
+    }
+
+    /**
+     * 前端的文件上传
+     *
+     * @param file
+     * @return
+     */
+    public boolean upload(MultipartFile file) {
+        String filename = file.getOriginalFilename();
+        try {
+            InputStream inputStream = file.getInputStream();
+            minioClient.putObject(PutObjectArgs.builder()
+                    .bucket(properties.getBucketName())
+                    .object(filename)
+                    .stream(inputStream, inputStream.available(), -1)
+                    .contentType(file.getContentType())
+                    .build());
+            return true;
+        } catch (Exception e) {
+            LOGGER.error("file upload minio exception, file name: {}", filename, e);
+            return false;
+        }
+    }
+
+    /**
+     * 上传到Minio指定路径
+     *
+     * @param path
+     * @param file
+     * @return
+     */
+    public boolean upload(String path, MultipartFile file) {
+        String filename = file.getOriginalFilename();
+        try {
+            filename = path + filename;
+            InputStream inputStream = file.getInputStream();
+            minioClient.putObject(PutObjectArgs.builder()
+                    .bucket(properties.getBucketName())
+                    .object(filename)
+                    .stream(inputStream, inputStream.available(), -1)
+                    .contentType(file.getContentType())
+                    .build());
+            return true;
+        } catch (Exception e) {
+            LOGGER.error("file upload minio exception, file name: {}", filename, e);
+            return false;
+        }
+    }
+
+    /**
+     * 上传到Minio指定目录，可选择自定义随机文件名
+     *
+     * @param path
+     * @param file
+     * @param isRandom
+     * @return
+     */
+    public UploadResultVO upload(String path, MultipartFile file, Boolean isRandom) {
+        String filename = file.getOriginalFilename();
+        if (Boolean.TRUE.equals(isRandom)) {
+            long millis = System.currentTimeMillis();
+            String extension = filename.substring(filename.lastIndexOf(".") + 1);
+            filename = millis + "." + extension;
+        }
+        try {
+            filename = path + "/" + filename;
+            InputStream inputStream = file.getInputStream();
+            minioClient.putObject(PutObjectArgs.builder()
+                    .bucket(properties.getBucketName())
+                    .object(filename)
+                    .stream(inputStream, inputStream.available(), -1)
+                    .contentType(file.getContentType())
+                    .build());
+            String resourceUrl = properties.getEndpoint() + "/" + properties.getBucketName() + "/" + filename;
+            return UploadResultVO.of(resourceUrl, fileType(file), filename);
+        } catch (Exception e) {
+            LOGGER.error("file upload minio exception, file name: {}, source file name: {}", filename, file.getOriginalFilename(), e);
+            return null;
+        }
+    }
+
+    private String fileType(MultipartFile file) {
+        // 获取文件的MIME类型
+        String mimeType = file.getContentType();
+        // 发布动态上传文件仅支持图片和视频
+        if (IMAGE_MIME_TYPES.contains(mimeType)) {
+            return FileTypeEnum.IMAGE.name();
+        }
+        if (VIDEO_MIME_TYPES.contains(mimeType)) {
+            return FileTypeEnum.VIDEO.name();
+        }
+        return FileTypeEnum.OTHER.name();
+    }
+
+    /**
+     * 文件下载
+     *
+     * @param filename
+     * @param response
+     */
+    public void download(String filename, HttpServletResponse response) {
+        response.reset();
+        try(InputStream inputStream = minioClient.getObject(GetObjectArgs.builder()
+                .bucket(properties.getBucketName())
+                .object(filename)
+                .build())) {
+            filename = filename.substring(filename.lastIndexOf("/") + 1);
+            ServletOutputStream outputStream = response.getOutputStream();
+            response.setContentType("application/octet-stream");
+            response.setCharacterEncoding("utf-8");
+            response.addHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(filename, "UTF-8"));
+            byte[] bytes = new byte[1024];
+            int len;
+            while ((len = inputStream.read(bytes)) > 0) {
+                outputStream.write(bytes, 0, len);
+            }
+            outputStream.close();
+        } catch (Exception e) {
+            LOGGER.error("file download from minio exception, file name: {}", filename,  e);
+        }
+    }
+}

webchat-connect/target/classes/application.yml

@@ -1,2 +0,0 @@
-server:
-  port: 8088