BnaireGameServer 서버 구조 & 동작 가이드

<Import Project="..\..\..\BnaireProtocol\Protocol\BnaireGameProtocol\BnaireGameProtocol.projitems" Label="Shared" />
<Import Project="..\..\..\BnaireProtocol\Protocol\BnaireProtocol\BnaireProtocol.projitems" Label="Shared" />
<Import Project="..\..\BnaireG\BnaireG.projitems" Label="Shared" />
<Import Project="..\..\BnaireCommon\BnaireCommon.projitems" Label="Shared" />

// 1) 로깅/설정
NLogEx.SetConfiguration("NLog.config", 5);
GameConfig.Load("GameIndividual.config");

// 2) AWS Secrets → DB 커넥션 문자열 부트스트랩
var key = AccessKey.Load(Const.AwsAccessKey, Const.AwsEncryptionKey);
await SecretsManager.InitializeAsync(key);
TblConnectionString.Initialize(SecretsManager.Get("CommonDB"));

// 3) 캐시/설정 새로고침, 분석로그 초기화
await RefreshManager.InitializeAsync();
Log.Initialize(CfgServer.Shared.SnowflakeLogDatabase, CfgServer.Shared.SnowflakeLogger, CfgServer.Shared.ServerMode);

// 4) 스케줄러 · 외부연동 초기화 (Quartz, Apple, Facebook, StoreKit ...)
await CreateScheduleJob(); OnTimeJobScheduler.Instance.Start();
await AppleId.InitializeAsync(); await FacebookManager.InitializeAsync();

// 5) 서비스 레지스트리 구축 (리플렉션) — 6장 참조
BnaireGameServer.Service.Initialize();

// 6) Redis 헬스체크 후 웹서버 기동
Redis.Ping(false); Redis.Ping(true);
RunWebServer(args, cts);

app.MapPost("/Gate",    async (context) => { await Gate.InvokeAsync(context); });    // 게임 통신 (유일한 실서비스)
app.MapGet ("/Monitor", async (context) => { await Monitor.InvokeAsync(context); }); // 관리자용 부하 대시보드
// 그 외: /Refresh, /AgeCheck, /AppStoreNotification, /Kick-Bnaire, /ServerTime ... (운영/연동 훅)
app.Run(CfgHaeginGameServer.Shared.ServerUrl);

var span = memory.Span;
encrypted = span[0];                          // 암호화 모드: 0, 1, 2
hash      = BitConverter.ToUInt32(span.Slice(1)); // 세션 해시 (bytes 1~4)

var key = CfgHaeginGameServer.Shared.Key;
if (encrypted == 2) {                          // 정적키 XOR 세션해시
    xxtea = new XXTea(new[]{ hash^key[0], hash^key[1], hash^key[2], hash^key[3] });
    req = DecryptAndDeserialize(xxtea, span.Slice(5), out step);
} else if (encrypted == 1) {                   // 정적키
    xxtea = new XXTea(new[]{ key[0], key[1], key[2], key[3] });
    req = DecryptAndDeserialize(xxtea, span.Slice(5), out step);
} else if (encrypted == 0) {                   // 평문
    req = MessagePackSerializer.Deserialize<ProtocolReq>(memory.Slice(5));
}

[MessagePackObject]
public class ProtocolReq
{
    [Key(0)] public long     Suid;      // 유저 식별자
    [Key(1)] public long     Ticks;     // 요청 고유값 = 멱등성 키 (MakeUniqueTicks)
    [Key(2)] public byte     Retry;
    [Key(3)] public Protocol Protocol;  // 실제 페이로드 (다형성)
}

[MessagePackObject]
[Union(1,   typeof(MaintenanceCheckReq))]
[Union(102, typeof(AuthReq))]
[Union(201, typeof(AliveReq))]
// ... 약 250개, Union 태그 = ProtocolId 값
public abstract class Protocol
{
    [IgnoreMember] public virtual byte Encrypted { get; set; } // 요구 최소 암호화 레벨(직렬화 안 됨)
    [Key(0)]       public ProtocolId ProtocolId { get; set; }
}

MessagePackSerializer.Serialize(ms, response);
ReadOnlyMemory<byte> bytes = ms.ToArray();
if (shouldCompress) bytes = CompressZstd(response.ProtocolId, bytes); // ① 압축
if (xxtea == null) { encrypted = bytes; return null; }
memoryOwner = xxtea.EncryptUsingMemoryPool(bytes.Span, out encrypted);  // ② 암호화

public interface IService
{
    ProtocolId ProtocolId { get; }
    bool IsSuidNeeded { get; }        // 인증된 유저 로드 필요?
    bool IsHashCheckNeeded { get; }   // 세션 해시 검증 필요?
    Task<ProtocolRes> ProcessAsync(HttpContext context, TblUser user, Protocol request);
}

private static Dictionary<ProtocolId, IService> dicHandler = new();

// Initialize(): 엔트리 어셈블리의 모든 타입 스캔
if (t.GetInterfaces().Contains(typeof(IService)) == false) continue;
if (typeInfo.GetCustomAttribute<ProtocolHandlerAttribute>() != null) {
    var instance = (IService)Activator.CreateInstance(t);
    dicHandler.Add(instance.ProtocolId, instance);   // 싱글톤 등록
}

// ProcessAsync(): 라우팅
if (dicHandler.TryGetValue(req.ProtocolId, out var handler) == false)
    throw new HaeginException(Result.UnknownProtocol, "Unknown Protocol : {0}", req.ProtocolId);

