go操作aws s3

v2 官方推荐版本,需要go版本>=1.20 安装 go get github.com/aws/aws-sdk-go-v2 go get github.com/aws/aws-sdk-go-v2/config go get github.com/aws/aws-sdk-go-v2/service/s3 必要参数 bucket: 存储桶的名称 Region: 存储桶所在区域,例us-east-1 accessKeyID: 访问存储桶所需的KeyID secretAccessKey: 访问存储桶所需的AccessKey 如何获取accessKeyID和secretAccessKey:指南 var ( s3Client *s3.Client bucket = "yourbucketname" ) func InitS3Client() { accessKeyID := "xxxxx" secretAccessKey := "xxxxx" cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithRegion("ap-east-1"), config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(accessKeyID, secretAccessKey, "")), ) if err != nil { log.Fatalf("unable to load SDK config, %v", err) } s3Client = s3.NewFromConfig(cfg) } func UploadToS3(filePath, fileName, mimeType string) (string, error) { file, err := os.Open(filePath) if err != nil { return "", fmt.Errorf("failed to open file %q, %v", filePath, err) } defer file.Close() _, err = s3Client.PutObject(context.TODO(), &s3.PutObjectInput{ Bucket: aws.String(bucket), Key: aws.String(fileName), Body: file, ContentType: aws.String(mimeType), }) if err != nil { return "", fmt.Errorf("failed to upload file to S3, %v", err) } return fmt.Sprintf("https://%s.s3.amazonaws.com/%s", bucket, fileName), nil } 参考2 // 创建s3Client实例。 payKeyId := "AK***" paySecret := "oiy***" accessKeyID := payKeyId secretAccessKey := paySecret cfg, err := config.LoadDefaultConfig(context.TODO(), config.WithRegion("ap-east-1"), config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(accessKeyID, secretAccessKey, "")), ) if err != nil { fmt.Printf("unable to load SDK config, %v", err) } name := "test" s3Client := s3.NewFromConfig(cfg) filePath := "static/test.jpg" // 读取本地文件。 fd, err := os.Open(filePath) if err != nil { return } defer fd.Close() _, err = s3Client.PutObject(context.TODO(), &s3.PutObjectInput{ Bucket: aws.String("up"), Key:

golang jwt 签署令牌Authentication token

