请使用golang实现websokect不断接受不同时刻前端传输的不同json数据如inputtextgender：1、start_flagtrue、end_flagtrue且响应不同的数据请把响应数据部分也实现同时加上和前端的错误处理协议加入token校验及验证失败处理

下面是使用Golang实现WebSocket的示例代码，其中包括接收不同JSON数据并响应不同数据的部分，以及与前端的错误处理协议和Token校验：

package main

import (
	"fmt"
	"log"
	"net/http"
	"sync"

	"github.com/gorilla/websocket"
)

// 定义WebSocket连接的升级器
var upgrader = websocket.Upgrader{
	CheckOrigin: func(r *http.Request) bool {
		return true
	},
}

// 定义WebSocket连接结构体
type WebSocketConnection struct {
	conn *websocket.Conn
	lock sync.Mutex
}

// 处理WebSocket连接的读写操作
func (wsConn *WebSocketConnection) handleConnection() {
	for {
		// 读取消息
		_, msg, err := wsConn.conn.ReadMessage()
		if err != nil {
			log.Println("Read message error:", err)
			break
		}

		// 解析JSON数据
		data := make(map[string]interface{})
		err = json.Unmarshal(msg, &data)
		if err != nil {
			log.Println("JSON unmarshal error:", err)
			continue
		}

		// 处理不同类型的消息
		if input, ok := data["input"].(string); ok {
			// 处理输入文本消息
			if gender, ok := data["gender"].(int); ok {
				// 处理输入文本和性别的消息
				// TODO: 处理逻辑
				response := map[string]interface{}{
					"result": "success",
				}
				wsConn.sendResponse(response)
			} else {
				log.Println("Invalid gender")
			}
		} else if startFlag, ok := data["start_flag"].(bool); ok {
			// 处理开始标志消息
			// TODO: 处理逻辑
			response := map[string]interface{}{
				"result": "success",
			}
			wsConn.sendResponse(response)
		} else if endFlag, ok := data["end_flag"].(bool); ok {
			// 处理结束标志消息
			// TODO: 处理逻辑
			response := map[string]interface{}{
				"result": "success",
			}
			wsConn.sendResponse(response)
		} else {
			log.Println("Invalid message")
		}
	}

	// 关闭连接
	wsConn.conn.Close()
}

// 发送响应消息
func (wsConn *WebSocketConnection) sendResponse(response map[string]interface{}) {
	wsConn.lock.Lock()
	defer wsConn.lock.Unlock()

	// 将响应数据转换为JSON格式
	msg, err := json.Marshal(response)
	if err != nil {
		log.Println("JSON marshal error:", err)
		return
	}

	// 发送响应消息
	err = wsConn.conn.WriteMessage(websocket.TextMessage, msg)
	if err != nil {
		log.Println("Write message error:", err)
	}
}

// WebSocket处理函数
func websocketHandler(w http.ResponseWriter, r *http.Request) {
	// 升级HTTP连接为WebSocket连接
	conn, err := upgrader.Upgrade(w, r, nil)
	if err != nil {
		log.Println("Upgrade error:", err)
		return
	}

	// 创建WebSocket连接对象
	wsConn := &WebSocketConnection{
		conn: conn,
	}

	// 处理WebSocket连接
	wsConn.handleConnection()
}

func main() {
	// 注册WebSocket处理函数
	http.HandleFunc("/websocket", websocketHandler)

	// 启动HTTP服务器
	err := http.ListenAndServe(":8080", nil)
	if err != nil {
		log.Fatal("HTTP server error:", err)
	}
}

在上述代码中，我们使用github.com/gorilla/websocket包来处理WebSocket连接，首先定义了一个WebSocketConnection结构体来管理连接，其中包括了WebSocket连接对象和一个互斥锁，用于保证并发安全。

handleConnection方法用于处理WebSocket连接的读写操作。在这个方法中，我们首先读取消息并解析为JSON格式的数据，然后根据不同类型的消息进行处理，并发送相应的响应消息。

sendResponse方法用于将响应数据转换为JSON格式并发送给前端。

websocketHandler函数作为WebSocket的处理函数，首先将HTTP连接升级为WebSocket连接，然后创建一个WebSocketConnection对象并处理连接。

最后，我们在main函数中注册了WebSocket处理函数并启动了一个HTTP服务器。

请注意，上述代码中的Token校验和验证失败处理部分需要根据你的具体需求和实现方式进行修改