Compare commits
2 Commits
b65234689c
...
c17348d3ad
| Author | SHA1 | Date |
|---|---|---|
|
|
c17348d3ad | |
|
|
fe9d0650dc |
|
|
@ -362,7 +362,8 @@ func ServerSendMsg(c *gin.Context) {
|
||||||
if len(msgs) > 0 {
|
if len(msgs) > 0 {
|
||||||
msg := msgs[0]
|
msg := msgs[0]
|
||||||
//发送消息
|
//发送消息
|
||||||
_, err := c.Writer.Write([]byte("data: " + msg.Msg + "\n\n"))
|
msg_str, _ := json.Marshal(msg)
|
||||||
|
_, err := c.Writer.Write([]byte("data: " + string(msg_str) + "\n\n"))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
worker.SetRedisWithExpire("user_"+strconv.Itoa(user_id)+"_status_v2", "0", time.Second*3600)
|
worker.SetRedisWithExpire("user_"+strconv.Itoa(user_id)+"_status_v2", "0", time.Second*3600)
|
||||||
break
|
break
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue