Amazon GameLift 高阶使用技巧（四）- Photon Fusion 与 GameLift Servers 集成指南

private FusionAppSettings BuildCustomAppSetting(string region, string customAppID = null, string appVersion = "2.0.0")
{
    var appSettings = PhotonAppSettings.Global.AppSettings.GetCopy(); ;
    
    appSettings.UseNameServer = true;
    appSettings.AppVersion = appVersion;
    
    if (string.IsNullOrEmpty(customAppID) == false)
    {
        appSettings.AppIdFusion = customAppID;
    }
    
    if (string.IsNullOrEmpty(region) == false)
    {
        appSettings.FixedRegion = region.ToLower();
    }
    
    // If the Region is set to China (CN),
    // the Name Server will be automatically changed to the right one
    // appSettings.Server = "ns.photonengine.cn";
    return appSettings;
}

//Server parameters are required for an Amazon GameLift Servers Anywhere fleet.
    //They are not required for an Amazon GameLift Servers managed EC2 fleet.
    ServerParameters serverParameters = new ServerParameters(
        webSocketUrl,
        processId,
        hostId,
        fleetId,
        authToken);
    //InitSDK establishes a local connection with an Amazon GameLift Servers agent 
    //to enable further communication.
    initSDKOutcome = GameLiftServerAPI.InitSDK(serverParameters);

initSDKOutcome = GameLiftServerAPI.InitSDK();

private void StartFusion(GameSession gameSession)
  {
    Debug.Log(Thread.CurrentThread.ManagedThreadId == 1);
    Debug.Log(SynchronizationContext.Current != null);

    var gameSessionName = $"TestGameRoom{UnityEngine.Random.Range(0, 10000)}";
    var connState = new ConnectionState();
    connState.gamesession = gameSession;
    connState.sessionName = gameSessionName;

    if (_isDedicatedServer)
    {
      Debug.Log($"gameSessionName: {gameSessionName} SERVER");
      _photonManager.StartGame(GameMode.Server, connState);
    }
    else if (_isDedicatedHost)
    {
      Debug.Log($"gameSessionName: {gameSessionName} HOST");
      _photonManager.StartGame(GameMode.Host, connState);
    }
    else
    {
      Debug.Log($"gameSessionName: {gameSessionName} CLIENT");
    }
  }

//Implement OnStartGameSession callback
  private void OnStartGameSession(GameSession gameSession)
  {
    //Amazon GameLift Servers sends a game session activation request to the game server 
    //with game session object containing game properties and other settings.
    //Here is where a game server takes action based on the game session object.
    //When the game server is ready to receive incoming player connections, 
    //it invokes the server SDK call ActivateGameSession().

    var outcome = GameLiftServerAPI.ActivateGameSession();
    if (!outcome.Success)
    {
      Debug.LogError($"OnStartGameSession Failed: {outcome.Error.ErrorMessage}");
    }
    else
    {
      Debug.Log($"OnStartGameSession Success");
      _unityContext.Post(state => {
        StartFusion(state as GameSession);
      }, gameSession);
    }
  }

