jyInfo/rpc/common/test/oss_test.go

package test

import (
	"bytes"
	"fmt"
	"io/ioutil"
	"log"
	"os"
	"testing"

	"app.yhyue.com/moapp/jyInfo/rpc/model/oss"
	"github.com/aliyun/aliyun-oss-go-sdk/oss"
)

//https://jytest2022.oss-cn-beijing.aliyuncs.com/
//https://jy-datafile.oss-cn-beijing.aliyuncs.com/

//es保存
var filename = "4671650439467_.pic_hd.jpg"
var filecont = "信息发布，不同意公开联系方式，则采购联系人、采购联系电话不展示。"
var filepath = "E:/oss/4671650439467_.pic_hd.jpg"

//b06c25cc82579e5e600239dec065a71a527e9b701c3315307782c66c01089aa8.docx
//20fede85e42bbeefd194a3180160b03d1141a0de3f5f6221e2531a9660c017d8.jpg
var objectName = "jytest2022"
var objectKey = "20fede85e42bbeefd194a3180160b03d1141a0de3f5f6221e2531a9660c017d8.jpg"

//

func Test_ossUp(t *testing.T) {
	bt, _ := ioutil.ReadFile(filepath)
	log.Println("size:", len(bt), len(bt)/1024)
	// bt := []byte(filecont)
	key := model.GetHashKey(bt) + model.TypeByExt(filename)
	log.Println("keys:", key)

	client, err := oss.New("oss-cn-beijing.aliyuncs.com", "LTAI4G5x9aoZx8dDamQ7vfZi", "Bk98FsbPYXcJe72n1bG3Ssf73acuNh")
	if err != nil {
		fmt.Println("Error:", err)
		os.Exit(-1)
	}
	// 获取存储空间。
	bucket, err := client.Bucket(objectName)
	if err != nil {
		fmt.Println("Error:", err)
	}
	err = bucket.PutObject(key, bytes.NewReader(bt))
	if err != nil {
		fmt.Println("file upload false:", err)
	}
	log.Println("----------")
}

//
func Test_ossIsExist(t *testing.T) {
	client, err := oss.New("oss-cn-beijing.aliyuncs.com", "LTAI4G5x9aoZx8dDamQ7vfZi", "Bk98FsbPYXcJe72n1bG3Ssf73acuNh")
	if err != nil {
		fmt.Println("Error:", err)
		os.Exit(-1)
	}
	// 获取存储信息
	bucket, err := client.Bucket(objectName)
	if err != nil {
		fmt.Println("Error:", err)
	}
	//附件是否存在
	ok, err := bucket.IsObjectExist(objectKey)
	log.Println("ok:", ok, "--err:", err)
}