Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
FLIPPED-AURORA
gin-vue-admin
提交
a71cfe1d
G
gin-vue-admin
项目概览
FLIPPED-AURORA
/
gin-vue-admin
大约 1 年 前同步成功
通知
334
Star
18155
Fork
5506
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
G
gin-vue-admin
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
a71cfe1d
编写于
7月 07, 2021
作者:
S
songzhibin97
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
feat:增加singleFlight并发控制jwt颁发
上级
7a1c2abf
变更
3
显示空白变更内容
内联
并排
Showing
3 changed file
with
18 addition
and
5 deletion
+18
-5
server/global/global.go
server/global/global.go
+5
-2
server/go.mod
server/go.mod
+1
-0
server/middleware/jwt.go
server/middleware/jwt.go
+12
-3
未找到文件。
server/global/global.go
浏览文件 @
a71cfe1d
...
...
@@ -3,6 +3,8 @@ package global
import
(
"gin-vue-admin/utils/timer"
"golang.org/x/sync/singleflight"
"go.uber.org/zap"
"gin-vue-admin/config"
...
...
@@ -20,4 +22,5 @@ var (
//GVA_LOG *oplogging.Logger
GVA_LOG
*
zap
.
Logger
GVA_Timer
timer
.
Timer
=
timer
.
NewTimerTask
()
GVA_Concurrency_Control
=
&
singleflight
.
Group
{}
)
server/go.mod
浏览文件 @
a71cfe1d
...
...
@@ -51,6 +51,7 @@ require (
github.com/unrolled/secure v1.0.7
go.uber.org/zap v1.10.0
golang.org/x/crypto v0.0.0-20210322153248-0c34fe9e7dc2 // indirect
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c // indirect
golang.org/x/tools v0.0.0-20200324003944-a576cf524670 // indirect
google.golang.org/protobuf v1.24.0 // indirect
gopkg.in/ini.v1 v1.55.0 // indirect
...
...
server/middleware/jwt.go
浏览文件 @
a71cfe1d
...
...
@@ -7,11 +7,12 @@ import (
"gin-vue-admin/model/request"
"gin-vue-admin/model/response"
"gin-vue-admin/service"
"strconv"
"time"
"github.com/dgrijalva/jwt-go"
"github.com/gin-gonic/gin"
"go.uber.org/zap"
"strconv"
"time"
)
func
JWTAuth
()
gin
.
HandlerFunc
{
...
...
@@ -48,7 +49,7 @@ func JWTAuth() gin.HandlerFunc {
}
if
claims
.
ExpiresAt
-
time
.
Now
()
.
Unix
()
<
claims
.
BufferTime
{
claims
.
ExpiresAt
=
time
.
Now
()
.
Unix
()
+
global
.
GVA_CONFIG
.
JWT
.
ExpiresTime
newToken
,
_
:=
j
.
CreateToken
(
*
claims
)
newToken
,
_
:=
j
.
CreateToken
ByOldToken
(
token
,
*
claims
)
newClaims
,
_
:=
j
.
ParseToken
(
newToken
)
c
.
Header
(
"new-token"
,
newToken
)
c
.
Header
(
"new-expires-at"
,
strconv
.
FormatInt
(
newClaims
.
ExpiresAt
,
10
))
...
...
@@ -91,6 +92,14 @@ func (j *JWT) CreateToken(claims request.CustomClaims) (string, error) {
return
token
.
SignedString
(
j
.
SigningKey
)
}
// CreateTokenByOldToken 旧token 换新token 使用归并回源避免并发问题
func
(
j
*
JWT
)
CreateTokenByOldToken
(
oldToken
string
,
claims
request
.
CustomClaims
)
(
string
,
error
)
{
v
,
err
,
_
:=
global
.
GVA_Concurrency_Control
.
Do
(
"JWT:"
+
oldToken
,
func
()
(
interface
{},
error
)
{
return
j
.
CreateToken
(
claims
)
})
return
v
.
(
string
),
err
}
// 解析 token
func
(
j
*
JWT
)
ParseToken
(
tokenString
string
)
(
*
request
.
CustomClaims
,
error
)
{
token
,
err
:=
jwt
.
ParseWithClaims
(
tokenString
,
&
request
.
CustomClaims
{},
func
(
token
*
jwt
.
Token
)
(
i
interface
{},
e
error
)
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录