1 什么是MinIO
MinlO是一个基于Apache License v2.0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口，非常适合于存储大容量非结构化的数据。例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等,而一个对象文件可以是任意大小,从几kb到最大5T不等。MinlO是一个非常轻量的服务 可以很简单的和其他应用的结合，类似NodeJS, Redis或者MySQL。
- 社区地址 - https://slack.min.io
- 文档地址（文档推荐）- https://docs.min.io
- 中文文档-http://docs.minio.org.cn/docs/
- 官网地址- https://min.io
2 使用MinIO实现上传和下载
2.1 安装相关依赖
npm install minio --save
npm install stream --save2.2 连接minIO服务
参考文档
let Minio = require('minio')
let stream = require('stream')
//连接minio文件服务器
var minioClient = new Minio.Client({
endPoint: '', //对象存储服务的URL
port: 9000, //端口号
useSSL: false, //true代表使用HTTPS
accessKey: '', //账户id
secretKey: '', //密码
});3 示例代码
主要实现功能
- 用户选择文件夹，将文件夹下文件进行上传
- 用户可以通过浏览器下载指定文件
<template>
<div style="margin:5px 5px">
<el-button @click="getFileName" type="primary">选择文件</el-button>
<input type="file" webkitdirectory multiple="multiple" id="minIoFile" ref="minIoFile" v-show="false" @change="getFile">
<el-button v-if="fileList.length>0" type="primary" @click="upload">上传</el-button>
<el-button type="primary" @click="download">下载</el-button>
</div>
</template>
<script>
let Minio = require('minio')
let stream = require('stream')
//连接minio文件服务器
var minioClient = new Minio.Client({
endPoint: '', //对象存储服务的URL
port: 9000, //端口号
useSSL: false, //true代表使用HTTPS
accessKey: '', //账户id
secretKey: '', //密码
});
export default {
name: 'MesAdivce',
data: () => ({
fileList: [],
}),
methods: {
download(filename, names) {
minioClient.bucketExists('ecgdata', async function(err) {
if (err) {
if (err.code == 'NoSuchBucket') return console.log("bucket does not exist.")
return console.log(err)
}
//存在
const file = await new Promise((resolve, reject)=>{
minioClient.getObject('ecgdata', '4A3D8BF371C044FDB3CED70010801EF5/1.3.12.2.1107.5.6.1.2387.30200122071903025612700000098.DCM', function (err, dataStream) {
let size = 0;
let file = [];
dataStream.on('data', function (chunk) {
size += chunk.length
console.log(chunk);
let aaa = Array.from(chunk)
file = file.concat(aaa);
})
dataStream.on('end', function () {
resolve(file)
})
dataStream.on('error', function (err) {
resolve(false)
})
})
})
// 进行下载
const blob = new Blob([file])
const blobUrl = URL.createObjectURL(blob)
const a = document.createElement('a')
a.setAttribute('href', blobUrl)
a.setAttribute('download', '1.3.12.2.1107.5.6.1.2387.30200122071903025612700000098.DCM')
a.click()
})
},
upload() {
this.fileList.map((item, index) => {
this.uploadMinIo(item, index);
})
},
getFileName() {
let inputDOM = this.$refs.minIoFile;
inputDOM.click();
},
getFile(event) {
let files = document.getElementById('minIoFile').files;
let arr = [];
let fileSwitch = true;
if (files.length > 0) {
for (let i = 0; i < files.length; i++) {
if ((files[i].size / 1024 / 1024).toFixed(5) > 64) {
this.$message({
message: `${item.name}超过文件的最大长度`,
type: 'warning'
});
fileSwitch = false;
}
}
if (fileSwitch) {
for (let i = 0; i < files.length; i++) {
if ((files[i].type == 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet') ||
(files[i].type == 'application/vnd.ms-excel') ||
(files[i].type == 'text/plain') ||
(files[i].type == 'image/png') ||
(files[i].type == 'image/gif') ||
(files[i].type == 'image/jpg') ||
(files[i].type == 'application/vnd.openxmlformats-officedocument.wordprocessingml.document') ||
(files[i].type == 'application/vnd.openxmlformats-officedocument.presentationml.presentation')
) {
this.fileList.push(files[i])
} else {
console.log("类型不对");
}
}
}
}
},
//上传文件
uploadMinIo(fileObj, index) {
this.fileList = this.fileList.filter((self, el) => {
return self != fileObj
})
let vm = this
// const files = fileObj;
if (fileObj) {
let file = fileObj
//获取文件类型及大小
const fileName = file.webkitRelativePath
const mineType = file.type
const fileSize = file.size
//参数
let metadata = {
"content-type": mineType,
"content-length": fileSize
}
//判断储存桶是否存在
minioClient.bucketExists('ecgdata', function(err) {
if (err) {
if (err.code == 'NoSuchBucket') return console.log("bucket does not exist.")
return console.log(err)
}
//准备上传
let reader = new FileReader();
reader.readAsDataURL(file);
reader.onloadend = function(e) { //读取完成触发，无论成功或失败
const dataurl = e.target.result
//base64转blob
const blob = vm.toBlob(dataurl)
//blob转arrayBuffer
let reader2 = new FileReader()
reader2.readAsArrayBuffer(blob)
reader2.onload = function(ex) {
//定义流
let bufferStream = new stream.PassThrough();
//将buffer写入
bufferStream.end(new Buffer(ex.target.result));
//上传
minioClient.putObject('ecgdata', fileName, bufferStream, fileSize, metadata, function(err,
etag) {
console.log(etag);
})
}
}
})
}
},
//base64转blob
toBlob(base64Data) {
let byteString = base64Data
if (base64Data.split(',')[0].indexOf('base64') >= 0) {
byteString = atob(base64Data.split(',')[1]) // base64 解码
} else {
byteString = unescape(base64Data.split(',')[1])
}
// 获取文件类型
let mimeString = base64Data.split(';')[0].split(":")[1] // mime类型
// ArrayBuffer 对象用来表示通用的、固定长度的原始二进制数据缓冲区
// let arrayBuffer = new ArrayBuffer(byteString.length) // 创建缓冲数组
// let uintArr = new Uint8Array(arrayBuffer) // 创建视图
let uintArr = new Uint8Array(byteString.length) // 创建视图
for (let i = 0; i < byteString.length; i++) {
uintArr[i] = byteString.charCodeAt(i)
}
// 生成blob
const blob = new Blob([uintArr], {
type: mimeString
})
// 使用 Blob 创建一个指向类型化数组的URL, URL.createObjectURL是new Blob文件的方法,可以生成一个普通的url,可以直接使用,比如用在img.src上
return blob
},
},
}
</script>