[ProtocolHandler]
public class ServiceAlive : IService
{
    public ProtocolId ProtocolId => ProtocolId.Alive;
    public bool IsSuidNeeded => true;
    public bool IsHashCheckNeeded => true;

    public async Task<ProtocolRes> ProcessAsync(HttpContext context, TblUser user, Protocol request)
    {
        var req = (AliveReq)request;   // Protocol 베이스에서 다운캐스트
        var res = new AliveRes();
        // ... 로직 ...
        return res;
    }
}

public async Task<ProtocolRes> ProcessAsync(HttpContext ctx, TblUser user, Protocol request)
{
    var res = new RefreshEventRes();
    // 여러 매니저의 정적 메서드를 병렬 호출 → 응답 조립
    res.Events        = EventManager.GetListActiveEvents();
    res.Currency      = await GameManager.GetUserCurrency(user);
    res.CardInventory = await CardManager.GetUserCardInventory(user, ...);
    res.ShopList      = await ShopManager.GetShopList(user, ...);
    return res;
}

public static string ToString(AccountType type, string id, string name, string password)
{
    id = Account.ToDecryptedId(id);
    var accountPass = $"{(int)type}#'%:{id}#'%:{name}#'%:{password}";
    var xxtea = new XXTea(CfgServer.Shared.AccountPassEncKey);
    return xxtea.EncryptString(accountPass);   // 클라에 주는 불투명 문자열
}

if (string.IsNullOrEmpty(authResult.AccountId))    // AccountPassToCreate 인 경우
{
    log.Debug($"=== Auth : Guest 신규 유저 생성");
    userAccount = await UserManager.CreateUserAccountAsync(
        req.Duid, req.Adid, req.Telecom, req.Market, req.Os, country, req.Language, currency, accountName: req.Nickname);
}

if (handler.IsSuidNeeded) {
    user = await TblUser.GetAsync(suid, ...);      // Redis 우선 → MySQL 폴백
    if (user == null)
        throw new HaeginException(Result.UserNotExist, ...);
    if (hash != user.Hash && handler.IsHashCheckNeeded)   // 세션 검증
        throw new HaeginException(Result.AuthenticationExpired, ...);
}
return await handler.ProcessAsync(context, user, req);

public static DbClient GetDbClient(string name) {
    if (dicClient.TryGetValue(name, out var dbClient) == false) {
        var connectionStrings = Find(name);        // tblConnectionString에서 로드
        dbClient = new MySqlClient(connectionStrings); // [0]=master, 나머지=slave
        dicClient.TryAdd(name, dbClient);
    }
    return dbClient;
}

public static DbConnection CreateConnection(TblUser user, bool isMaster) {
    var dbClient = TblConnectionString.GetDbClient($"Game{user.GameServerId}");
    return dbClient.CreateConnection(isMaster);   // isMaster=쓰기, false=읽기(slave)
}

static Redis() {
    connAuth     = ConnectionMultiplexer.Connect(CfgServer.Shared.RedisAuth);     // 유저/메시지/랭킹/이벤트
    connResponse = ConnectionMultiplexer.Connect(CfgServer.Shared.RedisResponse); // 멱등성 응답 캐시
    connMisc     = ConnectionMultiplexer.Connect(CfgServer.Shared.RedisMisc);     // 범용 KV + 분산 락
}

var data = await LoadResponseDataAsync(req);   // Redis.GetResponseAsync(Suid, Ticks)
if (data == null) {
    // 최초 요청: 서비스 실행 → SendResponseAsync가 응답을 캐시에 저장
} else {
    // 재요청: 캐시된 응답 그대로 반환, 서비스 실행 안 함
    StressMonitor.UpdateRetry(...);
}

// 같은 카드 환불 메시지를 한 번만 처리하도록 잠금
var ok = await db.StringSetAsync($"CARD:{messageSeq}", "locked",
                                 TimeSpan.FromMinutes(10), When.NotExists);
return ok;   // true = 내가 락 획득(처리 진행), false = 이미 처리 중/처리됨(건너뜀)

var isInserted = await CommonDB.InsertProductPurchaseAsync(
    user.SuidValue, gcp.OrderId, priceId, productId, ...);
if (isInserted) {
    // 최초 주문 → 보상 지급 (ShopManager.ProcessProductReward)
} else {
    gcp.ConsumptionState = ConsumptionState.Duplicated;  // 중복 → 지급 안 함
}

var response = new ErrorRes();
if (ex is HaeginException hex) {
    response.Result = hex.Result;             // 비즈니스 에러 → 그대로 전달
} else {
    log.Error(ex);
    switch (step) {                          // 인프라 에러 → 단계로 코드 결정
        case Step.None:      response.Result = Result.ProtocolFormatError; break;
        case Step.HeadRead:  response.Result = Result.DecryptionFailed;    break;
        case Step.Decrypted: response.Result = Result.DeserializationFailed; break;
        default:            response.Result = Result.UnknownError;        break;
    }
}

// 기동 시 1회 초기화 (Program.cs)
Log.Initialize(CfgServer.Shared.SnowflakeLogDatabase,
               CfgServer.Shared.SnowflakeLogger, CfgServer.Shared.ServerMode);

// 어디서든 fire-and-forget 로 이벤트 기록
_ = new LogDiceRoll { Suid = user.SuidValue, DiceNumber = n }.InsertAsync();

./deploy.sh bnaireS        # 스테이징
./deploy.sh bnaire-game-1  # 프로덕션 (AWS)