平替MinIO国产存储，用Java玩转RustFS，对象存储竟能这么丝滑

用Java玩转RustFS，对象存储竟能这么丝滑

Hello！这里是程序员 Feri—— 13 年 + 开发经验、带过团队、创过业，专注分享编程知识干货。感谢你的关注与交流，愿我们能相伴你的编程路。我始终坚信：努力，什么时候开始都不晚！ Feri 领航，编程不迷茫；君之所向，一往无前！

今天必须安利一个国产化替代的对象存储技术，我司之前一直使用的都是MinIO，最新的项目要求使用国产化替代，来来来，好好学！

我信任这个技术用过的人绝对少的可怜，你绝对没有用过，由于我也是第一次使用，哈哈！

作为Java开发者，你是不是也曾遇到过这些糟心事儿：想对接对象存储，却被各种私有API搞得头大；传大文件时断网就得从头再来；担心密钥泄露不敢让前端直接传文件……别慌，今天给大家安利一个“宝藏工具”——RustFS，这款用Rust写的分布式存储系统，不仅安全高效，还完美兼容S3协议，用你熟悉的AWS SDK就能搞定所有操作！

平替MinIO国产存储，用Java玩转RustFS，对象存储竟能这么丝滑

接下来咱们就从环境搭建到高级功能，手把手带你解锁RustFS的丝滑体验。

一、先搞懂：为啥RustFS对Java开发者这么友善？

在开始敲代码前，先跟大家掰扯下RustFS的“过人之处”：

零学习成本：兼容S3协议，意味着你不用学新API，拿熟悉的AWS SDK就能直接怼；
Rust加持够安全：内存安全、无泄漏，跑生产环境不用天天担心崩溃；
大文件友善：支持分片上传、断点续传，传几个G的文件也不怕断网；
配置简单：不用复杂的集群部署，单机测试分分钟搞定。

简单说，就是“用你会的工具，做你要的存储”，这不香吗？

平替MinIO国产存储，用Java玩转RustFS，对象存储竟能这么丝滑

二、三步搞定环境：从0到1搭好开发架子

话不多说，咱们直接上干货。按照文档推荐，用AWS SDK v2（功能更全，还支持异步），三步就能搭好环境。

第一步：建个Maven项目

不用搞花里胡哨的结构，标准Maven项目就行，目录长这样：

rustfs-java-demo/
├── pom.xml  # 放依赖
└── src/main/java/com/example/
    └── RustfsS3Example.java  # 核心代码

第二步：加依赖

在pom.xml里添上AWS SDK v2的S3依赖，版本直接用文档里的2.25.27（稳定不踩坑）：

<dependencies>
    <!-- AWS S3 SDK v2 核心依赖 -->
    <dependency>
        <groupId>software.amazon.awssdk</groupId>
        <artifactId>s3</artifactId>
        <version>2.25.27</version>
    </dependency>
</dependencies>

如果后面要用到预签名URL，记得再加个s3-presigner依赖，这个咱们后面讲。

第三步：验证环境

把项目导入IDEA或Eclipse，只要依赖不爆红，环境就没问题。接下来就是核心的客户端初始化了！

三、避坑指南：客户端初始化这3个配置必对

初始化S3客户端是关键一步，文档里的代码很详细，但有3个“坑点”必须注意，否则分分钟报错。咱们先看完整代码，再逐个拆解：

package com.example;

import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;

import java.net.URI;

public class RustfsS3Example {
    public static void main(String[] args) {
        // 1. 初始化RustFS客户端
        S3Client s3 = S3Client.builder()
                // 坑点1：必须指定RustFS的地址（IP+端口），默认9000
                .endpointOverride(URI.create("http://192.168.1.100:9000"))
                // 坑点2：region随意填（RustFS不校验），但不能不填
                .region(Region.US_EAST_1)
                // 坑点3：必须启用Path-Style，否则报301错误
                .forcePathStyle(true)
                // 填RustFS的AccessKey和SecretKey（默认是rustfsadmin/rustfssecret，生产要改！）
                .credentialsProvider(
                        StaticCredentialsProvider.create(
                                AwsBasicCredentials.create("rustfsadmin", "rustfssecret")
                        )
                )
                .build();

        System.out.println("客户端初始化成功！");
    }
}

