websocket 为什么是按顺序执行的？

这是用node写的，是可以同时执行的

var conn *websocket.Conn

func (c *Controller) Subscribe(ctx echo.Context) error {
	upgrader := websocket.Upgrader{
		CheckOrigin: func(r *http.Request) bool {
			return true
		},
		EnableCompression: true,
	}
	ws, err := upgrader.Upgrade(ctx.Response(), ctx.Request(), nil)
	if err != nil {
		return err
	}
	conn = ws

	go c.readLoop(ctx)

	return nil
}

func (c *Controller) readLoops(ctx echo.Context) {
	token := ctx.Request().URL.Query().Get("auth")
	userData, err := c.userService.GetUserDataFromCache(token)
	if err != nil {
		_ = conn.WriteJSON(tool.WebsocketResponse("error", err.Error(), nil))
	}

	for {
		body := new(socketRequest)
		if err := conn.ReadJSON(body); err != nil {
			_ = conn.WriteJSON(tool.WebsocketResponse("error", err.Error(), nil))
		}
		if err := ctx.Validate(body); err != nil {
			_ = conn.WriteJSON(tool.WebsocketResponse("error", err.Error(), nil))
		} else {
			switch body.Event {
			case "create":
				albumId, err := c.hashId.HashIdDecode(*body.Payload.AlbumId)
				if err != nil {
					_ = conn.WriteJSON(tool.WebsocketResponse("error", err.Error(), nil))
				}

				if event, err := c.CreateFromUrl(userData.Id, albumId, *body.Payload.Url); err != nil {
					_ = conn.WriteJSON(tool.WebsocketResponse(event, err.Error(), body.Payload))
				} else {
					_ = conn.WriteJSON(tool.WebsocketResponse(event, "", body.Payload))
				}
			}
		}
	}
}

解决咯~

在for里面写个go func，这样每次收到event的时候就能去开启一个goroutine去执行任务咯~ 这样写只是我一个人用而已没加消息队列。如果是大站的话不加估计会挂掉~