装潢公司设计效果图_网页设计师做什么_济南网站建设哪家好_百度云资源搜索入口

此博文内容为：

1. 使用SDK创建bucket；

1. 使用SDK上传文件；

1. 使用SDK下载文件。

maven添加：

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

首先使用Java SDK创建一个客户端实例：

MinioClient minioClient = MinioClient.builder().endpoint("http://192.168.36.128:9000").credentials("minioadmin", "minioadmin").build();

随后创建一个bucket

minioClient.makeBucket(MakeBucketArgs.builder().bucket("user1").build());

上传文件：

FileInputStream fileInputStream = new FileInputStream("C:\\Users\\cff\\Desktop\\test.pdf");ObjectWriteResponse writeResponse = minioClient.putObject(PutObjectArgs.builder().bucket("user1").object("test.pdf").stream(fileInputStream, fileInputStream.available(), -1).build());System.out.println("writeResponse : " + writeResponse.etag() + " " + writeResponse.versionId(

这里有一个要注意的地方：

        public PutObjectArgs.Builder stream(InputStream stream, long objectSize, long partSize) {this.validateNotNull(stream, "stream");long[] partinfo = this.getPartInfo(objectSize, partSize);long pSize = partinfo[0];int pCount = (int)partinfo[1];BufferedInputStream bis = stream instanceof BufferedInputStream ? (BufferedInputStream)stream : new BufferedInputStream(stream);return this.setStream(bis, objectSize, pSize, pCount);}

这个PutObjectArgs是上传接口partSize是分片，这里我填写的是-1。

下载文件：

try (InputStream stream =minioClient.getObject(GetObjectArgs.builder().bucket("user1").object("test.pdf").build())) {// Read the streamsaveFile(stream, "C:\\Users\\cff\\Desktop\\test2.pdf");
}catch (Exception e){e.printStackTrace();
}

完整代码如下：

package cn.minio.test;import io.minio.*;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;import java.io.*;@SpringBootApplication
public class Main implements CommandLineRunner {public static void main(String[] args) {SpringApplication.run(Main.class, args);}void saveFile(InputStream inputStream, String saveFile){try (OutputStream outputStream = new FileOutputStream(saveFile)) {// 读取源文件数据并写入目标文件byte[] buffer = new byte[1024];int bytesRead;while ((bytesRead = inputStream.read(buffer)) != -1) {outputStream.write(buffer, 0, bytesRead);}System.out.println("文件保存成功！");} catch (IOException e) {e.printStackTrace();}}public void run(String... args) throws Exception {MinioClient minioClient = MinioClient.builder().endpoint("http://192.168.36.128:9000").credentials("minioadmin", "minioadmin").build();minioClient.makeBucket(MakeBucketArgs.builder().bucket("user1").build());FileInputStream fileInputStream = new FileInputStream("C:\\Users\\cff\\Desktop\\test.pdf");ObjectWriteResponse writeResponse = minioClient.putObject(PutObjectArgs.builder().bucket("user1").object("test.pdf").stream(fileInputStream, fileInputStream.available(), -1).build());System.out.println("writeResponse : " + writeResponse.etag() + " " + writeResponse.versionId());try (InputStream stream =minioClient.getObject(GetObjectArgs.builder().bucket("user1").object("test.pdf").build())) {// Read the streamsaveFile(stream, "C:\\Users\\cff\\Desktop\\test2.pdf");}catch (Exception e){e.printStackTrace();}}
}

程序运行截图如下：

源码打包下载地址：

Java/MinIOTest at master · fengfanchen/Java · GitHub