92 lines
4.1 KiB
GDScript3
92 lines
4.1 KiB
GDScript3
|
#*****************************************************************************
|
||
|
|
# @author MakerYang
|
||
|
|
# @site mir2.makeryang.com
|
||
|
|
#*****************************************************************************
|
||
|
|
|
||
|
|
extends Node
|
||
|
|
|
||
|
|
# 数据结构
|
||
|
|
var data = {
|
||
|
|
"players": {}
|
||
|
|
}
|
||
|
|
|
||
|
|
# 自定义数据
|
||
|
|
var server_peer:ENetMultiplayerPeer
|
||
|
|
|
||
|
|
# 预加载资源
|
||
|
|
@onready var player_scenes: PackedScene = preload("res://scenes/world/player/player.tscn")
|
||
|
|
|
||
|
|
# 创建服务器并返回服务器状态
|
||
|
|
func create_server() -> int:
|
||
|
|
server_peer = ENetMultiplayerPeer.new()
|
||
|
|
var error = server_peer.create_server(Global.get_server_port())
|
||
|
|
if error == OK:
|
||
|
|
multiplayer.multiplayer_peer = server_peer
|
||
|
|
multiplayer.peer_connected.connect(_on_peer_connected)
|
||
|
|
multiplayer.peer_disconnected.connect(_on_peer_disconnected)
|
||
|
|
return error
|
||
|
|
|
||
|
|
# 客户端连接服务器时回调函数
|
||
|
|
func _on_peer_connected(client_id: int) -> void:
|
||
|
|
if multiplayer.is_server():
|
||
|
|
print("[server:client:connected]", "当前:" + str(multiplayer.get_unique_id()), "-->", "目标:" + str(client_id))
|
||
|
|
# 通知当前连接客户端同步所有玩家数据
|
||
|
|
rpc_id(client_id, "sync_players_data", client_id, JSON.stringify(data["players"]))
|
||
|
|
|
||
|
|
# 客户端断开服务器时回调函数
|
||
|
|
func _on_peer_disconnected(client_id: int) -> void:
|
||
|
|
if data["players"][str(client_id)] and multiplayer.is_server():
|
||
|
|
print("[server:client:disconnected]", "当前:" + str(multiplayer.get_unique_id()), "-->", "目标:" + str(client_id))
|
||
|
|
var internal_url = "/internal/player/update/client/id?token=" + data["players"][str(client_id)]["token"] + "&client_id=" + str(0)
|
||
|
|
Request.on_internal(internal_url, HTTPClient.METHOD_GET, {}, func(_result, code, _headers, body):
|
||
|
|
if code == 200:
|
||
|
|
var response = JSON.parse_string(body.get_string_from_utf8())
|
||
|
|
if response.code != 0:
|
||
|
|
printerr("[server:client:disconnected:update:client:id]", JSON.stringify(response))
|
||
|
|
return
|
||
|
|
print("[server:client:disconnected:update:client:id]", JSON.stringify(response))
|
||
|
|
var players_node = get_parent().get_node("World").get_node("Main").get_node(data["players"][str(client_id)]["player_map"]).get_node("Players")
|
||
|
|
if players_node.has_node(str(client_id)):
|
||
|
|
var player_node = players_node.get_node(str(client_id))
|
||
|
|
player_node.queue_free()
|
||
|
|
data["players"].erase(str(client_id))
|
||
|
|
print("[server:client:disconnected:remove]", str(client_id))
|
||
|
|
rpc("on_remove_player", client_id)
|
||
|
|
else:
|
||
|
|
printerr("[server:request:ping]", "error")
|
||
|
|
)
|
||
|
|
|
||
|
|
@rpc("any_peer", "call_remote")
|
||
|
|
func on_add_player(client_id: int, player_data: String) -> void:
|
||
|
|
if multiplayer.is_server():
|
||
|
|
print("[server:add:player] ", "当前:" + str(multiplayer.get_unique_id()), "-->", "目标:" + str(client_id))
|
||
|
|
var player_json = JSON.parse_string(player_data)
|
||
|
|
data["players"][str(client_id)] = player_json
|
||
|
|
rpc("sync_player_data", client_id, player_data)
|
||
|
|
var players_node: Node2D = get_parent().get_node("World").get_node("Main").get_node(player_json["player_map"]).get_node("Players")
|
||
|
|
var player_node:Player = player_scenes.instantiate()
|
||
|
|
player_node.name = str(client_id)
|
||
|
|
players_node.add_child(player_node)
|
||
|
|
|
||
|
|
@rpc("any_peer", "call_remote")
|
||
|
|
func on_remove_player(client_id: int) -> void:
|
||
|
|
if !multiplayer.is_server():
|
||
|
|
print("[client:disconnected:remove]", "当前:" + str(multiplayer.get_unique_id()), "-->", "目标:" + str(client_id))
|
||
|
|
data["players"].erase(str(client_id))
|
||
|
|
|
||
|
|
@rpc("any_peer", "call_remote")
|
||
|
|
# 客户端同步玩家数据
|
||
|
|
func sync_player_data(client_id: int, player_data: String) -> void:
|
||
|
|
if !multiplayer.is_server():
|
||
|
|
print("[client:sync:player] ", "当前:" + str(multiplayer.get_unique_id()), "-->", "目标:" + str(client_id))
|
||
|
|
var player_json = JSON.parse_string(player_data)
|
||
|
|
data["players"][str(client_id)] = player_json
|
||
|
|
|
||
|
|
@rpc("any_peer", "call_remote")
|
||
|
|
# 客户端同步所有玩家数据
|
||
|
|
func sync_players_data(client_id: int, players_data: String) -> void:
|
||
|
|
if !multiplayer.is_server():
|
||
|
|
print("[client:sync:players] ", "当前:" + str(multiplayer.get_unique_id()), "-->", "目标:" + str(client_id))
|
||
|
|
var player_json = JSON.parse_string(players_data)
|
||
|
|
data["players"] = player_json
|