fix : 서버 버그 수정 작업 머지

Merge branch 'fix/mmo-server-logic-bugs' of https://git.tolelom.xyz/A301/a301_mmo_game_server

# Conflicts:
#	MMOTestServer/MMOserver/Game/GameServer.cs

MMOTestServer/MMOserver/Api/RestApi.cs

@@ -35,7 +35,7 @@ public class RestApi : Singleton<RestApi>
                 if (response.StatusCode == HttpStatusCode.Unauthorized)
                 {
                     Log.Warning("[RestApi] 토큰 인증 실패 (401)");
-                    return "";
+                    return null;
                 }
 
                 response.EnsureSuccessStatusCode();
@@ -56,7 +56,7 @@ public class RestApi : Singleton<RestApi>
             }
         }
 
-        return "";
+        return null;
     }
 
     // 플레이어 프로필 조회 - 성공 시 PlayerProfileResponse 반환
@@ -133,7 +133,7 @@ public class RestApi : Singleton<RestApi>
 
     // 레이드 채널 접속 여부 체크
     // 성공 시 BossRaidResult 반환, 실패/거절 시 null 반환
-    public async Task<BossRaidResult?> BossRaidAccesssAsync(List<string> userNames, int bossId)
+    public async Task<BossRaidResult?> BossRaidAccessAsync(List<string> userNames, int bossId)
     {
         string url = AppConfig.RestApi.BaseUrl + AppConfig.RestApi.BossRaidAccess;
 
@@ -150,10 +150,12 @@ public class RestApi : Singleton<RestApi>
                     return null;
                 }
 
-                // 400: 입장 조건 미충족 (레벨 부족, 이미 진행중 등)
+                // 400: 입장 조건 미충족 / 409: 이미 레이드 중 등
-                if (response.StatusCode == HttpStatusCode.BadRequest)
+                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;
                 }
 

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 갱신)

MMOTestServer/MMOserver/Game/GameServer.cs

@@ -18,6 +18,9 @@ public class GameServer : ServerBase
     private readonly Dictionary<ushort, Action<NetPeer, int, byte[]>> packetHandlers;
     private readonly UuidGenerator userUuidGenerator;
 
+    // 동일 토큰 동시 인증 방지
+    private readonly HashSet<string> authenticatingTokens = new();
+
     public GameServer(int port, string connectionString) : base(port, connectionString)
     {
         packetHandlers = new Dictionary<ushort, Action<NetPeer, int, byte[]>>
@@ -99,54 +102,80 @@ 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<AccTokenPacket>(new ReadOnlyMemory<byte>(payload));
         string token = accTokenPacket.Token;
-        string? verifiedUsername = null;
+
-        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 전환 등 재연결: 이전 피어 교체 (토큰 재검증 불필요)
+            string? username = "";
-            existing.Tag = null;
+            int hashKey;
-            sessions.Remove(hashKey);
+            bool isReconnect;
-            Log.Information("[Server] 재연결 HashKey={Key} Old={Old} New={New}", hashKey, existing.Id, peer.Id);
+
-            existing.Disconnect();
+            lock (sessionLock)
-        }
-        else
-        {
-            // 신규 연결: 웹서버에 JWT 검증 요청
-            string? username = await RestApi.Instance.VerifyTokenAsync(token);
-            if (username == null || username.Trim().Length <= 0)
             {
-                Log.Warning("[Server] 토큰 검증 실패 - 연결 거부 PeerId={Id}", peer.Id);
+                isReconnect = tokenHash.TryGetValue(token, out hashKey) && hashKey > 1000;
-                userUuidGenerator.Release(hashKey);
+                if (!isReconnect)
-                peer.Disconnect();
+                {
-                return;
+                    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();
+                }
             }
 
-            Log.Information("[Server] 토큰 검증 성공 Username={Username} PeerId={Id}", username, peer.Id);
+            if (!isReconnect)
-            verifiedUsername = username;
+            {
-        }
+                // 신규 연결: 웹서버에 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);
+                Log.Information("[Server] 토큰 검증 성공 Username={Username} PeerId={Id}", username, peer.Id);
-        ((Session)peer.Tag).Token = token;
+            }
-        if (verifiedUsername != null)
+
+            // await 이후 — 공유 자원 접근 보호
+            lock (sessionLock)
+            {
+                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 = verifiedUsername;
+            authenticatingTokens.Remove(token);
-            ((Session)peer.Tag).UserName = verifiedUsername;
         }