public async void StartGame(GameMode mode, ConnectionState state)
  {
    Debug.Log($"GameMode: {mode}");

    try
    {

      GameSession gamesession = state.gamesession;
      string SessionName = state.sessionName;
      string gameAddress = state.gameAddress;
      ushort gameport = state.gamePort;
      
      // other logic
      var appSettings = BuildCustomAppSetting("<photon-region-code>", "<photon-custom-appid>");

      StartGameResult result;
      if (mode == GameMode.Client)
      {
        // CLIENT: Start or join (depends on gamemode) a session with a specific name
        // CLIENT LOGIC
      }
      else
      {
        // SERVER: get game session info
        if (gamesession != null)
        {
          gameAddress = gamesession.IpAddress;
          gameport = (ushort)gamesession.Port;
          var maxPlayers = gamesession.MaximumPlayerSessionCount;
          var gameProperties = gamesession.GameProperties;
          gameProperties.TryGetValue("SessionName", out SessionName);
          Debug.Log($"maxPlayers: {maxPlayers}");
        }
        Debug.Log($"STATE: SessionName: {SessionName}, gameAddress: {gameAddress}, gameport: {gameport}");
        // Start or join (depends on gamemode) a session with a specific name
        result = await _runner.StartGame(new StartGameArgs()
        {
          GameMode = mode,
          SessionName = SessionName,
          Scene = scene,
          EnableClientSessionCreation = false,
          SceneManager = gameObject.AddComponent<NetworkSceneManagerDefault>(),
          Address = NetAddress.CreateFromIpPort("0.0.0.0", gameport),
          CustomPublicAddress = NetAddress.CreateFromIpPort(gameAddress, gameport),
          CustomPhotonAppSettings = appSettings,
          MatchmakingMode = MatchmakingMode.FillRoom
        });
      }

      // other logic

    }
    catch (Exception ex)
    {
      Debug.Log(ex);
    }
  }

async void CreatePlayerSession(ConnectionState connState)
  {
    try
    {
      var client = new AmazonSecurityTokenServiceClient(awsRegion);
      var request = new AssumeRoleRequest
      {
        RoleArn = "<GameLift-Assumed-Role>",
        RoleSessionName = System.Guid.NewGuid().ToString()
      };
      var response = await client.AssumeRoleAsync(request);
      var gameLiftClient = new AmazonGameLiftClient(response.Credentials, awsRegion);

      var createPlayerSessionRequest = new CreatePlayerSessionRequest
      {
        GameSessionId = connState.gameSessionId,
        PlayerId = connState.playerSessionId
      };
      var result = await gameLiftClient.CreatePlayerSessionAsync(createPlayerSessionRequest);
      if (result.HttpStatusCode == System.Net.HttpStatusCode.OK)
      {
        Debug.Log("Player session created successfully!");
        if (result.PlayerSession != null)
        {
          connState.playerSessionId = result.PlayerSession.PlayerSessionId;
          _photonManager.StartGame(GameMode.Client, connState);
        }
        else
        {
          throw new Exception("Response was OK but player session data is missing!");
        }
      }
      else
      {
        throw new Exception($"Failed to create player session. HTTP Status: {response.HttpStatusCode}");
      }
    }
    catch (Exception ex)
    {
      Debug.LogError($"General error: {ex.Message}");
    }
  }

var playerSessionId = $"benxiwan-{UnityEngine.Random.Range(0, 10000)}";
var gameSessionId = "<gamelift-session-id>";

var connState = new ConnectionState
{
    sessionName = sessionName,
    playerSessionId = playerSessionId,
    gameSessionId = gameSessionId
};

CreatePlayerSession(connState);

  public async void StartGame(GameMode mode, ConnectionState state)
  {
    Debug.Log($"StartGame GameMode: {mode}");

    try
    {
      GameSession gamesession = state.gamesession;
      string SessionName = state.sessionName;
      string gameAddress = state.gameAddress;
      ushort gameport = state.gamePort;

      // other logic
      var appSettings = BuildCustomAppSetting("<photon-region-code>", "<photon-custom-appid>");
      
      StartGameResult result;
      if (mode == GameMode.Client)
      {
        Debug.Log($"STATE: SessionName: {SessionName}, gameAddress: {gameAddress}, gameport: {gameport}");
        // Start or join (depends on gamemode) a session with a specific name

        result = await _runner.StartGame(new StartGameArgs()
        {
          GameMode = mode,
          SessionName = SessionName,
          Scene = scene,
          EnableClientSessionCreation = false,
          SceneManager = gameObject.AddComponent<NetworkSceneManagerDefault>(),
          CustomPhotonAppSettings = appSettings,
          MatchmakingMode = MatchmakingMode.FillRoom,
          DisableNATPunchthrough = false,
          ConnectionToken = System.Text.Encoding.UTF8.GetBytes(state.playerSessionId)
        });
      }
      else
      {
        // SERVER: get game session info
        // SERVER LOGIC
      }

      // other logic

    }
    catch (Exception ex)
    {
      Debug.Log(ex);
    }
  }

