mirror of
https://github.com/lzh-1625/go_process_manager.git
synced 2025-10-05 16:06:51 +08:00
update to jwt v5
This commit is contained in:
2
go.mod
2
go.mod
@@ -126,7 +126,7 @@ require (
|
|||||||
github.com/creack/pty v1.1.21
|
github.com/creack/pty v1.1.21
|
||||||
github.com/gin-gonic/gin v1.9.1
|
github.com/gin-gonic/gin v1.9.1
|
||||||
github.com/glebarez/sqlite v1.11.0
|
github.com/glebarez/sqlite v1.11.0
|
||||||
github.com/golang-jwt/jwt v3.2.2+incompatible
|
github.com/golang-jwt/jwt/v5 v5.2.3
|
||||||
github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510
|
github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510
|
||||||
github.com/olivere/elastic/v7 v7.0.32
|
github.com/olivere/elastic/v7 v7.0.32
|
||||||
github.com/panjf2000/ants/v2 v2.10.0
|
github.com/panjf2000/ants/v2 v2.10.0
|
||||||
|
4
go.sum
4
go.sum
@@ -109,8 +109,8 @@ github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MG
|
|||||||
github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
|
github.com/godbus/dbus/v5 v5.0.4/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
|
||||||
github.com/godbus/dbus/v5 v5.1.0 h1:4KLkAxT3aOY8Li4FRJe/KvhoNFFxo0m6fNuFUO8QJUk=
|
github.com/godbus/dbus/v5 v5.1.0 h1:4KLkAxT3aOY8Li4FRJe/KvhoNFFxo0m6fNuFUO8QJUk=
|
||||||
github.com/godbus/dbus/v5 v5.1.0/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
|
github.com/godbus/dbus/v5 v5.1.0/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=
|
||||||
github.com/golang-jwt/jwt v3.2.2+incompatible h1:IfV12K8xAKAnZqdXVzCZ+TOjboZ2keLg81eXfW3O+oY=
|
github.com/golang-jwt/jwt/v5 v5.2.3 h1:kkGXqQOBSDDWRhWNXTFpqGSCMyh/PLnqUvMGJPDJDs0=
|
||||||
github.com/golang-jwt/jwt v3.2.2+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
|
github.com/golang-jwt/jwt/v5 v5.2.3/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
|
||||||
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
|
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0ktxqI+Sida1w446QrXBRJ0nee3SNZlA=
|
||||||
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
|
github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0=
|
||||||
github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
|
github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A=
|
||||||
|
@@ -22,7 +22,7 @@ func (u *userApi) LoginHandler(ctx *gin.Context, req model.LoginHandlerReq) any
|
|||||||
if !u.checkLoginInfo(req.Account, req.Password) {
|
if !u.checkLoginInfo(req.Account, req.Password) {
|
||||||
return errors.New("incorrect username or password")
|
return errors.New("incorrect username or password")
|
||||||
}
|
}
|
||||||
token, err := utils.GenToken(req.Account)
|
token, err := utils.GenerateToken(req.Account)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
@@ -51,7 +51,7 @@ func CheckToken() gin.HandlerFunc {
|
|||||||
} else {
|
} else {
|
||||||
token = c.Query("token")
|
token = c.Query("token")
|
||||||
}
|
}
|
||||||
if _, err := utils.ParseToken(token); err != nil {
|
if _, err := utils.VerifyToken(token); err != nil {
|
||||||
rErr(c, -2, "token校验失败", err)
|
rErr(c, -2, "token校验失败", err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -73,8 +73,8 @@ func getUser(ctx *gin.Context) (string, error) {
|
|||||||
} else {
|
} else {
|
||||||
token = ctx.Query("token")
|
token = ctx.Query("token")
|
||||||
}
|
}
|
||||||
if mc, err := utils.ParseToken(token); err == nil && mc != nil {
|
if mc, err := utils.VerifyToken(token); err == nil && mc != nil {
|
||||||
return mc.UserName, nil
|
return mc.Username, nil
|
||||||
} else {
|
} else {
|
||||||
return "", errors.Join(errors.New("用户信息获取失败"), err)
|
return "", errors.Join(errors.New("用户信息获取失败"), err)
|
||||||
}
|
}
|
||||||
|
82
utils/jwt.go
82
utils/jwt.go
@@ -1,67 +1,59 @@
|
|||||||
package utils
|
package utils
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"fmt"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/lzh-1625/go_process_manager/config"
|
"github.com/golang-jwt/jwt/v5"
|
||||||
|
|
||||||
"github.com/golang-jwt/jwt"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var mySecret []byte
|
var jwtKey []byte
|
||||||
|
|
||||||
func SetSecret(secret []byte) {
|
|
||||||
mySecret = secret
|
|
||||||
}
|
|
||||||
|
|
||||||
func keyFunc(_ *jwt.Token) (i interface{}, err error) {
|
|
||||||
return mySecret, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
type MyClaims struct {
|
type MyClaims struct {
|
||||||
UserName string `json:"user_name"`
|
Username string `json:"username"`
|
||||||
jwt.StandardClaims
|
jwt.RegisteredClaims
|
||||||
}
|
}
|
||||||
|
|
||||||
func GenToken(UserName string) (string, error) {
|
func SetSecret(secret []byte) {
|
||||||
// 创建一个我们自己的声明的数据
|
jwtKey = []byte(secret)
|
||||||
c := MyClaims{
|
}
|
||||||
UserName,
|
|
||||||
jwt.StandardClaims{
|
func GenerateToken(username string) (string, error) {
|
||||||
ExpiresAt: time.Now().Add(
|
expirationTime := time.Now().Add(3 * 24 * time.Hour)
|
||||||
time.Duration(config.CF.TokenExpirationTime) * time.Hour).Unix(), // 过期时间
|
|
||||||
Issuer: "jwt", // 签发人
|
claims := &MyClaims{
|
||||||
|
Username: username,
|
||||||
|
RegisteredClaims: jwt.RegisteredClaims{
|
||||||
|
ExpiresAt: jwt.NewNumericDate(expirationTime),
|
||||||
|
IssuedAt: jwt.NewNumericDate(time.Now()),
|
||||||
|
NotBefore: jwt.NewNumericDate(time.Now()),
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
// 使用指定的签名方法创建签名对象
|
|
||||||
token := jwt.NewWithClaims(jwt.SigningMethodHS256, c)
|
token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
|
||||||
return token.SignedString(mySecret)
|
|
||||||
|
tokenString, err := token.SignedString(jwtKey)
|
||||||
|
if err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
|
||||||
|
return tokenString, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func ParseToken(tokenString string) (*MyClaims, error) {
|
func VerifyToken(tokenString string) (*MyClaims, error) {
|
||||||
var mc = new(MyClaims)
|
claims := &MyClaims{}
|
||||||
token, err := jwt.ParseWithClaims(tokenString, mc, keyFunc)
|
|
||||||
|
token, err := jwt.ParseWithClaims(tokenString, claims, func(token *jwt.Token) (interface{}, error) {
|
||||||
|
return jwtKey, nil
|
||||||
|
})
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if token.Valid {
|
|
||||||
return mc, nil
|
|
||||||
}
|
|
||||||
return nil, errors.New("invalid token")
|
|
||||||
}
|
|
||||||
|
|
||||||
func RefreshToken(aToken, rToken string) (newAToken, newRToken string, err error) {
|
if !token.Valid {
|
||||||
if _, err = jwt.Parse(rToken, keyFunc); err != nil {
|
return nil, fmt.Errorf("invalid token")
|
||||||
return
|
|
||||||
}
|
}
|
||||||
var claims MyClaims
|
|
||||||
_, err = jwt.ParseWithClaims(aToken, &claims, keyFunc)
|
|
||||||
v, _ := err.(*jwt.ValidationError)
|
|
||||||
|
|
||||||
if v.Errors == jwt.ValidationErrorExpired {
|
return claims, nil
|
||||||
token, _ := GenToken(claims.UserName)
|
|
||||||
return token, "", nil
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user