平替MinIO国产存储，用Java玩转RustFS，对象存储竟能这么丝滑

敲黑板：3个避坑重点

endpointOverride不能少：RustFS不是AWS官方服务，必须指定你自己部署的RustFS地址，格式是http://IP:9000；
forcePathStyle(true)是刚需：S3有两种访问风格，RustFS只支持“路径风格”（列如http://IP:9000/桶名/文件名），不设这个会报301 Moved Permanently；
AccessKey/SecretKey别填错：默认是rustfsadmin和rustfssecret，生产环境必定要改，不然数据不安全！

四、实战：5分钟搞定对象存储CRUD

客户端初始化好后，咱们来实操最常用的“增删改查”——创建桶、上传文件、下载文件、列对象、删对象，代码都给你贴好了，复制就能用。

1. 创建存储桶（Bucket）

桶就像“文件夹”，用来存对象，注意桶名在RustFS里要唯一：

String bucketName = "my-first-rustfs-bucket";
try {
    // 创建桶
    s3.createBucket(CreateBucketRequest.builder().bucket(bucketName).build());
    System.out.println("桶创建成功：" + bucketName);
} catch (BucketAlreadyExistsException | BucketAlreadyOwnedByYouException e) {
    // 捕获“桶已存在”的异常，避免程序崩溃
    System.out.println("桶已经存在，不用重复创建～");
}

2. 上传文件（Put Object）

传个本地的hello.txt试试，一行代码搞定：

// 上传本地文件到桶里，key是“hello.txt”（相当于文件名）
s3.putObject(
        PutObjectRequest.builder().bucket(bucketName).key("hello.txt").build(),
        Paths.get("hello.txt")  // 本地文件路径
);
System.out.println("文件上传成功！");

3. 下载文件（Get Object）

把刚才传的文件下载到本地，命名为downloaded-hello.txt：

s3.getObject(
        GetObjectRequest.builder().bucket(bucketName).key("hello.txt").build(),
        Paths.get("downloaded-hello.txt")  // 下载后的本地路径
);
System.out.println("文件下载成功！");

4. 列出桶里的所有对象

看看桶里有哪些文件，用listObjectsV2就行：

ListObjectsV2Response listResponse = s3.listObjectsV2(
        ListObjectsV2Request.builder().bucket(bucketName).build()
);
// 遍历输出所有对象的key
listResponse.contents().forEach(obj -> System.out.println("找到对象：" + obj.key()));

5. 删除对象

用完的文件可以删掉，避免占空间：

s3.deleteObject(
        DeleteObjectRequest.builder().bucket(bucketName).key("hello.txt").build()
);
System.out.println("对象删除成功！");

运行代码，控制台依次输出“创建桶成功→上传成功→下载成功→列出对象→删除成功”，整个流程丝滑得不行～

平替MinIO国产存储，用Java玩转RustFS，对象存储竟能这么丝滑

五、高级玩法：解决Java开发者的2个核心痛点

基础CRUD够用了，但实际开发中还有两个难题：前端直接传文件怕泄露密钥、大文件上传断网要重传。别急，RustFS的预签名URL和分片上传正好能解决这两个问题。

1. 预签名URL：前端直传不用暴露密钥

预签名URL是个“临时通行证”——Java后端生成一个有有效期的URL，前端拿着这个URL就能直接传文件到RustFS，不用知道AccessKey/SecretKey，超安全！

第一步：加依赖

先在pom.xml里加s3-presigner依赖：

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>s3-presigner</artifactId>
    <version>2.25.27</version>
