客服系统即时通讯IM开发（五）网站实时向在线访客推送消息

        //发送给监控访客消息
        kefuGroup.POST("/monitorMessage", controller.PostMonitorMessage)

type MonitorMessageForm struct {
    UniqId  string `form:"uniqid" json:"uniqid" uri:"uniqid" xml:"uniqid" binding:"required"`
    Message string `form:"message" json:"message" uri:"message" xml:"message" binding:"required"`
}

//监控访客消息
func PostMonitorMessage(c *gin.Context) {
    var form MonitorMessageForm
    err := c.Bind(&form)
    if err != nil {
        c.JSON(200, gin.H{
            "code":   types.ApiCode.FAILED,
            "msg":    types.ApiCode.GetMessage(types.ApiCode.INVALID),
            "result": err.Error(),
        })
        return
    }
    kefuName, _ := c.Get("kefu_name")

    for conn, connect := range ws.MonitorList {
        if connect.KefuName == kefuName && form.UniqId == connect.UinqId {
            conn.WriteMessage(1, []byte(form.Message))
        }
    }

    c.JSON(200, gin.H{
        "code": 200,
        "msg":  "ok",
    })
}

    ws.onmessage = function (event) {
        console.log(`收到服务器的消息：${event.data}`);
        let data=event.data;

        if(data=="ok"){

        }
        if(data=="chat"){

        }

    };