minio public桶禁止在直接访问桶位置时列出所有文件url

news2024/9/28 9:31:59

minio的public桶因为没有限制，所以在直接访问到桶地址的时候会列出桶内所有文件的url，这样很不安全，如何禁止这个功能，可以使用三种方法

1、如果是新版的可以直接设置桶的Access Policy为自定义就好

 编辑custom的Policy，去掉Action集合中的ListBucket就可以了，如下是去掉后的json

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "AWS": [
                    "*"
                ]
            },
            "Action": [
                "s3:GetBucketLocation",
                "s3:ListBucketMultipartUploads"
            ],
            "Resource": [
                "arn:aws:s3:::桶名称"
            ]
        },
        {
            "Effect": "Allow",
            "Principal": {
                "AWS": [
                    "*"
                ]
            },
            "Action": [
                "s3:AbortMultipartUpload",
                "s3:DeleteObject",
                "s3:GetObject",
                "s3:ListMultipartUploadParts",
                "s3:PutObject"
            ],
            "Resource": [
                "arn:aws:s3:::桶名称/*"
            ]
        }
    ]
}

设置完后

2、有些minio版本不支持直接设置，那就要通过minio Client设置桶的custom的Policy了

下载地址：http://dl.minio.org.cn/client/mc/release/linux-amd64/mc

 下载后放到服务器上，然后根据以下命令运行即可

（1）添加连接服务

        ./mc config host add minio http://127.0.0.1:9000 用户名 密码

（2）查看已连接的服务，查看上步添加的minio连接服务是否成功

        ./mc config host list

（3）置PUBLIC桶的访问权限

        ./mc anonymous set-json  /home/aadata/minio/自定义桶的Policy的json文件.json  minio/桶名

        自定义桶的Policy的json文件.json文件如下

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "AWS": [
                    "*"
                ]
            },
            "Action": [
                "s3:GetBucketLocation",
                "s3:ListBucketMultipartUploads"
            ],
            "Resource": [
                "arn:aws:s3:::桶名"
            ]
        },
        {
            "Effect": "Allow",
            "Principal": {
                "AWS": [
                    "*"
                ]
            },
            "Action": [
                "s3:AbortMultipartUpload",
                "s3:DeleteObject",
                "s3:GetObject",
                "s3:ListMultipartUploadParts",
                "s3:PutObject"
            ],
            "Resource": [
                "arn:aws:s3:::桶名/*"
            ]
        }
    ]
}

（4）删除第一部添加的服务

        ./mc config host remove minio 

3、直接代码中实现设置桶的Policy，参照下面代码自行理解吧

import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;

import io.minio.*;
import io.minio.http.Method;

public class Minio {


