zhangdeman/queue
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

生产数据增生产加消息的机器IP

Browse Source
This commit is contained in:
白茶清欢 2022-07-06 19:00:50 +08:00
parent f3fd54906f
commit 57be7f3f33
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
delay/define.go
View File

@ -15,6 +15,7 @@ package delay
type ProduceData struct { type ProduceData struct {
MsgID string `json:"msg_id"` // 消息ID MsgID string `json:"msg_id"` // 消息ID
Timestamp int64 `json:"timestamp"` // 消息生成时间: ms Timestamp int64 `json:"timestamp"` // 消息生成时间: ms
Host string `json:"host"` // 生产消息的机器IP
Data map[string]interface{} `json:"data"` // 传入的业务数据 Data map[string]interface{} `json:"data"` // 传入的业务数据
} }

1
delay/redis_produce.go
View File

@ -69,6 +69,7 @@ func (rp *redisProduce) buildAddMember(queueData *Queue) *redis.Z {
byteData, _ := json.Marshal(&ProduceData{ byteData, _ := json.Marshal(&ProduceData{
MsgID: util.String.Md5(util.String.GenRandom("", 16)), MsgID: util.String.Md5(util.String.GenRandom("", 16)),
Timestamp: time.Now().UnixNano() / 1e6, Timestamp: time.Now().UnixNano() / 1e6,
Host: util.IP.GetHostIP(),
Data: queueData.Data, Data: queueData.Data,
}) })
return &redis.Z{ return &redis.Z{