RustFS
世界上增长最快的分布式对象存储，根据 GitHub 的数据，RustFS 是增长最快的分布式对象存储。 RustFS 用热门安全的 Rust 语言开发，兼容 S3 协议。适用于 AI/ML 及海量数据存储、大数据、互联网、工业和保密存储等全部场景，支持国产保密设备和系统。
安装
注意：
- 树莓派4b使用：rustfs-linux-aarch64-musl-latest.zip
- 正常ubuntu使用：rustfs-linux-x86_64-musl-latest.zip
第一步：下载安装包
wget xxx
unzip rustfs-linux-x86_64-musl-latest.zip
mv rustfs /usr/local/bin/
cd /usr/local/bin/
chmod +x rustfs第二步：配置系统服务
注意挂载磁盘调整：/root/data/rustfs_oss/
sudo tee /etc/systemd/system/rustfs.service <<'EOF'
[Unit]
Description=RustFS Object Storage Server
Documentation=https://rustfs.com/docs/
After=network-online.target
Wants=network-online.target
[Service]
Type=notify
NotifyAccess=main
User=root
Group=root
Environment="RUSTFS_ACCESS_KEY=rustfsadmin"
Environment="RUSTFS_SECRET_KEY=rustfsadmin"
Environment="RUSTFS_OBS_LOG_DIRECTORY=/var/logs/rustfs/"
ExecStart=/usr/local/bin/rustfs \
server \
--address :9000 \
--console-enable \
/root/data/rustfs_oss/
StandardOutput=append:/var/logs/rustfs/rustfs.log
StandardError=append:/var/logs/rustfs/rustfs-err.log
Restart=always
RestartSec=10s
TimeoutStartSec=30s
[Install]
WantedBy=multi-user.target
EOF第三步：启动
sudo mkdir -p /root/data/rustfs_oss /var/logs/rustfs /opt/tls
sudo chmod -R 750 /root/data/rustfs_oss* /var/logs/rustfs
# 1. 重新加载配置
sudo systemctl daemon-reload
# 2. 启动服务
sudo systemctl start rustfs
# 3. 查看状态
systemctl status rustfs访问
IP:9000 API 数据接口
IP:9001 后台管理页面Java接口示例
依赖
<!--RustFS-->
<dependency>
<groupId>software.amazon.awssdk</groupId>
<artifactId>s3</artifactId>
<version>2.25.27</version>
</dependency>代码
package com.fan.model.image;
import com.fan.entity.vo.ComResult;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;
import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.core.sync.RequestBody;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.model.*;
import java.net.URI;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Objects;
/**
* 文件上传
*/
@Slf4j
@Controller
public class ImageController {
/**
* 图片上传
*/
@RequestMapping("/image/upload")
@ResponseBody
public ComResult<String> uploadImg(@RequestParam("file") MultipartFile file) throws IOException {
// 文件为空
if (file.isEmpty()) {
return ComResult.failMsg("文件不能为空");
}
// 文件后缀
String suffix = Objects.requireNonNull(file.getOriginalFilename()).substring(file.getOriginalFilename().lastIndexOf("."));
// 文件格式限制
if (!suffix.contains("png") && !suffix.contains("jpg") && !suffix.contains("gif")) {
return ComResult.failMsg("仅支持png/jpg/gif图片");
}
// 随机数字6位数字，多机模式
String random = String.valueOf((int) (Math.random() * 1000000));
// 新的文件名
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
String newFileName = sdf.format(new Date());
// 最终文件名
String name = newFileName + "_" + random;
// 完整文件名
String objectName = name + suffix;
// 初始化 S3 客户端
S3Client s3 = S3Client.builder()
.endpointOverride(URI.create("http://8.156.74.169:6003")) // RustFS 地址
.region(Region.US_EAST_1) // 可写死，RustFS 不校验 region
.credentialsProvider(
StaticCredentialsProvider.create(
AwsBasicCredentials.create("xxx", "xxx")
)
)
.forcePathStyle(true) // 关键配置！RustFS 需启用 Path-Style
.build();
// Bucket
String bucket = "house";
// 上传文件
s3.putObject(
PutObjectRequest.builder().bucket(bucket).key(objectName).build(),
RequestBody.fromByteBuffer(
java.nio.ByteBuffer.wrap(file.getBytes())
)
);
// 返回图片请求路径
return ComResult.data("添加成功", "https://fanmr.cn/oss/" + bucket + "/" + objectName);
}
}