void INetworkRunnerCallbacks.OnPlayerJoined(NetworkRunner runner, PlayerRef player)
  {
    if (runner.IsServer)
    {
      Debug.Log($"Photon OnPlayerJoined playerId: {player.PlayerId}");

      byte[] token = runner.GetPlayerConnectionToken(player);
      var playerSessionId = System.Text.Encoding.UTF8.GetString(token);

      Debug.Log($"GameLift OnPlayerJoined playerId: {playerSessionId}");
      GameLiftServerAPI.AcceptPlayerSession(playerSessionId);
    }
  }

  void INetworkRunnerCallbacks.OnPlayerLeft(NetworkRunner runner, PlayerRef player)
  {
    if (runner.IsServer && _spawnedCharacters.TryGetValue(player, out NetworkObject networkObject))
    {
      Debug.Log($"OnPlayerLeft playerId: {player.PlayerId}");
      byte[] token = runner.GetPlayerConnectionToken(player);
      var playerSessionId = System.Text.Encoding.UTF8.GetString(token);
      Debug.Log($"RemovePlayerSession:{playerSessionId}");
      GameLiftServerAPI.RemovePlayerSession(playerSessionId);
    }
  }

# step 1: create custom location
aws gamelift create-location \
--location-name custom-location-1

# step 2: create fleet
aws gamelift create-fleet \
--name myFleet001 \
--compute-type ANYWHERE \
--locations "Location=custom-location-1"

# step 3: get the fleetid from step 2 and register local compute
aws gamelift register-compute \
--compute-name benxiwanAnywhere001 \
--fleet-id <fleetId Arn> \
--ip-address <public ip address> \
--location custom-location-1

# step 4: generate auth token
aws gamelift get-compute-auth-token \
--fleet-id <fleetId Arn> \
--compute-name benxiwanAnywhere001

# step 5: use the auth token to access gamelift server in Unity
# this auth token is for DS
string authToken = "<auth token>";

# step 6: create game session with game properties
# this gameSessionId is for Client
aws gamelift create-game-session \
--maximum-player-session-count 10 \
--fleet-id <fleetId Arn> \
--game-properties {"Key": "SessionName", "Value": "photonRoom001"} \
--location custom-location-1 

# step 1: upload build with basic information
aws gamelift upload-build \
--name "unity-photon-v1" \
--build-version "1.8" \
--build-root "./Builds/linux" \
--operating-system AMAZON_LINUX_2 \
--server-sdk-version "5.0.0" \
--region <aws-region-code>

# step 2: create fleet, need build id from previous step
# for port, refer: https://doc.photonengine.com/fusion/current/manual/connection-and-matchmaking/tcp-and-udp-port-numbers
aws gamelift create-fleet \
--name "photon-fleet.v1" \
--build-id <buid id> \
--certificate-configuration 'CertificateType=GENERATED' \
--instance-role-arn '<custom-instance-role>' \
--ec2-instance-type c5.xlarge \
--ec2-inbound-permissions 'FromPort=4530,ToPort=4540,IpRange=0.0.0.0/0,Protocol=TCP' \
--ec2-inbound-permissions 'FromPort=5050,ToPort=5060,IpRange=0.0.0.0/0,Protocol=UDP' \
--ec2-inbound-permissions 'FromPort=27000,ToPort=27010,IpRange=0.0.0.0/0,Protocol=UDP' \
--fleet-type SPOT \
--runtime-configuration 'ServerProcesses=[
{LaunchPath=/local/game/TestServer.x86_64,ConcurrentExecutions=1}
]' \
--region <aws-region-code>

# step 3: create game session, need fleetid from previus step
# this gameSessionId is for Client
aws gamelift create-game-session \
--maximum-player-session-count 10 \
--fleet-id <fleet id arn> \
--game-properties {"Key": "SessionName", "Value": "photonRoom001"} \
--region <aws-region-code>