Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
97911ec21d | ||
|
|
aa203fcf61 | ||
|
|
c00770cab3 |
17
file.go
17
file.go
@@ -1,8 +1,9 @@
|
|||||||
package go_aliyun_oss
|
package go_aliyun_oss
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
uuid "github.com/satori/go.uuid"
|
"github.com/google/uuid"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"mime/multipart"
|
"mime/multipart"
|
||||||
"os"
|
"os"
|
||||||
@@ -35,7 +36,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
|
|||||||
ossFile.FileByte, err = ioutil.ReadAll(ossFile.File.(*os.File))
|
ossFile.FileByte, err = ioutil.ReadAll(ossFile.File.(*os.File))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("read os type file failed:" + err.Error())
|
return nil, errors.New("read os type file failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
_, ossFile.FileOldName = filepath.Split(ossFile.File.(*os.File).Name())
|
_, ossFile.FileOldName = filepath.Split(ossFile.File.(*os.File).Name())
|
||||||
@@ -55,7 +56,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
|
|||||||
ossFile.FileByte, err = ioutil.ReadAll(fileResources)
|
ossFile.FileByte, err = ioutil.ReadAll(fileResources)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("read multipart file failed:" + err.Error())
|
return nil, errors.New("read multipart file failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
ossFile.FileOldName = ossFile.File.(*multipart.FileHeader).Filename
|
ossFile.FileOldName = ossFile.File.(*multipart.FileHeader).Filename
|
||||||
@@ -66,7 +67,7 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
|
|||||||
newFile, err := os.Open(ossFile.File.(string))
|
newFile, err := os.Open(ossFile.File.(string))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("open file path failed:" + err.Error())
|
return nil, errors.New("open file path failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
defer newFile.Close()
|
defer newFile.Close()
|
||||||
@@ -83,16 +84,16 @@ func (ossFile *OssFile) FileTypeTransForm() (*OssFile,error) {
|
|||||||
|
|
||||||
//判断是否指定了文件的类型 如果没有指定默认为png格式
|
//判断是否指定了文件的类型 如果没有指定默认为png格式
|
||||||
if ossFile.FileType == "" || len(ossFile.FileType) <= 0 {
|
if ossFile.FileType == "" || len(ossFile.FileType) <= 0 {
|
||||||
ossFile.FileOldName = uuid.NewV4().String() + ".png"
|
ossFile.FileOldName = uuid.NewString() + ".png"
|
||||||
} else {
|
} else {
|
||||||
ossFile.FileOldName = uuid.NewV4().String() + ossFile.FileType
|
ossFile.FileOldName = uuid.NewString() + ossFile.FileType
|
||||||
}
|
}
|
||||||
|
|
||||||
break
|
break
|
||||||
|
|
||||||
default:
|
default:
|
||||||
fmt.Println(reflect.TypeOf(ossFile.File))
|
fmt.Println(reflect.TypeOf(ossFile.File))
|
||||||
panic("file type is not support" )
|
return nil, errors.New("file type is not support")
|
||||||
}
|
}
|
||||||
|
|
||||||
ossFile.GetFileType()
|
ossFile.GetFileType()
|
||||||
@@ -115,7 +116,7 @@ func (ossFile *OssFile) GetFileType() *OssFile {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//generate only file name
|
//generate only file name
|
||||||
ossFile.FileNewName = uuid.NewV5(uuid.NewV4(),ossFile.FileOldName).String() + ossFile.FileType
|
ossFile.FileNewName = uuid.NewString() + ossFile.FileType
|
||||||
|
|
||||||
return ossFile
|
return ossFile
|
||||||
}
|
}
|
||||||
4
go.mod
4
go.mod
@@ -3,9 +3,9 @@ module github.com/cowardmrx/go_aliyun_oss
|
|||||||
go 1.15
|
go 1.15
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible
|
github.com/aliyun/aliyun-oss-go-sdk v2.2.5+incompatible
|
||||||
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f // indirect
|
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f // indirect
|
||||||
github.com/satori/go.uuid v1.2.0
|
github.com/google/uuid v1.6.0 // indirect
|
||||||
golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e // indirect
|
golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e // indirect
|
||||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
|
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
|
||||||
)
|
)
|
||||||
|
|||||||
4
go.sum
4
go.sum
@@ -1,7 +1,11 @@
|
|||||||
github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible h1:v5yDfjkRY/kOxu05gkh0/D/2wYxbTFCoTr3JqFI0FLE=
|
github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible h1:v5yDfjkRY/kOxu05gkh0/D/2wYxbTFCoTr3JqFI0FLE=
|
||||||
github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
|
github.com/aliyun/aliyun-oss-go-sdk v2.1.5+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
|
||||||
|
github.com/aliyun/aliyun-oss-go-sdk v2.2.5+incompatible h1:QoRMR0TCctLDqBCMyOu1eXdZyMw3F7uGA9qPn2J4+R8=
|
||||||
|
github.com/aliyun/aliyun-oss-go-sdk v2.2.5+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
|
||||||
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f h1:ZNv7On9kyUzm7fvRZumSyy/IUiSC7AzL0I1jKKtwooA=
|
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f h1:ZNv7On9kyUzm7fvRZumSyy/IUiSC7AzL0I1jKKtwooA=
|
||||||
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f/go.mod h1:AuiFmCCPBSrqvVMvuqFuk0qogytodnVFVSN5CeJB8Gc=
|
github.com/baiyubin/aliyun-sts-go-sdk v0.0.0-20180326062324-cfa1a18b161f/go.mod h1:AuiFmCCPBSrqvVMvuqFuk0qogytodnVFVSN5CeJB8Gc=
|
||||||
|
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
|
||||||
|
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
|
||||||
github.com/kr/pretty v0.2.1 h1:Fmg33tUaq4/8ym9TJN1x7sLJnHVwhP33CNkpYV/7rwI=
|
github.com/kr/pretty v0.2.1 h1:Fmg33tUaq4/8ym9TJN1x7sLJnHVwhP33CNkpYV/7rwI=
|
||||||
github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
|
github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
|
||||||
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
|
github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package go_aliyun_oss
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
|
"errors"
|
||||||
"github.com/aliyun/aliyun-oss-go-sdk/oss"
|
"github.com/aliyun/aliyun-oss-go-sdk/oss"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -22,7 +23,7 @@ type ossResponse struct {
|
|||||||
// params: ossDir string `oss dir [要推送到的oss目录]` example: test/20201121/
|
// params: ossDir string `oss dir [要推送到的oss目录]` example: test/20201121/
|
||||||
// params: file interface `upload file resource [文件资源]`
|
// params: file interface `upload file resource [文件资源]`
|
||||||
// return string `oss file accessible uri [可访问地址]`
|
// return string `oss file accessible uri [可访问地址]`
|
||||||
func (client *AliOssClient) Put(ossDir string, file interface{},fileType string) *ossResponse {
|
func (client *AliOssClient) Put(ossDir string, file interface{}, fileType string) (*ossResponse, error) {
|
||||||
//file to []byte
|
//file to []byte
|
||||||
//文件转字节流
|
//文件转字节流
|
||||||
uploadFile := &OssFile{
|
uploadFile := &OssFile{
|
||||||
@@ -33,7 +34,7 @@ func (client *AliOssClient) Put(ossDir string, file interface{},fileType string)
|
|||||||
ossFile, err := uploadFile.FileTypeTransForm()
|
ossFile, err := uploadFile.FileTypeTransForm()
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("transfer file failed" + err.Error())
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// 最终的oss名称
|
// 最终的oss名称
|
||||||
@@ -58,7 +59,7 @@ func (client *AliOssClient) Put(ossDir string, file interface{},fileType string)
|
|||||||
err = client.Client.PutObject(ossPath, bytes.NewReader(ossFile.FileByte))
|
err = client.Client.PutObject(ossPath, bytes.NewReader(ossFile.FileByte))
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("put file to oss failed:" + err.Error())
|
return nil, errors.New("put file to oss failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
return &ossResponse{
|
return &ossResponse{
|
||||||
@@ -66,59 +67,59 @@ func (client *AliOssClient) Put(ossDir string, file interface{},fileType string)
|
|||||||
LongPath: client.Domain + "/" + ossPath,
|
LongPath: client.Domain + "/" + ossPath,
|
||||||
ShortPath: ossPath,
|
ShortPath: ossPath,
|
||||||
FileName: ossFileName,
|
FileName: ossFileName,
|
||||||
}
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// HasExists 校验文件是否已经存在
|
// HasExists 校验文件是否已经存在
|
||||||
// check file already exists in oss server
|
// check file already exists in oss server
|
||||||
// params: ossFilePath string `file oss path [文件的oss的路径]`
|
// params: ossFilePath string `file oss path [文件的oss的路径]`
|
||||||
func (client *AliOssClient) HasExists(ossFilePath string) bool {
|
func (client *AliOssClient) HasExists(ossFilePath string) (bool, error) {
|
||||||
|
|
||||||
//oss check fun
|
//oss check fun
|
||||||
isExists, err := client.Client.IsObjectExist(ossFilePath)
|
isExists, err := client.Client.IsObjectExist(ossFilePath)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("check file in oss is exists failed:" + err.Error())
|
return false, errors.New("check file in oss is exists failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
return isExists
|
return isExists, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// Delete 删除文件-单文件删除
|
// Delete 删除文件-单文件删除
|
||||||
// delete one file in oss
|
// delete one file in oss
|
||||||
// params ossPath string `file oss path [文件的oss路径]`
|
// params ossPath string `file oss path [文件的oss路径]`
|
||||||
// return bool
|
// return bool
|
||||||
func (client *AliOssClient) Delete(ossFilePath string) bool {
|
func (client *AliOssClient) Delete(ossFilePath string) (bool, error) {
|
||||||
|
|
||||||
//oss delete one file fun
|
//oss delete one file fun
|
||||||
err := client.Client.DeleteObject(ossFilePath)
|
err := client.Client.DeleteObject(ossFilePath)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("delete file "+ ossFilePath +" failed:" + err.Error())
|
return false, errors.New("delete file " + ossFilePath + " failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
return true
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// DeleteMore 删除文件-多文件删除
|
// DeleteMore 删除文件-多文件删除
|
||||||
// delete more file in oss
|
// delete more file in oss
|
||||||
// params ossPath []string `file oss path array [文件的oss路径数组]`
|
// params ossPath []string `file oss path array [文件的oss路径数组]`
|
||||||
// return bool
|
// return bool
|
||||||
func (client *AliOssClient) DeleteMore(ossFilePath []string) bool {
|
func (client *AliOssClient) DeleteMore(ossFilePath []string) (bool, error) {
|
||||||
//oss delete more file fun
|
//oss delete more file fun
|
||||||
_, err := client.Client.DeleteObjects(ossFilePath)
|
_, err := client.Client.DeleteObjects(ossFilePath)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("delete more file in oss failed:" + err.Error())
|
return false, errors.New("delete more file in oss failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
return true
|
return true, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// GetTemporaryUrl 获取文件临时地址
|
// GetTemporaryUrl 获取文件临时地址
|
||||||
// path string 文件路径
|
// path string 文件路径
|
||||||
// expireInSecond int64 多久后过期 单位: 秒,默认 60
|
// expireInSecond int64 多久后过期 单位: 秒,默认 60
|
||||||
func (client *AliOssClient) GetTemporaryUrl(path string,expireInSecond int64) string {
|
func (client *AliOssClient) GetTemporaryUrl(path string, expireInSecond int64) (string, error) {
|
||||||
|
|
||||||
var expireTime int64
|
var expireTime int64
|
||||||
|
|
||||||
@@ -131,9 +132,9 @@ func (client *AliOssClient) GetTemporaryUrl(path string,expireInSecond int64) st
|
|||||||
signUrl, err := client.Client.SignURL(path, oss.HTTPGet, expireTime)
|
signUrl, err := client.Client.SignURL(path, oss.HTTPGet, expireTime)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic("generate sign url failed:" + err.Error())
|
return "", errors.New("generate sign url failed:" + err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
return signUrl
|
return signUrl, nil
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -35,12 +35,10 @@ func TestPutBase64(t *testing.T) {
|
|||||||
// 读取base
|
// 读取base
|
||||||
file, _ := ioutil.ReadFile("./File/3HaqWaOzJWD86DDvZD9Pmn9VUEOBOBbuWackGOXb (2).jpeg")
|
file, _ := ioutil.ReadFile("./File/3HaqWaOzJWD86DDvZD9Pmn9VUEOBOBbuWackGOXb (2).jpeg")
|
||||||
|
|
||||||
|
|
||||||
fileStr := base64.StdEncoding.EncodeToString(file)
|
fileStr := base64.StdEncoding.EncodeToString(file)
|
||||||
|
|
||||||
bat, _ := base64.StdEncoding.DecodeString(fileStr)
|
bat, _ := base64.StdEncoding.DecodeString(fileStr)
|
||||||
|
|
||||||
|
|
||||||
uri := client.Put("logo/", bat, ".png")
|
uri := client.Put("logo/", bat, ".png")
|
||||||
//
|
//
|
||||||
fmt.Println(uri)
|
fmt.Println(uri)
|
||||||
@@ -96,7 +94,7 @@ func TestAliOssClient_DeleteMore(t *testing.T) {
|
|||||||
|
|
||||||
func TestAliOssClient_GetTemporaryUrl(t *testing.T) {
|
func TestAliOssClient_GetTemporaryUrl(t *testing.T) {
|
||||||
ossConfig := &AliOssConfig{
|
ossConfig := &AliOssConfig{
|
||||||
EndPoint: "",
|
EndPoint: "https://oss-cn-hangzhou.aliyuncs.com",
|
||||||
AccessKeyId: "",
|
AccessKeyId: "",
|
||||||
AccessKeySecret: "",
|
AccessKeySecret: "",
|
||||||
BucketName: "",
|
BucketName: "",
|
||||||
@@ -104,8 +102,7 @@ func TestAliOssClient_GetTemporaryUrl(t *testing.T) {
|
|||||||
|
|
||||||
client := ossConfig.CreateOssConnect()
|
client := ossConfig.CreateOssConnect()
|
||||||
|
|
||||||
singUrl := client.GetTemporaryUrl("logo/8497b913-2a79-58a1-984b-c25827f8212e.png",180)
|
singUrl := client.GetTemporaryUrl("", 180)
|
||||||
|
|
||||||
fmt.Println(singUrl)
|
fmt.Println(singUrl)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user