-        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)
@@ -336,7 +365,7 @@ public class GameServer : ServerBase
         {
             IsAccepted = true,
             Player = ToPlayerInfo(player),
-            MaplId = channelId
+            MapId = player.CurrentMapId
         };
 
         byte[] data = PacketSerializer.Serialize((ushort)PacketCode.LOAD_GAME, packet);
@@ -428,10 +457,10 @@ public class GameServer : ServerBase
 
         // 이전에 다른 채널에 있었는지 체크
         int preChannelId = cm.HasUser(hashKey);
+        Player? prevPlayer = preChannelId >= 0 ? cm.GetChannel(preChannelId).GetPlayer(hashKey) : null;
         if (preChannelId >= 0)
         {
-            // 제거 전에 채널/플레이어 정보 저장 (브로드캐스트에 필요)
+            Player? player = prevPlayer;
-            Player? player = cm.GetChannel(preChannelId).GetPlayer(hashKey);
 
             // 파티 자동 탈퇴
             HandlePartyLeaveOnExit(preChannelId, hashKey);
@@ -453,6 +482,14 @@ 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 && prevPlayer != null)
+            {
+                cm.AddUser(preChannelId, hashKey, prevPlayer, 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);
@@ -464,7 +501,7 @@ public class GameServer : ServerBase
         {
             HashKey = hashKey,
             PlayerId = hashKey,
-            Nickname = ((Session)peer.Tag).UserName
+            Nickname = ((Session)peer.Tag).Username ?? ""
         };
 
         Session? session = peer.Tag as Session;
@@ -548,12 +585,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 (preParty == null)
-        if (preChannelId < 0 || preParty == null)
         {
             Log.Warning("[GameServer] INTO_CHANNEL_PARTY 해당 파티 없음");
             return;
@@ -574,12 +618,15 @@ public class GameServer : ServerBase
             return;
         }
 
-        // 기존 채널에서 제거 + 기존 채널 유저들에게 나감 알림
+        // 기존 채널에서 제거 전에 플레이어 정보 보존
+        Dictionary<int, Player> 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),
@@ -615,12 +662,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);
 
@@ -1012,7 +1060,7 @@ public class GameServer : ServerBase
         }
 
         SendTo(peer, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, response));
-        Log.Debug("[GameServer] CHANGE_MAP HashKey={Key} OldMap={OldMapId} NewMap={MapId}", hashKey, oldMapId, newMapId);
+        Log.Debug("[GameServer] CHANGE_MAP HashKey={Key} OldMap={OldMapId} NewMap={MapId}", hashKey, oldMapId, packet.MapId);
     }
 
     private void OnPartyChangeMap(NetPeer peer, int hashKey, byte[] payload)
@@ -1092,7 +1140,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<IntoBossRaidPacket>(new ReadOnlyMemory<byte>(payload));
 
@@ -1135,85 +1192,105 @@ public class GameServer : ServerBase
             }
         }
 
-        BossRaidResult? result = await RestApi.Instance.BossRaidAccesssAsync(userNames, 1);
+        BossRaidResult? result = await RestApi.Instance.BossRaidAccessAsync(userNames, packet.RaidId);
 
-        // 입장 실패
+        // await 이후 — 공유 자원 접근 보호
-        if (result == null || result.BossId <= 0)
+        lock (sessionLock)
         {
-            SendTo(peer,
+            // 입장 실패
-                PacketSerializer.Serialize((ushort)PacketCode.INTO_BOSS_RAID,
+            if (result == null || result.BossId <= 0)
-                    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)
             {
-                continue;
+                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 이후 상태 재검증
-            memberPlayer.PreviousMapId = memberPlayer.CurrentMapId;
+            channelId = cm.HasUser(hashKey);
-
+            if (channelId < 0)
-            int oldMapId = memberPlayer.CurrentMapId;
-            channel.ChangeMap(memberId, memberPlayer, assignedRaidMapId);
-
-            if (!sessions.TryGetValue(memberId, out NetPeer? memberPeer))
             {
-                continue;
+                return;
             }
 
-            PlayerInfo memberInfo = ToPlayerInfo(memberPlayer);
+            channel = cm.GetChannel(channelId);
-
+            party = channel.GetPartyManager().GetPartyByPlayer(hashKey);
-            // 기존 맵 유저들에게 퇴장 알림
+            if (party == null)
-            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())
+                return;
+            }
+
+            // 레이드 맵 할당 (미사용 맵 탐색 → 없으면 동적 생성)
+            int assignedRaidMapId = channel.GetOrCreateAvailableRaidMap();
+
+            // 진행중 맵으로 등록
+            channel.AddInstanceMap(assignedRaidMapId);
+
+            // 파티원 전체 레이드 맵으로 이동 + 각자에게 알림
+            foreach (int memberId in party.PartyMemberIds)
+            {
+                Player? memberPlayer = channel.GetPlayer(memberId);
+                if (memberPlayer == null)
                 {
-                    if (uid != memberId)
+                    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())
                     {
-                        response.Players.Add(ToPlayerInfo(p));
+                        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
+                                : ""
+                        }));
             }
 