    /**
     * minio参数
     */
    private static final String ENDPOINT = "http://127.0.0.1:9000";
    private static final String ACCESS_KEY = "******";
    private static final String SECRET_KEY = "******";

/**
     * 桶占位符
     */
    private static final String BUCKET_PARAM = "${bucket}";
    /**
     * bucket权限-只读
     */
    private static final String READ_ONLY = "{\"Version\":\"2012-10-17\",\"Statement\":[{\"Effect\":\"Allow\",\"Principal\":{\"AWS\":[\"*\"]},\"Action\":[\"s3:GetBucketLocation\",\"s3:ListBucket\"],\"Resource\":[\"arn:aws:s3:::" + BUCKET_PARAM + "\"]},{\"Effect\":\"Allow\",\"Principal\":{\"AWS\":[\"*\"]},\"Action\":[\"s3:GetObject\"],\"Resource\":[\"arn:aws:s3:::" + BUCKET_PARAM + "/*\"]}]}";
    /**
     * bucket权限-只读
     */
    private static final String WRITE_ONLY = "{\"Version\":\"2012-10-17\",\"Statement\":[{\"Effect\":\"Allow\",\"Principal\":{\"AWS\":[\"*\"]},\"Action\":[\"s3:GetBucketLocation\",\"s3:ListBucketMultipartUploads\"],\"Resource\":[\"arn:aws:s3:::" + BUCKET_PARAM + "\"]},{\"Effect\":\"Allow\",\"Principal\":{\"AWS\":[\"*\"]},\"Action\":[\"s3:AbortMultipartUpload\",\"s3:DeleteObject\",\"s3:ListMultipartUploadParts\",\"s3:PutObject\"],\"Resource\":[\"arn:aws:s3:::" + BUCKET_PARAM + "/*\"]}]}";
    /**
     * bucket权限-读写
     */
    private static final String READ_WRITE = "{\"Version\":\"2012-10-17\",\"Statement\":[{\"Effect\":\"Allow\",\"Principal\":{\"AWS\":[\"*\"]},\"Action\":[\"s3:GetBucketLocation\",\"s3:ListBucket\",\"s3:ListBucketMultipartUploads\"],\"Resource\":[\"arn:aws:s3:::" + BUCKET_PARAM + "\"]},{\"Effect\":\"Allow\",\"Principal\":{\"AWS\":[\"*\"]},\"Action\":[\"s3:DeleteObject\",\"s3:GetObject\",\"s3:ListMultipartUploadParts\",\"s3:PutObject\",\"s3:AbortMultipartUpload\"],\"Resource\":[\"arn:aws:s3:::" + BUCKET_PARAM + "/*\"]}]}";

/**
     * 文件url前半段
     *
     * @param bucket 桶
     * @return 前半段
     */
    public static String getObjectPrefixUrl(String bucket) {
        return String.format("%s/%s/", ENDPOINT, bucket);
    }

/**
     * 创建桶
     *
     * @param bucket 桶
     */
    public static void makeBucket(String bucket) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        // 判断桶是否存在
        boolean isExist = client.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());
        if (!isExist) {
            // 新建桶
            client.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());
        }
    }

 /**
     * 更新桶权限策略
     *
     * @param bucket 桶
     * @param policy 权限
     */
    public static void setBucketPolicy(String bucket, String policy) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        switch (policy) {
            case "read-only":
                client.setBucketPolicy(SetBucketPolicyArgs.builder().bucket(bucket).config(READ_ONLY.replace(BUCKET_PARAM, bucket)).build());
                break;
            case "write-only":
                client.setBucketPolicy(SetBucketPolicyArgs.builder().bucket(bucket).config(WRITE_ONLY.replace(BUCKET_PARAM, bucket)).build());
                break;
            case "read-write":
                client.setBucketPolicy(SetBucketPolicyArgs.builder().bucket(bucket).config(READ_WRITE.replace(BUCKET_PARAM, bucket)).build());
                break;
            case "none":
            default:
                break;
        }
    }

 /**
     * 上传本地文件
     *
     * @param bucket    桶
     * @param objectKey 文件key
     * @param filePath  文件路径
     * @return 文件url
     */
    public static String uploadFile(String bucket, String objectKey, String filePath) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        client.uploadObject(UploadObjectArgs.builder().bucket(bucket).object(objectKey).filename(filePath).contentType("image/png").build());
        return getObjectPrefixUrl(bucket) + objectKey;
    }

/**
     * 流式上传文件
     *
     * @param bucket      桶
     * @param objectKey   文件key
     * @param inputStream 文件输入流
     * @return 文件url
     */
    public static String uploadInputStream(String bucket, String objectKey, InputStream inputStream) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        client.putObject(PutObjectArgs.builder().bucket(bucket).object(objectKey).stream(inputStream, inputStream.available(), -1).contentType("image/png").build());
        return getObjectPrefixUrl(bucket) + objectKey;
    }

 /**
     * 下载文件
     *
     * @param bucket    桶
     * @param objectKey 文件key
     * @return 文件流
     */
    public static InputStream download(String bucket, String objectKey) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        return client.getObject(GetObjectArgs.builder().bucket(bucket).object(objectKey).build());
    }

  /**
     * 文件复制
     *
     * @param sourceBucket    源桶
     * @param sourceObjectKey 源文件key
     * @param bucket          桶
     * @param objectKey       文件key
     * @return 新文件url
     */
    public static String copyFile(String sourceBucket, String sourceObjectKey, String bucket, String objectKey) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        CopySource source = CopySource.builder().bucket(sourceBucket).object(sourceObjectKey).build();
        client.copyObject(CopyObjectArgs.builder().bucket(bucket).object(objectKey).source(source).build());
        return getObjectPrefixUrl(bucket) + objectKey;
    }

 /**
     * 删除文件
     *
     * @param bucket    桶
     * @param objectKey 文件key
     */
    public static void deleteFile(String bucket, String objectKey) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        client.removeObject(RemoveObjectArgs.builder().bucket(bucket).object(objectKey).build());
    }

  /**
     * 获取文件签名url
     *
     * @param bucket    桶
     * @param objectKey 文件key
     * @param expires   签名有效时间  单位秒
     * @return 文件签名地址
     */
    public static String getSignedUrl(String bucket, String objectKey, int expires) throws Exception {
        MinioClient client = MinioClient.builder().endpoint(ENDPOINT).credentials(ACCESS_KEY, SECRET_KEY).build();
        return client.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder().method(Method.GET).bucket(bucket).object(objectKey).expiry(expires).build());
    }

