yunfantec
/
mq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: yunfantec:679154720f57e6089e84b6e02639501ca7b456d3
Branches Tags
yunfantec:master
...
compare: yunfantec:2a93e1cc384b456a28b4a2f6f1f90e6d3d5bae20
Branches Tags
yunfantec:master

3 Commits
679154720f ... 2a93e1cc38

Author SHA1 Message Date
qiyunfanbo126.com 2a93e1cc38 增加重连 2025-01-22 14:34:18 +08:00
qiyunfanbo126.com 90a4ad85d0 增加重连 2025-01-22 14:15:01 +08:00
qiyunfanbo126.com 2c62f5d38a 优化短线后cpu飙升问题 2025-01-22 13:50:59 +08:00
3 changed files with 3 additions and 3 deletions
Show Stats Expand all files Collapse all files

1
app/http/tcppool/single.go
View File

@ -144,6 +144,7 @@ func (t *TcpHelper) watch(conn net.Conn) {
} else { } else {
atomic.StoreInt32(t.Full, 1) atomic.StoreInt32(t.Full, 1)
utils.Log(nil, "连接关闭", err) utils.Log(nil, "连接关闭", err)
t.reconnect(config.GetConf().OrderPort)
} }
} }
time.Sleep(1 * time.Second) time.Sleep(1 * time.Second)

2
app/utils/mq/kafka_v2.go
View File

@ -95,7 +95,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
go func() { go func() {
for { for {
if atomic.LoadInt32(tcppool.TcpFactory.Full) == 1 { if atomic.LoadInt32(tcppool.TcpFactory.Full) == 1 {
utils.Log(nil, "对列阻塞") //utils.Log(nil, "对列阻塞")
time.Sleep(100 * time.Millisecond) time.Sleep(100 * time.Millisecond)
continue continue
} else { } else {

3
app/utils/util.go
View File

@ -9,7 +9,6 @@ import (
func Log(c *gin.Context, name string, msg ...interface{}) { func Log(c *gin.Context, name string, msg ...interface{}) {
_, file, line, _ := runtime.Caller(1) _, file, line, _ := runtime.Caller(1)
timeLayout := "2006-01-01 03:04:05" //转化所需模板 var datetime = time.Now().Format(time.DateTime)
var datetime = time.Unix(time.Now().Unix(), 0).Format(timeLayout)
fmt.Println(name, msg, file, line, datetime) fmt.Println(name, msg, file, line, datetime)
} }