</dependency>

第二步：生成上传URL（前端用）

生成一个10分钟有效期的上传URL，前端用PUT方法就能传文件：

import software.amazon.awssdk.services.s3.presigner.S3Presigner;
import software.amazon.awssdk.services.s3.presigner.model.PresignedPutObjectRequest;
import software.amazon.awssdk.services.s3.presigner.model.PutObjectPresignRequest;

// 初始化预签名客户端（配置和S3Client一致）
S3Presigner presigner = S3Presigner.builder()
        .endpointOverride(URI.create("http://192.168.1.100:9000"))
        .region(Region.US_EAST_1)
        .credentialsProvider(
                StaticCredentialsProvider.create(
                        AwsBasicCredentials.create("rustfsadmin", "rustfssecret")
                )
        )
        .build();

// 生成上传URL
PutObjectRequest putRequest = PutObjectRequest.builder()
        .bucket(bucketName)
        .key("user-avatar.jpg")  // 前端要上传的文件名
        .build();

// 设置URL有效期10分钟
PutObjectPresignRequest presignRequest = PutObjectPresignRequest.builder()
        .putObjectRequest(putRequest)
        .signatureDuration(Duration.ofMinutes(10))
        .build();

// 拿到预签名URL
PresignedPutObjectRequest presignedPut = presigner.presignPutObject(presignRequest);
System.out.println("前端上传URL：" + presignedPut.url());

前端拿到这个URL后，用Axios发个PUT请求就能传文件，后端完全不用管上传过程，省事儿！

2. 分片上传：大文件断网不用重传

传几个G的压缩包或视频时，最怕断网——普通上传得从头再来，分片上传则是“分而治之”：把大文件切成多个小分片（列如50MB一个），传完的分片不用重传，效率直接拉满。

完整流程：3步搞定大文件上传

import java.util.ArrayList;
import java.util.List;
import software.amazon.awssdk.services.s3.model.*;

// 1. 启动分片上传，拿到uploadId（唯一标识这次上传）
CreateMultipartUploadRequest createRequest = CreateMultipartUploadRequest.builder()
        .bucket(bucketName)
        .key("bigfile.zip")  // 要上传的大文件名
        .build();
CreateMultipartUploadResponse createResponse = s3.createMultipartUpload(createRequest);
String uploadId = createResponse.uploadId();
System.out.println("分片上传ID：" + uploadId);

// 2. 上传每个分片（假设切成3个分片，part1.bin、part2.bin、part3.bin）
List<CompletedPart> completedParts = new ArrayList<>();
for (int partNum = 1; partNum <= 3; partNum++) {
    String partPath = "part" + partNum + ".bin";  // 每个分片的本地路径
    UploadPartRequest uploadPartRequest = UploadPartRequest.builder()
            .bucket(bucketName)
            .key("bigfile.zip")
            .uploadId(uploadId)
            .partNumber(partNum)  // 分片编号（从1开始）
            .build();

    // 上传分片，拿到eTag（用来校验分片）
    UploadPartResponse uploadPartResponse = s3.uploadPart(uploadPartRequest, Paths.get(partPath));
    completedParts.add(
            CompletedPart.builder()
                    .partNumber(partNum)
                    .eTag(uploadPartResponse.eTag())
                    .build()
    );
    System.out.println("分片" + partNum + "上传成功");
}

// 3. 完成分片上传（把所有分片合并成完整文件）
CompletedMultipartUpload completedUpload = CompletedMultipartUpload.builder()
        .parts(completedParts)
        .build();
CompleteMultipartUploadRequest completeRequest = CompleteMultipartUploadRequest.builder()
        .bucket(bucketName)
        .key("bigfile.zip")
        .uploadId(uploadId)
        .multipartUpload(completedUpload)
        .build();

s3.completeMultipartUpload(completeRequest);
System.out.println("大文件分片上传完成！");