当前位置：首页 > news >正文

godot使用ws

news 2025/7/13 7:30:26

go服务端

package mainimport ("encoding/json""fmt""github.com/gorilla/websocket""net/http"
)var upgrader = websocket.Upgrader{ReadBufferSize:  1024,WriteBufferSize: 1024,
}// 处理函数
func handleWebSocket(w http.ResponseWriter, r *http.Request) {// 使用 upgrader 将 HTTP 连接升级为 WebSocket 连接conn, err := upgrader.Upgrade(w, r, nil)if err != nil {fmt.Println("Upgrade:", err)return}defer conn.Close()for {// 读取客户端发送的消息messageType, message, err := conn.ReadMessage()if err != nil {fmt.Println("Read:", err)break}fmt.Printf("Received: %s\n", message)// 将消息回发给客户端m := map[string]string{}m["message"] = "hello"marshal, err := json.Marshal(m)if err != nil {return}err = conn.WriteMessage(messageType, marshal)if err != nil {fmt.Println("Write:", err)break}}
}func main() {http.HandleFunc("/ws", handleWebSocket)fmt.Println("Listening on :11111...")err := http.ListenAndServe(":11111", nil)if err != nil {panic(err)}
}

godot 客户端

extends Nodevar socket = WebSocketPeer.new()func _ready():socket.connect_to_url("ws://localhost:11111/ws")print("conn ws")socket.send_text("hello")func _process(delta):socket.poll()var state = socket.get_ready_state()if state == WebSocketPeer.STATE_OPEN:socket.send_text("godot hello")while socket.get_available_packet_count():var json_string = socket.get_packet().get_string_from_utf8()print("数据包：", json_string)#var dict = JSON.parse_string(json_string)# 创建 JSON 解析器实例#var json_parser = JSON.new()# 解析 JSON 字符串到字典#var dict = json_parser.parse(json_string)#print("dict ", dict)#if dict != null:#print(dict)#Dictionary result =(Dictionary)json.Parse(json_string).Result;#print(result["message"]);if json_string == "":continueelse :print(json_string)var json = JSON.new()var data = json.parse_string(json_string)if data != null:print(" get message : " , data["message"])pass#var data_received = json.data#print("data_received : ",data_received)else:print("JSON Parse Error: ", json.get_error_message(), " in ", json_string, " at line ", json.get_error_line())elif state == WebSocketPeer.STATE_CLOSING:# 继续轮询才能正确关闭。passelif state == WebSocketPeer.STATE_CLOSED:var code = socket.get_close_code()var reason = socket.get_close_reason()print("WebSocket 已关闭，代码：%d，原因 %s。干净得体：%s" % [code, reason, code != -1])set_process(false) # 停止处理。