-            SendTo(memberPeer, PacketSerializer.Serialize((ushort)PacketCode.CHANGE_MAP, response));
+            Log.Debug("[GameServer] INTO_BOSS_RAID HashKey={Key} PartyId={PartyId} AssignedRaidMapId={RaidId}", hashKey, party.PartyId,
-
+                assignedRaidMapId);
-            // 각 멤버에게 개별 토큰과 함께 레이드 이동 알림
-            string? memberToken = null;
-            result.Tokens?.TryGetValue(memberPlayer.Nickname, out memberToken);
-
-            SendTo(memberPeer,
-                PacketSerializer.Serialize((ushort)PacketCode.INTO_BOSS_RAID,
-                    new IntoBossRaidPacket
-                        { RaidId = assignedRaidMapId, IsSuccess = true, Session = result.SessionName, Token = memberToken }));
         }
-
-        Log.Debug("[GameServer] INTO_BOSS_RAID HashKey={Key} PartyId={PartyId} AssignedRaidMapId={RaidId}", hashKey, party.PartyId,
-            assignedRaidMapId);
     }
 
     // 채널 퇴장/연결 해제 시 파티 자동 탈퇴 처리
@@ -1229,8 +1306,8 @@ public class GameServer : ServerBase
 
         pm.LeaveParty(hashKey, out PartyInfo? remaining);
 
-        // 0명 → DELETE, 남은 멤버 있음 → LEAVE
+        // 남은 멤버 있음 → LEAVE, 0명(파티 해산됨) → DELETE
-        UpdatePartyPacket notify = remaining != null
+        UpdatePartyPacket notify = remaining != null && remaining.PartyMemberIds.Count > 0
             ? new UpdatePartyPacket
             {
                 PartyId = partyId.Value,

MMOTestServer/MMOserver/Game/Party/PartyManager.cs

@@ -28,6 +28,12 @@ public class PartyManager
             memeberIds = new List<int>();
         }
 
+        // 리더 중복 방지: 기존 멤버 목록에 리더가 없을 때만 추가
+        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;
     }

MMOTestServer/MMOserver/Packet/PacketBody.cs

@@ -198,7 +198,7 @@ public class LoadGamePacket
     }
 
     [ProtoMember(3)]
-    public int MaplId
+    public int MapId
     {
         get;
         set;

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
 }

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);
+        lock (sessionLock)
-
-        if (peer.Tag is Session session)
         {
-            // 현재 인증된 피어가 이 peer일 때만 세션 제거
+            pendingPeers.Remove(peer.Id);
-            // (재연결로 이미 교체된 경우엔 건드리지 않음)
+
-            if (sessions.TryGetValue(session.HashKey, out NetPeer? current) && current.Id == peer.Id)
+            if (peer.Tag is Session session)
             {
-                // 더미 클라 아니면 token관리
+                // 현재 인증된 피어가 이 peer일 때만 세션 제거
-                if (!string.IsNullOrEmpty(session.Token))
+                // (재연결로 이미 교체된 경우엔 건드리지 않음)
+                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);
+                peer.Tag = null;
-                Log.Information("[Server] 세션 해제 HashKey={Key} Reason={Reason}", session.HashKey, disconnectInfo.Reason);
-                OnSessionDisconnected(peer, session.HashKey, disconnectInfo);
             }
-
-            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);
 
     // ─── 전송 헬퍼 ───────────────────────────────────────────────────────
 

MMOTestServer/ServerLib/Service/Session.cs

@@ -22,12 +22,6 @@ public class Session
         init;
     }
 
-    public string UserName
-    {
-        get;
-        set;
-    }
-
     public NetPeer Peer
     {
         get;