public static void main(String[] args) {
        String bucket = "public";
        String objectKey = "demo/123.png";
        try {
            // 创建桶
            makeBucket(bucket);
            // 设置桶读写权限
            setBucketPolicy(bucket, "read-write");
            // 上传本地文件
            String url1 = uploadFile(bucket, objectKey, "D://123.png");
            // 输出  http://127.0.0.1:9000/demo/123.png
            System.out.println(url1);
            // 上传文件流
            String url2 = uploadInputStream(bucket, objectKey, new FileInputStream(new File("D://123.png")));
            // 输出  http://127.0.0.1:9000/demo/123.png
            System.out.println(url2);
            // 下载文件
            InputStream inputStream = download(bucket, objectKey);
            // 文件复制
            String url3 = copyFile(bucket, objectKey, "test", "test/abc.png");
            // 输出  http://127.0.0.1:9000/test/abc.png
            System.out.println(url3);
            // 删除文件
            deleteFile("test", "test/abc.png");
            // 获取文件签名url
            String sign = getSignedUrl(bucket, objectKey, 600);
            // 该路径可访问文件五分钟
            System.out.println(sign);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/349517.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

五种情况下企业需要引进低代码开发平台

五种情况下企业需要引进低代码开发平台

随着低代码开发平台的热度在上升，企业中也开始流行一种新的应用交付方式：业务部门基于低代码开发平台将所需要的功能（或简单的可用版本）自行搭建出来，当遇到较为复杂的需求时，则向IT部门请求支援。业务与IT…
阅读更多...
【MFC】模拟采集系统——数据绘制（19）

【MFC】模拟采集系统——数据绘制（19）

完成界面设计后，数据绘制也可以按照对MFC类派生来完成，值得注意的是这里的数据绘制仅仅是通过随机产生的数据来显示，并且显示的方法也有很多。 数据绘制 在主对话框中添加两个 Picture Control 位置大小任意，可以设置一下外观&a…
阅读更多...
Python3 数据结构实例及演示

Python3 数据结构实例及演示

本章节主要结合前面所学的知识点来介绍Python数据结构。 列表 Python中列表是可变的，这是它区别于字符串和元组的最重要的特点，1句话概括即：列表可以修改，而字符串和元组不能。 以下是 Python 中列表的方法： 下面示…
阅读更多...
阿里云服务器部署前后端分离项目

阿里云服务器部署前后端分离项目

阿里云服务器部署 【若依】 前后端分离项目 文章目录一、域名解析二、服务器操作系统置空三、部署方式四、需安装环境配置五、Linux服务器安装相应内容（具体安装步骤）（一）安装JDK（3种方式）使用Yum安装&…
阅读更多...
Assignment写作各个部分怎么衔接完美？

Assignment写作各个部分怎么衔接完美？

Assignment格式很简单，就只有四个部分，按着通用的套路来，发现也没什么难度。不过这4个部分自己需要衔接完美，下面就给大家分享一下写Assignment最简单的方法。 如果没有目录可以放在第一页的开头，用“标题字体”加重显…
阅读更多...
互联网大厂Java岗最全八股文面试1100道真题汇总，堪称2023年面试天花板

互联网大厂Java岗最全八股文面试1100道真题汇总，堪称2023年面试天花板

2023 年的互联网行业竞争越来越严峻，面试也是越来越难，一直以来我都想整理一套完美的面试宝典，奈何难抽出时间，这套 1100道的 Java 面试手册是行业内各大神联合总结出来的，上传到 Git 上目前 star 数达到了 30K 这套互…
阅读更多...
POE指数积公式的简单matlab实现

POE指数积公式的简单matlab实现

参考现代机器人学 及机器人工程师进阶之路（八）指数积（PoE）建立机械臂模型及正运动 1.使用Robotics在matlab中建立一个简单的机械臂，方便验证后面的代码写的对不对 %Robotics 工具箱介绍： https://blog.csd…
阅读更多...
【使用secureCRT管理Linux系统】

【使用secureCRT管理Linux系统】

使用secureCRT管理Linux系统 进入secureCRT快速连接虚拟机 默认是SSH2类型，红线是虚拟机的ip地址，绿线是虚拟机的用户名称 如果之后的页面出现了需要输入用户密码，那就是成功了，如果出现了Connection timed out 可能原因是电脑…
阅读更多...
Spring如何整合MyBatis框架？使用XML及java类的配置方式

Spring如何整合MyBatis框架？使用XML及java类的配置方式

前言 Spring文章链接: 从头到尾Spring概念，家族，核心技术使用，事务这一篇就够了！！！_千小半的博客-CSDN博客_spring最新技术 mybatis文章链接: MyBatis框架入门(含实例)_mybatis sqlsession创建和关闭_千小…
阅读更多...
文华财经期货日内多空金叉波段彩带幅图指标公式，震荡区间决策预警信号指标公式

文华财经期货日内多空金叉波段彩带幅图指标公式，震荡区间决策预警信号指标公式

​期货指标公式不是交易的圣杯，也不是期货亏损后的救命稻草。请理性运用指标公式，独立决策，盈亏自负。 1.在期货交易中，大部分品种，大部分时间都是在走一个趋势行情。即使是形态内的震荡行情，也是在走一个…
阅读更多...
redis 实现延迟队列及其他实现延迟队列

redis 实现延迟队列及其他实现延迟队列

1、 前言 1.1、什么是延迟队列？ 延时队列相比于普通队列最大的区别就体现在其延时的属性上，普通队列的元素是先进先出，按入队顺序进行处理，而延时队列中的元素在入队时会指定一个延迟时间，表示其希望能够在经过该指定…
阅读更多...
虹科新品|HK-Edgility敏捷边缘计算套件

虹科新品|HK-Edgility敏捷边缘计算套件

敏捷、经济高效且易于管理大规模IT服务基础设施 业务动态和数字化转型将业务资源和业务用户都推到了传统 IT 边界之外。业务资源和服务被虚拟化并迁移到云端。随着数字工作空间的发展和业务用户需要随时随地访问业务资源，越来越多的业务资源被推向网络边缘。 由于…
阅读更多...
研报精选230216

研报精选230216

目录 【行业230216东吴证券】环保行业月报：2023M1环卫新能源渗透率大增至11.91%，上海地区渗透率高达77%【行业230216国元证券】国元新食饮：一图君：22年白酒产量：同降6.2%【行业230216浙商证券】农林牧渔点评报告&#…
阅读更多...
认识数据库

认识数据库

今天为大家带来数据库的知识 🚀1.什么是数据库 🚀2.数据库的分类 🚀3.数据库的存储 1.首先来聊一聊MySQL数据库的定义 已经学习了数据结构 数据结构是一门研究数据如何存储的学科，当数据是少量的时候，用数据结构…
阅读更多...
在vue2使用百度脑图的kityminder-core进行二次开发思维导图，给节点绑定数据后添加新的图标

在vue2使用百度脑图的kityminder-core进行二次开发思维导图，给节点绑定数据后添加新的图标

需求说明：在给某个节点绑定文件数据后，用户并不能一眼看出哪个节点上绑定了数据，因此需要在绑定文件数据后给节点上加一个图标用于标识。 添加图标 1、在kityminder-core/src/module/file.js文件中添加代码 （file.js文件如何添加…
阅读更多...
ChatGPT国内镜像站初体验：聊天、Python代码生成等

ChatGPT国内镜像站初体验：聊天、Python代码生成等

ChatGPT国内镜像站试用，聊天、Python代码生成。 (本文获得CSDN质量评分【92】)【学习的细节是欢悦的历程】Python 官网：https://www.python.org/ Free：大咖免费“圣经”教程《 python 完全自学教程》，不仅仅是基础那么简单…… …
阅读更多...
基于离散时间频率增益传感器的P级至M级PMU模型的实现（Matlab代码实现）

基于离散时间频率增益传感器的P级至M级PMU模型的实现（Matlab代码实现）

👨‍🎓个人主页：研学社的博客💥💥💞💞欢迎来到本博客❤️❤️💥💥🏆博主优势：🌞🌞🌞博客内容尽量做到思维缜密…
阅读更多...
[足式机器人]Part3机构运动微分几何学分析与综合Ch01-4 平面运动微分几何学——【读书笔记】

[足式机器人]Part3机构运动微分几何学分析与综合Ch01-4 平面运动微分几何学——【读书笔记】

本文仅供学习使用 本文参考： 《机构运动微分几何学分析与综合》-王德伦、汪伟 《微分几何》吴大任 Ch01-4 平面运动微分几何学1.2.3-2 点轨迹的Euler-Savary公式1.2.4 高阶曲率理论1.2.3-2 点轨迹的Euler-Savary公式 例1-7： 平面曲柄摇杆机构的 Euler-Sa…
阅读更多...
VS中scanf为什么会报错

VS中scanf为什么会报错

简单来讲&#xff0c;scanf会强行输入内容&#xff0c;所以是不安全的。 我们来看这样的例子&#xff1a; #include <iostream> using namespace std;int main() {char demo[3];scanf("%s", demo);return 0; }对于以上代码&#xff0c;当我们输入字符不超过3时…
阅读更多...
联合身份验证与Cognito

联合身份验证与Cognito

Hello大家好&#xff0c;我们接下来讨论AWS联合身份验证的内容。 AWS联合身份验证 对于考试&#xff0c;联合身份验证部分是一块非常重要的内容。那什么是联合身份验证&#xff0c;它是做什么用的呢&#xff1f; 联合身份验证&#xff0c;是用来允许AWS外部用户&#xff0c;如…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023