From 7f2cd281dacd87d7c8921815cc62fa3630e50d19 Mon Sep 17 00:00:00 2001 From: tolelom <98kimsungmin@naver.com> Date: Tue, 17 Mar 2026 00:34:40 +0900 Subject: [PATCH 1/2] =?UTF-8?q?fix:=20MMO=20=EC=84=9C=EB=B2=84=20=EB=A1=9C?= =?UTF-8?q?=EC=A7=81=20=EB=B2=84=EA=B7=B8=206=EA=B1=B4=20=EC=88=98?= =?UTF-8?q?=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 1. PlayerId 스푸핑 방지: OnTransformPlayer, OnActionPlayer, OnStatePlayer에서 브로드캐스트 전 packet.PlayerId = hashKey로 강제 교체 2. HP/MP 클라이언트 조작 방지: OnStatePlayer에서 범위 클램핑 (0 ≤ Hp ≤ MaxHp, 0 ≤ Mp ≤ MaxMp) 3. CreateParty 파티원 등록 누락 수정: - memberIds 파라미터 사용 시 모든 멤버를 playerPartyMap에 등록 - 리더 중복 추가 방지 (Contains 체크) 4. OnIntoChannel 채널 만석 유령 상태 방지: 이전 채널 제거 후 새 채널 입장 실패 시 이전 채널로 복귀 5. HandleAuth async 경합 방지: authenticatingTokens HashSet으로 동일 토큰 동시 인증 차단 6. 레이드 맵 미반환 수정: TryReleaseRaidMap 헬퍼 추가, OnChangeMap/OnSessionDisconnected에서 레이드 맵(1001+) 유저 0명 시 인스턴스 맵 해제 Co-Authored-By: Claude Opus 4.6 (1M context) --- MMOTestServer/MMOserver/Game/GameServer.cs | 137 +++++++++++++----- .../MMOserver/Game/Party/PartyManager.cs | 14 +- 2 files changed, 116 insertions(+), 35 deletions(-) diff --git a/MMOTestServer/MMOserver/Game/GameServer.cs b/MMOTestServer/MMOserver/Game/GameServer.cs index 4318702..4ae78d1 100644 --- a/MMOTestServer/MMOserver/Game/GameServer.cs +++ b/MMOTestServer/MMOserver/Game/GameServer.cs @@ -18,6 +18,9 @@ public class GameServer : ServerBase private readonly Dictionary> packetHandlers; private readonly UuidGenerator userUuidGenerator; + // 동일 토큰 동시 인증 방지 + private readonly HashSet authenticatingTokens = new(); + public GameServer(int port, string connectionString) : base(port, connectionString) { packetHandlers = new Dictionary> @@ -103,49 +106,65 @@ public class GameServer : ServerBase { AccTokenPacket accTokenPacket = Serializer.Deserialize(new ReadOnlyMemory(payload)); string token = accTokenPacket.Token; - string username = ""; - tokenHash.TryGetValue(token, out int hashKey); - if (hashKey <= 1000) + + // 동일 토큰 동시 인증 방지 + if (!authenticatingTokens.Add(token)) { - hashKey = userUuidGenerator.Create(); + Log.Warning("[Server] 동일 토큰 동시 인증 시도 차단 PeerId={Id}", peer.Id); + peer.Disconnect(); + return; } - if (sessions.TryGetValue(hashKey, out NetPeer? existing)) + try { - // WiFi → LTE 전환 등 재연결: 이전 피어 교체 (토큰 재검증 불필요) - existing.Tag = null; - sessions.Remove(hashKey); - Log.Information("[Server] 재연결 HashKey={Key} Old={Old} New={New}", hashKey, existing.Id, peer.Id); - existing.Disconnect(); - } - else - { - // 신규 연결: 웹서버에 JWT 검증 요청 - username = await RestApi.Instance.VerifyTokenAsync(token); - if (username == null) + string username = ""; + tokenHash.TryGetValue(token, out int hashKey); + if (hashKey <= 1000) { - Log.Warning("[Server] 토큰 검증 실패 - 연결 거부 PeerId={Id}", peer.Id); - userUuidGenerator.Release(hashKey); - peer.Disconnect(); - return; + hashKey = userUuidGenerator.Create(); } - Log.Information("[Server] 토큰 검증 성공 Username={Username} PeerId={Id}", username, peer.Id); - } + if (sessions.TryGetValue(hashKey, out NetPeer? existing)) + { + // WiFi → LTE 전환 등 재연결: 이전 피어 교체 (토큰 재검증 불필요) + existing.Tag = null; + sessions.Remove(hashKey); + Log.Information("[Server] 재연결 HashKey={Key} Old={Old} New={New}", hashKey, existing.Id, peer.Id); + existing.Disconnect(); + } + else + { + // 신규 연결: 웹서버에 JWT 검증 요청 + username = await RestApi.Instance.VerifyTokenAsync(token); + if (username == null) + { + Log.Warning("[Server] 토큰 검증 실패 - 연결 거부 PeerId={Id}", peer.Id); + userUuidGenerator.Release(hashKey); + peer.Disconnect(); + return; + } - peer.Tag = new Session(hashKey, peer); - ((Session)peer.Tag).Token = token; - if (username.Length > 0) + Log.Information("[Server] 토큰 검증 성공 Username={Username} PeerId={Id}", username, peer.Id); + } + + peer.Tag = new Session(hashKey, peer); + ((Session)peer.Tag).Token = token; + if (username.Length > 0) + { + ((Session)peer.Tag).UserName = username; + } + + sessions[hashKey] = peer; + tokenHash[token] = hashKey; + pendingPeers.Remove(peer.Id); + + Log.Information("[Server] 인증 완료 HashKey={Key} PeerId={Id}", hashKey, peer.Id); + OnSessionConnected(peer, hashKey); + } + finally { - ((Session)peer.Tag).UserName = username; + authenticatingTokens.Remove(token); } - - sessions[hashKey] = peer; - tokenHash[token] = hashKey; - pendingPeers.Remove(peer.Id); - - Log.Information("[Server] 인증 완료 HashKey={Key} PeerId={Id}", hashKey, peer.Id); - OnSessionConnected(peer, hashKey); } protected override void OnSessionConnected(NetPeer peer, int hashKey) @@ -186,6 +205,9 @@ public class GameServer : ServerBase // 파티 자동 탈퇴 HandlePartyLeaveOnExit(channelId, hashKey); + // 레이드 맵이었으면 해제 체크 + TryReleaseRaidMap(cm.GetChannel(channelId), player.CurrentMapId); + // 같은 채널 유저들에게 나갔다고 알림 SendExitChannelPacket(peer, hashKey, channelId, player); } @@ -447,6 +469,20 @@ public class GameServer : ServerBase { Log.Warning("[GameServer] INTO_CHANNEL 채널 인원 초과 HashKey={Key} ChannelId={ChannelId} UserCount={Count}/{Max}", hashKey, packet.ChannelId, newChannel.UserCount, newChannel.UserCountMax); + + // 이전 채널에서 이미 제거된 경우 → 이전 채널로 복귀 + if (preChannelId >= 0) + { + Player? fallbackPlayer = new() + { + HashKey = hashKey, + PlayerId = hashKey, + Nickname = ((Session)peer.Tag).UserName + }; + cm.AddUser(preChannelId, hashKey, fallbackPlayer, peer); + Log.Information("[GameServer] INTO_CHANNEL 만석 → 이전 채널({ChannelId})로 복귀 HashKey={Key}", preChannelId, hashKey); + } + byte[] full = PacketSerializer.Serialize((ushort)PacketCode.INTO_CHANNEL, new IntoChannelPacket { ChannelId = -1 }); SendTo(peer, full); @@ -662,6 +698,9 @@ public class GameServer : ServerBase player.PosZ = packet.Position.Z; player.RotY = packet.RotY; + // PlayerId 강제 교체 (클라이언트 스푸핑 방지) + packet.PlayerId = hashKey; + // 같은 맵 유저들에게 위치/방향 브로드캐스트 (나 제외) byte[] data = PacketSerializer.Serialize((ushort)PacketCode.TRANSFORM_PLAYER, packet); BroadcastToMap(channelId, player.CurrentMapId, data, peer, DeliveryMethod.Unreliable); @@ -684,6 +723,9 @@ public class GameServer : ServerBase return; } + // PlayerId 강제 교체 (클라이언트 스푸핑 방지) + packet.PlayerId = hashKey; + // 같은 맵 유저들에게 행동 브로드캐스트 (나 제외) byte[] data = PacketSerializer.Serialize((ushort)PacketCode.ACTION_PLAYER, packet); BroadcastToMap(channelId, player.CurrentMapId, data, peer); @@ -707,6 +749,15 @@ public class GameServer : ServerBase return; } + // PlayerId 강제 교체 (클라이언트 스푸핑 방지) + packet.PlayerId = hashKey; + + // HP/MP 범위 클램핑 (클라이언트 조작 방지) + if (packet.MaxHp < 0) packet.MaxHp = 0; + if (packet.MaxMp < 0) packet.MaxMp = 0; + packet.Hp = Math.Clamp(packet.Hp, 0, packet.MaxHp); + packet.Mp = Math.Clamp(packet.Mp, 0, packet.MaxMp); + player.Hp = packet.Hp; player.MaxHp = packet.MaxHp; player.Mp = packet.Mp; @@ -957,6 +1008,10 @@ public class GameServer : ServerBase } SendTo(peer, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, response)); + + // 레이드 맵(1001+)에서 나갔고 남은 유저가 0이면 인스턴스 맵 해제 + TryReleaseRaidMap(channel, oldMapId); + Log.Debug("[GameServer] CHANGE_MAP HashKey={Key} OldMap={OldMapId} NewMap={MapId}", hashKey, oldMapId, packet.MapId); } @@ -1188,6 +1243,22 @@ public class GameServer : ServerBase BroadcastToChannel(channelId, data); } + // 레이드 맵(1001+)에서 유저가 빠졌을 때, 남은 유저가 0이면 인스턴스 맵 해제 + private static void TryReleaseRaidMap(Channel.Channel channel, int mapId) + { + if (mapId < 1001) + { + return; + } + + AMap? map = channel.GetMap(mapId); + if (map != null && map.GetUsers().Count == 0) + { + channel.RemoveInstanceMap(mapId); + Log.Debug("[GameServer] 레이드 맵 해제 MapId={MapId}", mapId); + } + } + private void SendError(NetPeer peer, ErrorCode code) { ErrorPacket err = new() { Code = code }; diff --git a/MMOTestServer/MMOserver/Game/Party/PartyManager.cs b/MMOTestServer/MMOserver/Game/Party/PartyManager.cs index 7dca0b9..c87b642 100644 --- a/MMOTestServer/MMOserver/Game/Party/PartyManager.cs +++ b/MMOTestServer/MMOserver/Game/Party/PartyManager.cs @@ -28,6 +28,12 @@ public class PartyManager memeberIds = new List(); } + // 리더 중복 방지: 기존 멤버 목록에 리더가 없을 때만 추가 + if (!memeberIds.Contains(leaderId)) + { + memeberIds.Add(leaderId); + } + party = new PartyInfo { PartyId = partyId, @@ -35,10 +41,14 @@ public class PartyManager PartyName = partyName, PartyMemberIds = memeberIds }; - party.PartyMemberIds.Add(leaderId); parties[partyId] = party; - playerPartyMap[leaderId] = partyId; + + // 모든 멤버를 playerPartyMap에 등록 + foreach (int memberId in memeberIds) + { + playerPartyMap[memberId] = partyId; + } return true; } From 53eabe2f3db2d02f3292d1b45fac000a24e9827a Mon Sep 17 00:00:00 2001 From: tolelom <98kimsungmin@naver.com> Date: Wed, 18 Mar 2026 23:26:39 +0900 Subject: [PATCH 2/2] =?UTF-8?q?fix:=20MMO=20=EC=84=9C=EB=B2=84=20=EB=B2=84?= =?UTF-8?q?=EA=B7=B8=20=EC=88=98=EC=A0=95=20=EB=B0=8F=20=EC=95=88=EC=A0=95?= =?UTF-8?q?=EC=84=B1=20=EA=B0=9C=EC=84=A0=20(20=EA=B1=B4)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - VerifyTokenAsync 인증 우회 차단 (빈 문자열→null 반환) - HandleAuth/OnIntoBossRaid async void→async Task 전환 - await 후 스레드 안전성 확보 (sessionLock 도입) - 보스레이드 파티원 세션/토큰 개별 전달 (tokens Dictionary 타입 수정) - 409 Conflict 처리 추가, bossId 하드코딩 제거 - 채널 이동 시 레이드 맵 해제, 플레이어 상태 보존 - 파티원 닉네임 손실 수정, HandlePartyLeaveOnExit 알림 타입 수정 - PacketCode enum 명시적 값 할당, MaplId→MapId/BossRaidAccesss→Access 오타 수정 - Channel.UserCount 음수 방지, HandleAuth 재연결 로직 수정 Co-Authored-By: Claude Opus 4.6 (1M context) --- MMOTestServer/MMOserver/Api/BossRaidResult.cs | 2 +- MMOTestServer/MMOserver/Api/RestApi.cs | 16 +- .../MMOserver/Game/Channel/Channel.cs | 7 +- MMOTestServer/MMOserver/Game/GameServer.cs | 283 +++++++++++------- MMOTestServer/MMOserver/Packet/PacketBody.cs | 2 +- .../MMOserver/Packet/PacketHeader.cs | 122 ++++---- MMOTestServer/ServerLib/Service/ServerBase.cs | 42 ++- 7 files changed, 275 insertions(+), 199 deletions(-) diff --git a/MMOTestServer/MMOserver/Api/BossRaidResult.cs b/MMOTestServer/MMOserver/Api/BossRaidResult.cs index 4a9c629..1a0abc3 100644 --- a/MMOTestServer/MMOserver/Api/BossRaidResult.cs +++ b/MMOTestServer/MMOserver/Api/BossRaidResult.cs @@ -9,5 +9,5 @@ public sealed class BossRaidResult public int BossId { get; init; } public List Players { get; init; } = new(); public string Status { get; init; } = string.Empty; - public string? Tokens { get; init; } + public Dictionary? Tokens { get; init; } } diff --git a/MMOTestServer/MMOserver/Api/RestApi.cs b/MMOTestServer/MMOserver/Api/RestApi.cs index 7c418ec..0ba4735 100644 --- a/MMOTestServer/MMOserver/Api/RestApi.cs +++ b/MMOTestServer/MMOserver/Api/RestApi.cs @@ -35,7 +35,7 @@ public class RestApi : Singleton if (response.StatusCode == HttpStatusCode.Unauthorized) { Log.Warning("[RestApi] 토큰 인증 실패 (401)"); - return ""; + return null; } response.EnsureSuccessStatusCode(); @@ -56,7 +56,7 @@ public class RestApi : Singleton } } - return ""; + return null; } private sealed class AuthVerifyResponse @@ -71,7 +71,7 @@ public class RestApi : Singleton // 레이드 채널 접속 여부 체크 // 성공 시 BossRaidResult 반환, 실패/거절 시 null 반환 - public async Task BossRaidAccesssAsync(List userNames, int bossId) + public async Task BossRaidAccessAsync(List userNames, int bossId) { string url = AppConfig.RestApi.BaseUrl + "/api/internal/bossraid/entry"; @@ -88,10 +88,12 @@ public class RestApi : Singleton return null; } - // 400: 입장 조건 미충족 (레벨 부족, 이미 진행중 등) - if (response.StatusCode == HttpStatusCode.BadRequest) + // 400: 입장 조건 미충족 / 409: 이미 레이드 중 등 + if (response.StatusCode == HttpStatusCode.BadRequest || + response.StatusCode == HttpStatusCode.Conflict) { - Log.Warning("[RestApi] 보스 레이드 입장 거절 (400) BossId={BossId}", bossId); + Log.Warning("[RestApi] 보스 레이드 입장 거절 ({Status}) BossId={BossId}", + (int)response.StatusCode, bossId); return null; } @@ -166,7 +168,7 @@ public class RestApi : Singleton } [JsonPropertyName("tokens")] - public string? Tokens + public Dictionary? Tokens { get; set; diff --git a/MMOTestServer/MMOserver/Game/Channel/Channel.cs b/MMOTestServer/MMOserver/Game/Channel/Channel.cs index 98ee1ff..386a636 100644 --- a/MMOTestServer/MMOserver/Game/Channel/Channel.cs +++ b/MMOTestServer/MMOserver/Game/Channel/Channel.cs @@ -79,9 +79,12 @@ public class Channel currentMap.RemoveUser(userId); } - connectUsers.Remove(userId); + if (connectUsers.Remove(userId)) + { + UserCount--; + } + connectPeers.Remove(userId); - UserCount--; } // 맵 이동 (현재 맵 제거 → 새 맵 추가 → CurrentMapId 갱신) diff --git a/MMOTestServer/MMOserver/Game/GameServer.cs b/MMOTestServer/MMOserver/Game/GameServer.cs index 4ae78d1..a953768 100644 --- a/MMOTestServer/MMOserver/Game/GameServer.cs +++ b/MMOTestServer/MMOserver/Game/GameServer.cs @@ -102,7 +102,7 @@ public class GameServer : ServerBase OnSessionConnected(peer, hashKey); } - protected override async void HandleAuth(NetPeer peer, byte[] payload) + protected override async Task HandleAuth(NetPeer peer, byte[] payload) { AccTokenPacket accTokenPacket = Serializer.Deserialize(new ReadOnlyMemory(payload)); string token = accTokenPacket.Token; @@ -118,21 +118,28 @@ public class GameServer : ServerBase try { string username = ""; - tokenHash.TryGetValue(token, out int hashKey); - if (hashKey <= 1000) + int hashKey; + bool isReconnect; + + lock (sessionLock) { - hashKey = userUuidGenerator.Create(); + isReconnect = tokenHash.TryGetValue(token, out hashKey) && hashKey > 1000; + if (!isReconnect) + { + hashKey = userUuidGenerator.Create(); + } + + if (isReconnect && sessions.TryGetValue(hashKey, out NetPeer? existing)) + { + // WiFi → LTE 전환 등 재연결: 이전 피어 교체 (토큰 재검증 불필요) + existing.Tag = null; + sessions.Remove(hashKey); + Log.Information("[Server] 재연결 HashKey={Key} Old={Old} New={New}", hashKey, existing.Id, peer.Id); + existing.Disconnect(); + } } - if (sessions.TryGetValue(hashKey, out NetPeer? existing)) - { - // WiFi → LTE 전환 등 재연결: 이전 피어 교체 (토큰 재검증 불필요) - existing.Tag = null; - sessions.Remove(hashKey); - Log.Information("[Server] 재연결 HashKey={Key} Old={Old} New={New}", hashKey, existing.Id, peer.Id); - existing.Disconnect(); - } - else + if (!isReconnect) { // 신규 연결: 웹서버에 JWT 검증 요청 username = await RestApi.Instance.VerifyTokenAsync(token); @@ -147,16 +154,20 @@ public class GameServer : ServerBase Log.Information("[Server] 토큰 검증 성공 Username={Username} PeerId={Id}", username, peer.Id); } - peer.Tag = new Session(hashKey, peer); - ((Session)peer.Tag).Token = token; - if (username.Length > 0) + // await 이후 — 공유 자원 접근 보호 + lock (sessionLock) { - ((Session)peer.Tag).UserName = username; - } + peer.Tag = new Session(hashKey, peer); + ((Session)peer.Tag).Token = token; + if (username.Length > 0) + { + ((Session)peer.Tag).UserName = username; + } - sessions[hashKey] = peer; - tokenHash[token] = hashKey; - pendingPeers.Remove(peer.Id); + sessions[hashKey] = peer; + tokenHash[token] = hashKey; + pendingPeers.Remove(peer.Id); + } Log.Information("[Server] 인증 완료 HashKey={Key} PeerId={Id}", hashKey, peer.Id); OnSessionConnected(peer, hashKey); @@ -357,7 +368,7 @@ public class GameServer : ServerBase { IsAccepted = true, Player = ToPlayerInfo(player), - MaplId = channelId + MapId = player.CurrentMapId }; byte[] data = PacketSerializer.Serialize((ushort)PacketCode.LOAD_GAME, packet); @@ -444,14 +455,20 @@ public class GameServer : ServerBase // 이전에 다른 채널에 있었는지 체크 int preChannelId = cm.HasUser(hashKey); + Player? prevPlayer = preChannelId >= 0 ? cm.GetChannel(preChannelId).GetPlayer(hashKey) : null; if (preChannelId >= 0) { - // 제거 전에 채널/플레이어 정보 저장 (브로드캐스트에 필요) - Player? player = cm.GetChannel(preChannelId).GetPlayer(hashKey); + Player? player = prevPlayer; // 파티 자동 탈퇴 HandlePartyLeaveOnExit(preChannelId, hashKey); + // 레이드 맵 해제 체크 + if (player != null) + { + TryReleaseRaidMap(cm.GetChannel(preChannelId), player.CurrentMapId); + } + cm.RemoveUser(hashKey); Log.Debug("[GameServer] EXIT_CHANNEL HashKey={Key} PlayerId={PlayerId}", hashKey, preChannelId); @@ -471,15 +488,9 @@ public class GameServer : ServerBase hashKey, packet.ChannelId, newChannel.UserCount, newChannel.UserCountMax); // 이전 채널에서 이미 제거된 경우 → 이전 채널로 복귀 - if (preChannelId >= 0) + if (preChannelId >= 0 && prevPlayer != null) { - Player? fallbackPlayer = new() - { - HashKey = hashKey, - PlayerId = hashKey, - Nickname = ((Session)peer.Tag).UserName - }; - cm.AddUser(preChannelId, hashKey, fallbackPlayer, peer); + cm.AddUser(preChannelId, hashKey, prevPlayer, peer); Log.Information("[GameServer] INTO_CHANNEL 만석 → 이전 채널({ChannelId})로 복귀 HashKey={Key}", preChannelId, hashKey); } @@ -543,12 +554,19 @@ public class GameServer : ServerBase ChannelManager cm = ChannelManager.Instance; int preChannelId = cm.HasUser(hashKey); + + // 이전에 다른 채널에 있었는지 체크 / 파티이동은 이미 접속한 상태여야 한다. + if (preChannelId < 0) + { + Log.Warning("[GameServer] INTO_CHANNEL_PARTY 채널에 접속하지 않은 유저"); + return; + } + Channel.Channel preChannel = cm.GetChannel(preChannelId); Channel.Channel newChannel = cm.GetChannel(packet.ChannelId); PartyInfo? preParty = preChannel.GetPartyManager().GetParty(packet.PartyId); - // 이전에 다른 채널에 있었는지 체크 / 파티이동은 이미 접속한 상태여야 한다. - if (preChannelId < 0 || preParty == null) + if (preParty == null) { Log.Warning("[GameServer] INTO_CHANNEL_PARTY 해당 파티 없음"); return; @@ -569,12 +587,15 @@ public class GameServer : ServerBase return; } - // 기존 채널에서 제거 + 기존 채널 유저들에게 나감 알림 + // 기존 채널에서 제거 전에 플레이어 정보 보존 + Dictionary savedPlayers = new(); foreach (int memberId in preParty.PartyMemberIds) { Player? player = preChannel.GetPlayer(memberId); if (player != null) { + savedPlayers[memberId] = player; + UpdateChannelUserPacket exitNotify = new() { Players = ToPlayerInfo(player), @@ -610,12 +631,13 @@ public class GameServer : ServerBase if (memberPeer != null) { - // 새 채널에 유저 추가 + // 새 채널에 유저 추가 (보존된 플레이어 정보 사용) + string nickname = savedPlayers.TryGetValue(memberId, out Player? saved) ? saved.Nickname : memberId.ToString(); Player newPlayer = new() { HashKey = memberId, PlayerId = memberId, - Nickname = memberId.ToString() + Nickname = nickname }; cm.AddUser(packet.ChannelId, memberId, newPlayer, memberPeer); @@ -663,6 +685,12 @@ public class GameServer : ServerBase if (channelId >= 0) { HandlePartyLeaveOnExit(channelId, hashKey); + + // 레이드 맵 해제 체크 + if (player != null) + { + TryReleaseRaidMap(cm.GetChannel(channelId), player.CurrentMapId); + } } cm.RemoveUser(hashKey); @@ -1092,7 +1120,16 @@ public class GameServer : ServerBase Log.Debug("[GameServer] PARTY_CHANGE_MAP HashKey={Key} PartyId={PartyId} MapId={MapId}", hashKey, packet.PartyId, packet.MapId); } - private async void OnIntoBossRaid(NetPeer peer, int hashKey, byte[] payload) + private void OnIntoBossRaid(NetPeer peer, int hashKey, byte[] payload) + { + _ = OnIntoBossRaidAsync(peer, hashKey, payload).ContinueWith(t => + { + if (t.IsFaulted) + Log.Error(t.Exception, "[GameServer] OnIntoBossRaid 예외 HashKey={Key}", hashKey); + }, TaskContinuationOptions.OnlyOnFaulted); + } + + private async Task OnIntoBossRaidAsync(NetPeer peer, int hashKey, byte[] payload) { IntoBossRaidPacket packet = Serializer.Deserialize(new ReadOnlyMemory(payload)); @@ -1127,32 +1164,6 @@ public class GameServer : ServerBase // API로 접속 체크 List userNames = new List(); foreach (int memberId in party.PartyMemberIds) - { - userNames.Add(channel.GetPlayer(memberId).Nickname); - } - - BossRaidResult? result = await RestApi.Instance.BossRaidAccesssAsync(userNames, 1); - - // 입장 실패 - if (result == null || result.BossId <= 0) - { - SendTo(peer, - PacketSerializer.Serialize((ushort)PacketCode.INTO_BOSS_RAID, - new IntoBossRaidPacket { RaidId = -1, IsSuccess = false })); - - Log.Debug("[GameServer] INTO_BOSS_RAID HashKey={Key} PartyId={PartyId} AssignedRaidMapId={RaidId} Failed", hashKey, - party.PartyId, -1); - return; - } - - // 레이드 맵 할당 (미사용 맵 탐색 → 없으면 동적 생성) - int assignedRaidMapId = channel.GetOrCreateAvailableRaidMap(); - - // 진행중 맵으로 등록 - channel.AddInstanceMap(assignedRaidMapId); - - // 파티원 전체 레이드 맵으로 이동 + 각자에게 알림 - foreach (int memberId in party.PartyMemberIds) { Player? memberPlayer = channel.GetPlayer(memberId); if (memberPlayer == null) @@ -1160,53 +1171,103 @@ public class GameServer : ServerBase continue; } - // 이전 맵 캐싱 (레이드 종료 후 복귀용) - memberPlayer.PreviousMapId = memberPlayer.CurrentMapId; - - int oldMapId = memberPlayer.CurrentMapId; - channel.ChangeMap(memberId, memberPlayer, assignedRaidMapId); - - if (!sessions.TryGetValue(memberId, out NetPeer? memberPeer)) - { - continue; - } - - PlayerInfo memberInfo = ToPlayerInfo(memberPlayer); - - // 기존 맵 유저들에게 퇴장 알림 - ChangeMapPacket exitNotify = new() { MapId = oldMapId, IsAdd = false, Player = memberInfo }; - BroadcastToMap(channelId, oldMapId, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, exitNotify)); - - // 새 맵 유저들에게 입장 알림 (본인 제외) - ChangeMapPacket enterNotify = new() { MapId = assignedRaidMapId, IsAdd = true, Player = memberInfo }; - BroadcastToMap(channelId, assignedRaidMapId, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, enterNotify), - memberPeer); - - // 본인에게 새 맵 플레이어 목록 전달 - ChangeMapPacket response = new() { MapId = assignedRaidMapId }; - AMap? raidMap = channel.GetMap(assignedRaidMapId); - if (raidMap != null) - { - foreach ((int uid, Player p) in raidMap.GetUsers()) - { - if (uid != memberId) - { - response.Players.Add(ToPlayerInfo(p)); - } - } - } - - SendTo(memberPeer, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, response)); - - // 모두에게 레이드로 이동 (할당된 실제 레이드 맵 ID 전달) - SendTo(peer, - PacketSerializer.Serialize((ushort)PacketCode.INTO_BOSS_RAID, - new IntoBossRaidPacket - { RaidId = assignedRaidMapId, IsSuccess = true, Session = result.SessionName, Token = result.Tokens })); + userNames.Add(memberPlayer.Nickname); } - Log.Debug("[GameServer] INTO_BOSS_RAID HashKey={Key} PartyId={PartyId} AssignedRaidMapId={RaidId}", hashKey, party.PartyId, - assignedRaidMapId); + BossRaidResult? result = await RestApi.Instance.BossRaidAccessAsync(userNames, packet.RaidId); + + // await 이후 — 공유 자원 접근 보호 + lock (sessionLock) + { + // 입장 실패 + if (result == null || result.BossId <= 0) + { + SendTo(peer, + PacketSerializer.Serialize((ushort)PacketCode.INTO_BOSS_RAID, + new IntoBossRaidPacket { RaidId = -1, IsSuccess = false })); + + Log.Debug("[GameServer] INTO_BOSS_RAID HashKey={Key} PartyId={PartyId} AssignedRaidMapId={RaidId} Failed", hashKey, + party.PartyId, -1); + return; + } + + // await 이후 상태 재검증 + channelId = cm.HasUser(hashKey); + if (channelId < 0) + { + return; + } + + channel = cm.GetChannel(channelId); + party = channel.GetPartyManager().GetPartyByPlayer(hashKey); + if (party == null) + { + return; + } + + // 레이드 맵 할당 (미사용 맵 탐색 → 없으면 동적 생성) + int assignedRaidMapId = channel.GetOrCreateAvailableRaidMap(); + + // 진행중 맵으로 등록 + channel.AddInstanceMap(assignedRaidMapId); + + // 파티원 전체 레이드 맵으로 이동 + 각자에게 알림 + foreach (int memberId in party.PartyMemberIds) + { + Player? memberPlayer = channel.GetPlayer(memberId); + if (memberPlayer == null) + { + continue; + } + + // 이전 맵 캐싱 (레이드 종료 후 복귀용) + memberPlayer.PreviousMapId = memberPlayer.CurrentMapId; + + int oldMapId = memberPlayer.CurrentMapId; + channel.ChangeMap(memberId, memberPlayer, assignedRaidMapId); + + if (!sessions.TryGetValue(memberId, out NetPeer? memberPeer)) + { + continue; + } + + PlayerInfo memberInfo = ToPlayerInfo(memberPlayer); + + // 기존 맵 유저들에게 퇴장 알림 + ChangeMapPacket exitNotify = new() { MapId = oldMapId, IsAdd = false, Player = memberInfo }; + BroadcastToMap(channelId, oldMapId, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, exitNotify)); + + // 새 맵 유저들에게 입장 알림 (본인 제외) + ChangeMapPacket enterNotify = new() { MapId = assignedRaidMapId, IsAdd = true, Player = memberInfo }; + BroadcastToMap(channelId, assignedRaidMapId, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, enterNotify), + memberPeer); + + // 본인에게 새 맵 플레이어 목록 전달 + ChangeMapPacket response = new() { MapId = assignedRaidMapId }; + AMap? raidMap = channel.GetMap(assignedRaidMapId); + if (raidMap != null) + { + foreach ((int uid, Player p) in raidMap.GetUsers()) + { + if (uid != memberId) + { + response.Players.Add(ToPlayerInfo(p)); + } + } + } + + SendTo(memberPeer, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, response)); + + // 각 파티원에게 레이드 입장 결과 전달 (Session, Token 포함) + SendTo(memberPeer, + PacketSerializer.Serialize((ushort)PacketCode.INTO_BOSS_RAID, + new IntoBossRaidPacket + { RaidId = assignedRaidMapId, IsSuccess = true, Session = result.SessionName, Token = result.Tokens != null && result.Tokens.TryGetValue(memberPlayer.Nickname, out string? memberToken) ? memberToken : null })); + } + + Log.Debug("[GameServer] INTO_BOSS_RAID HashKey={Key} PartyId={PartyId} AssignedRaidMapId={RaidId}", hashKey, party.PartyId, + assignedRaidMapId); + } } // 채널 퇴장/연결 해제 시 파티 자동 탈퇴 처리 @@ -1222,8 +1283,8 @@ public class GameServer : ServerBase pm.LeaveParty(hashKey, out PartyInfo? remaining); - // 0명 → DELETE, 남은 멤버 있음 → LEAVE - UpdatePartyPacket notify = remaining != null + // 남은 멤버 있음 → LEAVE, 0명(파티 해산됨) → DELETE + UpdatePartyPacket notify = remaining != null && remaining.PartyMemberIds.Count > 0 ? new UpdatePartyPacket { PartyId = partyId.Value, diff --git a/MMOTestServer/MMOserver/Packet/PacketBody.cs b/MMOTestServer/MMOserver/Packet/PacketBody.cs index e2ac3e9..572d160 100644 --- a/MMOTestServer/MMOserver/Packet/PacketBody.cs +++ b/MMOTestServer/MMOserver/Packet/PacketBody.cs @@ -198,7 +198,7 @@ public class LoadGamePacket } [ProtoMember(3)] - public int MaplId + public int MapId { get; set; diff --git a/MMOTestServer/MMOserver/Packet/PacketHeader.cs b/MMOTestServer/MMOserver/Packet/PacketHeader.cs index 44d012e..abb099b 100644 --- a/MMOTestServer/MMOserver/Packet/PacketHeader.cs +++ b/MMOTestServer/MMOserver/Packet/PacketHeader.cs @@ -2,73 +2,73 @@ namespace MMOserver.Packet; public enum PacketCode : ushort { + // 초기 클라이언트 시작시 jwt토큰 받아옴 + ACC_TOKEN = 1, + + // 내 정보 로드 (서버 -> 클라) + LOAD_GAME = 2, + + // 모든 채널 로드 - jwt토큰 검증후 게임에 들어갈지 말지 (내 데이터도 전송) + // (서버 -> 클라) + LOAD_CHANNEL = 3, + + // 나 채널 접속 (클라 -> 서버) + INTO_CHANNEL = 4, + + // 파티 채널 접속 (클라 -> 서버) + INTO_CHANNEL_PARTY = 5, + + // 새로운 유저 채널 접속 (서버 -> 클라) / 유저 채널 나감 (서버 -> 클라) + UPDATE_CHANNEL_USER = 6, + + // 채널 나가기 (클라 -> 서버) + EXIT_CHANNEL = 7, + + // 맵 이동 + CHANGE_MAP = 8, + + // 단체로 맵 이동 + PARTY_CHANGE_MAP = 9, + + // 파티장이 보스 레이드(인스턴스 던전) 입장 신청 (클라 -> 서버) + INTO_BOSS_RAID = 10, + + // 플레이어 위치, 방향 (서버 -> 클라 \ 클라 -> 서버) + TRANSFORM_PLAYER = 11, + + // 플레이어 행동 업데이트 (서버 -> 클라 \ 클라 -> 서버) + ACTION_PLAYER = 12, + + // 플레이어 스테이트 업데이트 (서버 -> 클라 \ 클라 -> 서버) + STATE_PLAYER = 13, + + // NPC 위치, 방향 (서버 -> 클라) + TRANSFORM_NPC = 14, + + // NPC 행동 업데이트 (서버 -> 클라) + ACTION_NPC = 15, + + // NPC 스테이트 업데이트 (서버 -> 클라) + STATE_NPC = 16, + + // 데미지 UI 전달 (서버 -> 클라) + DAMAGE = 17, + + // 파티 생성/삭제, 파티원 추가/제거 (서버 -> 클라) + UPDATE_PARTY = 18, + + // 파티 참가/탈퇴/생성/해산 요청 (클라 -> 서버) + REQUEST_PARTY = 19, + + // 채팅 (클라 -> 서버 & 서버 -> 클라) - GLOBAL / PARTY / WHISPER + CHAT = 20, + // ECHO ECHO = 1000, // DUMMY 클라는 이걸로 jwt토큰 안받음 DUMMY_ACC_TOKEN = 1001, - // 초기 클라이언트 시작시 jwt토큰 받아옴 - ACC_TOKEN = 1, - - // 내 정보 로드 (서버 -> 클라) - LOAD_GAME, - - // 모든 채널 로드 - jwt토큰 검증후 게임에 들어갈지 말지 (내 데이터도 전송) - // (서버 -> 클라) - LOAD_CHANNEL, - - // 나 채널 접속 (클라 -> 서버) - INTO_CHANNEL, - - // 파티 채널 접속 (클라 -> 서버) - INTO_CHANNEL_PARTY, - - // 새로운 유저 채널 접속 (서버 -> 클라) / 유저 채널 나감 (서버 -> 클라) - UPDATE_CHANNEL_USER, - - // 채널 나가기 (클라 -> 서버) - EXIT_CHANNEL, - - // 맵 이동 - CHANGE_MAP, - - // 단체로 맵 이동 - PARTY_CHANGE_MAP, - - // 파티장이 보스 레이드(인스턴스 던전) 입장 신청 (클라 -> 서버) - INTO_BOSS_RAID, - - // 플레이어 위치, 방향 (서버 -> 클라 \ 클라 -> 서버) - TRANSFORM_PLAYER, - - // 플레이어 행동 업데이트 (서버 -> 클라 \ 클라 -> 서버) - ACTION_PLAYER, - - // 플레이어 스테이트 업데이트 (서버 -> 클라 \ 클라 -> 서버) - STATE_PLAYER, - - // NPC 위치, 방향 (서버 -> 클라) - TRANSFORM_NPC, - - // NPC 행동 업데이트 (서버 -> 클라) - ACTION_NPC, - - // NPC 스테이트 업데이트 (서버 -> 클라) - STATE_NPC, - - // 데미지 UI 전달 (서버 -> 클라) - DAMAGE, - - // 파티 생성/삭제, 파티원 추가/제거 (서버 -> 클라) - UPDATE_PARTY, - - // 파티 참가/탈퇴/생성/해산 요청 (클라 -> 서버) - REQUEST_PARTY, - - // 채팅 (클라 -> 서버 & 서버 -> 클라) - GLOBAL / PARTY / WHISPER - CHAT, - // 요청 실패 응답 (서버 -> 클라) ERROR = 9999 } diff --git a/MMOTestServer/ServerLib/Service/ServerBase.cs b/MMOTestServer/ServerLib/Service/ServerBase.cs index 8eecf77..e3a5aaa 100644 --- a/MMOTestServer/ServerLib/Service/ServerBase.cs +++ b/MMOTestServer/ServerLib/Service/ServerBase.cs @@ -42,6 +42,9 @@ public abstract class ServerBase : INetEventListener // 재사용 NetDataWriter (단일 스레드 폴링이므로 안전) private readonly NetDataWriter cachedWriter = new(); + // async 메서드(HandleAuth 등)의 await 이후 공유 자원 접근 보호용 + protected readonly object sessionLock = new(); + // 핑 로그 출력 여부 public bool PingLogRtt { @@ -118,26 +121,29 @@ public abstract class ServerBase : INetEventListener // 클라이언트가 연결 해제됐을 때 (타임아웃, 명시적 끊기 등) public void OnPeerDisconnected(NetPeer peer, DisconnectInfo disconnectInfo) { - pendingPeers.Remove(peer.Id); - - if (peer.Tag is Session session) + lock (sessionLock) { - // 현재 인증된 피어가 이 peer일 때만 세션 제거 - // (재연결로 이미 교체된 경우엔 건드리지 않음) - if (sessions.TryGetValue(session.HashKey, out NetPeer? current) && current.Id == peer.Id) + pendingPeers.Remove(peer.Id); + + if (peer.Tag is Session session) { - // 더미 클라 아니면 token관리 - if (!string.IsNullOrEmpty(session.Token)) + // 현재 인증된 피어가 이 peer일 때만 세션 제거 + // (재연결로 이미 교체된 경우엔 건드리지 않음) + if (sessions.TryGetValue(session.HashKey, out NetPeer? current) && current.Id == peer.Id) { - tokenHash.Remove(session.Token); + // 더미 클라 아니면 token관리 + if (!string.IsNullOrEmpty(session.Token)) + { + tokenHash.Remove(session.Token); + } + + sessions.Remove(session.HashKey); + Log.Information("[Server] 세션 해제 HashKey={Key} Reason={Reason}", session.HashKey, disconnectInfo.Reason); + OnSessionDisconnected(peer, session.HashKey, disconnectInfo); } - sessions.Remove(session.HashKey); - Log.Information("[Server] 세션 해제 HashKey={Key} Reason={Reason}", session.HashKey, disconnectInfo.Reason); - OnSessionDisconnected(peer, session.HashKey, disconnectInfo); + peer.Tag = null; } - - peer.Tag = null; } } @@ -167,7 +173,11 @@ public abstract class ServerBase : INetEventListener // Auth 패킷은 베이스에서 처리 (raw 8-byte long, protobuf 불필요) if (type == (ushort)PacketType.ACC_TOKEN) { - HandleAuth(peer, payload); + _ = HandleAuth(peer, payload).ContinueWith(t => + { + if (t.IsFaulted) + Log.Error(t.Exception, "[Server] HandleAuth 예외 PeerId={Id}", peer.Id); + }, TaskContinuationOptions.OnlyOnFaulted); return; } else if (type == (ushort)PacketType.DUMMY_ACC_TOKEN) @@ -240,7 +250,7 @@ public abstract class ServerBase : INetEventListener // ─── Auth 처리 ──────────────────────────────────────────────── - protected abstract void HandleAuth(NetPeer peer, byte[] payload); + protected abstract Task HandleAuth(NetPeer peer, byte[] payload); // ─── 전송 헬퍼 ───────────────────────────────────────────────────────