Web socket 长链接。实时推送下单任务数据首页展示

客户端与后端建立连接。实时接受数据回显到页面。

过程：

客户端接到数据后做两件事

• 数据页面回显
• 告诉后端，我接受到了，再次发送新的数据

话不多说上代码

websocket包

go get github.com/gorilla/websocket

var (
    upgrader = websocket.Upgrader{
        ReadBufferSize:  0,
        WriteBufferSize: 0,
        CheckOrigin: func(r *http.Request) bool {
            return true
        },
    }
)

// 接口 客户端与这个接口建立连接
// GetDashBoardData
func (dbh *DashBoardHandler) GetDashBoardData(c echo.Context) error {

    ws, err := upgrader.Upgrade(c.Response(), c.Request(), nil)
    if err != nil {
        logger.RLog.Error(fmt.Sprintf("websocket connection failed "), zap.Error(err))
        return c.JSON(http.StatusOK, _system.WebSocketConnectionErr)
    }
    defer ws.Close()

    for {
        // write
        err = ws.WriteMessage(websocket.TextMessage, getDashboardData())
        if err != nil {
            logger.RLog.Error("websocket write failed")
            return c.JSON(http.StatusOK, _system.WebWriteErr)
        }
        // read
        _, msg, err := ws.ReadMessage()
        if err != nil {
            logger.RLog.Error("websocket read failed")
            return nil
        }
        //logger.RLog.Info(fmt.Sprintf("------------ msg: %v", string(msg)))
        if string(msg) == "success" {
            //logger.RLog.Info("------------------ 继续发送数据 ---------------")
            err = ws.WriteMessage(websocket.TextMessage, getDashboardData())
            if err != nil {
                logger.RLog.Error("websocket write failed")
                return c.JSON(http.StatusOK, _system.WebWriteErr)
            }
        }
    }
}

func getDashboardData() []byte {

  // 从数据中心拿数据
}

vu3部分代码