1.要安装 jwt 包,首先需要 安装Go,然后可以使用下面的命令将其添加jwt-go为 Go 程序中的依赖项。 go get -u github.com/golang-jwt/jwt/v5 2.将其导入到您的代码中: import "github.com/golang-jwt/jwt/v5" 3.demo func Test(t *testing.T) { //商户 subject := "01H" // 密钥 secretBase64 := "AwFj+OTCI=" secret, err := base64.StdEncoding.DecodeString(secretBase64) if err != nil { log.Fatalf("Error decoding base64 secret: %v", err) } // 过期秒数 expirseIn := 60 * time.Second // 创建jwt token token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.MapClaims{ "sub": subject, "exp": time.Now().Add(expirseIn).Unix(), }) // 使用密钥签名 tokenString, err := token.SignedString(secret) if err != nil { log.Fatalf("Error signing token: %v", err) } fmt.Println("tokenString=", tokenString) m := make(mapinterface m = "www" m = "qqq" // 将数据转为JSON格式 jsonData, err := json.Marshal(m) if err != nil { log.Fatalf("Error marshalling JSON: %v", err) } client := &http.Client{} url := "https://demo.com" method := "POST" req, err := http.NewRequest(method, url, bytes.NewBuffer(jsonData)) if err != nil { log.Fatalf("Error creating request: %v", err) } req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", tokenString)) req.Header.Set("Content-Type", "application/json; charset=utf-8") resp, err := client.Do(req) if err != nil { log.Fatalf("Error sending request: %v", err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { body, err := ioutil.ReadAll(resp.Body) if err != nil { log.Fatalf("Error reading response body: %v", err) } log.Printf("Response body: %s", string(body)) } log.Printf("Response StatusCode: %d,%d", resp.StatusCode,http.StatusOK) info := TestRespone{} err = ffjson.Unmarshal(body, &info) if err != nil { log.Printf("body

gin获取请求体(json格式)参数

gin 框架里 c.PostForm() 函数只能从表单中获取参数,不能从 body 中解析表单参数,也就是说你如果用 c.PostForm() 来解析获取参数,客户端发起请求时,如果参数放在表单(form-data)里,服务端能正常获取到参数,但是如果客户端把参数放在 raw 里,即使 header 里配置了 content-type:multipart/form-data,服务端仍就无法获取到参数。 c.PostForm获取表单数据 package main import ( "bytes" "fmt" "github.com/gin-gonic/gin" "io/ioutil" ) func main() { gin.SetMode(gin.ReleaseMode) r := gin.Default() r.GET("/test", func(c *gin.Context) { data, _ := ioutil.ReadAll(c.Request.Body) fmt.Printf("req.body=%s\n, content-type=%v\n", data, c.ContentType()) // 这点很重要,把字节流重新放回 body 中 c.Request.Body = ioutil.NopCloser(bytes.NewBuffer(data)) // 获取参数 userName := c.PostForm("user_name") age := c.PostForm("age") fmt.Printf("userName=%s, age=%s\n", userName, age) c.JSON(200, "success") }) r.Run(":7000") } 或 func Test(c *gin.Context) error { m := make(mapinterface{}) m = c.Request.PostFormValue("memberid") // 商户ID m = c.Request.PostFormValue("orderid") // 订单号 } 从body中获取参数 package main import ( "bytes" "encoding/json" "fmt" "github.com/gin-gonic/gin" "io" "io/ioutil" ) type User struct { UserName string `json:"user_name"` Age int `json:"age"` } // 关键 func JSONDecode(r io.Reader, obj interface{}) error { if err := json.NewDecoder(r).Decode(obj); err != nil { return err } return nil } func main() { gin.SetMode(gin.ReleaseMode) r := gin.Default() r.POST("/test", func(c *gin.Context) { // 打印出 body //data, _ := ioutil.ReadAll(c.Request.Body) //fmt.Printf("req.body=%s\n, content-type=%v\n", data, c.ContentType()) var json User data, err := c.GetRawData() if err != nil { fmt.Println(err.Error()) } fmt.Println("data:", string(data)) // 把字节流重新放回 body 中 c.Request.Body = ioutil.NopCloser(bytes.NewBuffer(data)) err2 := JSONDecode(c.Request.Body, &json) if err2 != nil { fmt.Println("decode err:", err2) } // 打印body中的参数 fmt.Println("user_name:", json.UserName, "age:", json.Age) c.JSON(200, "success") }) r.Run(":7000")

golang 使用 gomail 发送邮件

安装gomail go get gopkg.in/gomail.v2 package main import ( "crypto/tls" "fmt" "gopkg.in/gomail.v2" ) func main() { test1() } func test1() { message := ` <p> Hello %s,</p> <p style="text-indent:2em">测试测试测试测试.</p> <p style="text-indent:2em">测试11111</p> ` // QQ 邮箱: // SMTP 服务器地址:smtp.qq.com(SSL协议端口:465/994 | 非SSL协议端口:25) // 163 邮箱: // SMTP 服务器地址:smtp.163.com(端口:25) host := "xxxxx" port := 25 userName := "xxxx" // 有些油箱登入名不是邮箱地址 password := "xxxx" fromemail := "xx@xx.com" m := gomail.NewMessage() m.SetHeader("From", fromemail) // 发件人 // m.SetHeader("From", "alias"+"<"+userName+">") // 增加发件人别名 // 多个收件人形式 // mailTo := string{ // "******@qq.com", // "******@qq.com", // } // m.SetHeader("To", mailTo...) m.SetHeader("To", "xxxxx@qq.com") // 收件人,可以多个收件人,但必须使用相同的 SMTP 连接 // 多个同上 // m.SetHeader("Cc", "******@qq.com") // 抄送,可以多个 // m.SetHeader("Bcc", "******@qq.com") // 暗送,可以多个 m.SetHeader("Subject", "发送测试11111") // 邮件主题 // text/html 的意思是将文件的 content-type 设置为 text/html 的形式,浏览器在获取到这种文件时会自动调用html的解析器对文件进行相应的处理。 // 可以通过 text/html 处理文本格式进行特殊处理,如换行、缩进、加粗等等 m.SetBody("text/html", fmt.Sprintf(message, "测试")) // text/plain的意思是将文件设置为纯文本的形式,浏览器在获取到这种文件时并不会对其进行处理 // m.SetBody("text/plain", "纯文本") // m.Attach("test.sh") // 附件文件,可以是文件,照片,视频等等 // m.Attach("lolcatVideo.mp4") // 视频 // m.Attach("lolcat.jpg") // 照片 d := gomail.NewDialer( host, port, userName, password, ) // 关闭SSL协议认证 d.TLSConfig = &tls.Config{InsecureSkipVerify: true} if err := d.DialAndSend(m); err != nil { panic(err) } } package main import ( "gopkg.in/gomail.v2" "strconv" ) func SendMail(mailTo string,subject string, body string ) error { //定义邮箱服务器连接信息,如果是阿里邮箱 pass填密码,qq邮箱填授权码 mailConn := mapstring { "user": "zhangqiang@xxxx.com", "pass": "xxxx", "host": "smtp.mxhichina.com", "port": "465", } port, _

NeXT-Server 手动安装

38 cd /home 使用 wget 下载你选择的版本,https://go.dev/dl/ 找到适用于Linux的版本,你可以选择 .tar.gz 格式的文件以用于Debian系统 39 wget https://go.dev/dl/go1.22.4.linux-amd64.tar.gz 40 tar -C /usr/local -xzf go1.22.4.linux-amd64.tar.gz 42 echo 'export PATH=$PATH:/usr/local/go/bin' >> ~/.profile 44 vim ~/.bashrc 编辑~/.bashrc ,一般在root目录,根据自己的情况修改,添加下面内容到.bashrc文件尾 export GO_HOME=/usr/local/go/ export GO_PATH=$HOME/go export PATH=${GO_HOME}/bin:$GO_PATH/bin:$PATH 更新当前会话以应用路径更改 45 source ~/.profile 验证Go是否安装成功 46 go version 50 apt install git 51 git --version 52 git clone https://github.com/SSPanel-NeXT/NeXT-Server 48 cd NeXt-Server/ 49 git version 56 go mod tidy 57 go build -o NextServer -ldflags "-s -w" 编辑nextServer的配置文件 vim release/config/config.yml 运行nextServer 58 ./NextServer --config config.yml