springboot整合minio实现文件存储功能

docker pull minio/minio
新版本： 
docker run \
  -p 9000:9000 \
  -p 9001:9001 \
  --name minio \
  -d --restart=always \
  -e "MINIO_ROOT_USER=admin" \
  -e "MINIO_ROOT_PASSWORD=admin123456" \
  -v /home/data:/data \
  -v /home/config:/root/.minio \
  minio/minio server /data --console-address ":9001"
 
 

<dependency>
    <groupId>io.minio</groupId>
    <artifactId>minio</artifactId>
    <version>8.2.0</version>
</dependency>

minio:
  endpointUrl: http://192.168.17.166:9000
  accessKey: admin
  secreKey: admin123456
  bucketName: gmall
 

 @RestController
@RequestMapping("/admin/product")
public class FileController {
    //由于参数不固定,因此需要从配置文件读取,有两种方式①@value注解②创建实体类使用@configurationproperties注解指定前缀注入
    @Value("${minio.endpointUrl}")
    private String endpointUrl; //文件服务器登录地址
    @Value("${minio.accessKey}")
    private String accessKey; //用户名
    @Value("${minio.secreKey}")
    private String secreKey;  //密码
    @Value("${minio.bucketName}")
    private String bucketName; //储存桶名称
 
 
    /**
     * @Description: 上传图片到minio文件服务器
     * @Param: MultipartFile
     * @return:
     * @Author: Mr.Zhan
     * @Date: 2022/3/28  17:59
     */
    @PostMapping("/fileUpload")
    public Result fileUpload(MultipartFile file) {
        String result =null;
        try {
            // 创建minio的客户端
            MinioClient minioClient =
                    MinioClient.builder()
                            .endpoint(endpointUrl)  //指定文件服务器地址,用户名,密码
                            .credentials(accessKey, secreKey)
                            .build();
 
            // 判断存储桶是否存在
            boolean found =
                    minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            if (!found) {
                // 不存在则创建一个桶
                minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
            } else {
                throw new GmallException("存储桶已经存在", 20001);
            }
 
            //准备上传的图片名称
            String fileName = System.currentTimeMillis() + UUID.randomUUID().toString().replaceAll("-", "") + file.getOriginalFilename();
            //使用流上传文件
            /*
             * ①bucketName 存储桶名字
             * ②fileName   文件名称
             * ③ file.getInputStream() 文件流
             * ④file.getSize()文件大小
             * file.getContentType() 文件类型
             * */
            minioClient.putObject(
                    PutObjectArgs.builder().bucket(bucketName).object(fileName).stream(
                            file.getInputStream(), file.getSize(), -1)
                            .contentType(file.getContentType())
                            .build());
            result=endpointUrl + "/" + bucketName + "/" + fileName;
 
            
        } catch (ErrorResponseException e) {
            e.printStackTrace();
        } catch (InsufficientDataException e) {
            e.printStackTrace();
        } catch (InternalException e) {
            e.printStackTrace();
        } catch (InvalidKeyException e) {
            e.printStackTrace();
        } catch (InvalidResponseException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (XmlParserException e) {
            e.printStackTrace();
        }
        return Result.ok(result);
    }
}
 

注意：文件上传时，需要调整一下linux 服务器的时间与windows 时间一致！
第一步：安装ntp服务
yum -y install ntp
 
第二步：开启开机启动服务
systemctl enable ntpd
 
第三步：启动服务
systemctl start ntpd
 
第四步：更改时区
timedatectl set-timezone Asia/Shanghai
 
第五步：启用ntp同步
timedatectl set-ntp yes
 
第六步：同步时间
ntpq -p