|
|
|
@ -22,13 +22,15 @@ func Routers(r *gin.RouterGroup) {
|
|
|
|
|
rr.GET("/getUrl", getUrl)
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//声明s3的客户端实例
|
|
|
|
|
var s3Client *minio.Client
|
|
|
|
|
var err error
|
|
|
|
|
var bucketName string
|
|
|
|
|
|
|
|
|
|
//初始化
|
|
|
|
|
func init() {
|
|
|
|
|
bucketName=ConfigUtil.MinioBacketName
|
|
|
|
|
bucketName = ConfigUtil.MinioBacketName
|
|
|
|
|
s3Client, err = minio.New(ConfigUtil.MinioEndpoint, ConfigUtil.MinioAk, ConfigUtil.MinioSk, false)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Fatalln(err)
|
|
|
|
@ -64,7 +66,8 @@ func presignedUrl(c *gin.Context) {
|
|
|
|
|
name = CommonUtil.GetUUID() + "." + ext
|
|
|
|
|
presignedURL, err := s3Client.PresignedPutObject(bucketName, name, time.Duration(1000)*time.Second*300)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Fatalln(err)
|
|
|
|
|
c.String(http.StatusInternalServerError, "发生了严重错误!")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
c.String(http.StatusOK, presignedURL.String())
|
|
|
|
|
}
|
|
|
|
|