Amazon GameLift 高阶使用技巧（三）- 使用 Amazon GameLift Servers+ Amazon GameLift Streams 托管游戏服，并构建云游戏串流

mkdir out 
cd out 
cmake -G "Visual Studio 17 2022" -DBUILD_FOR_UNREAL=1 .. 
msbuild ALL_BUILD.vcxproj /p:Configuration=Release

sudo yum install git docker
sudo systemctl enable docker
sudo systemctl start docker
git clone https://github.com/aws/amazon-gamelift-toolkit.git
cd amazon-gamelift-toolkit/building-gamelift-server-sdk-for-unreal-engine-and-amazon-linux

#!/bin/bash
echo "Building the Unreal GameLift Server SDK binaries for Amazon Linux 2023 (ARM64)..."

# 确保启用BuildKit
export DOCKER_BUILDKIT=1

# 创建输出目录
mkdir -p ./output

# 构建ARM64架构的Docker镜像并提取二进制文件
docker buildx build --platform=linux/arm64 --output=type=local,dest=./output --target=server .

echo "Build completed. Creating ZIP archive..."

# 打包所有输出文件
cd output
zip -r ../AL2023GameliftUE5sdk_arm64.zip ./*
cd ..

echo "Done! Your ARM64 binaries are available in AL2023GameliftUE5sdk_arm64.zip"

sudo ./buildbinaries.sh

{"Name": "GameLiftServerSDK","Enabled": true}

PublicDependencyModuleNames.AddRange(
    new string[] {
        "Core",
        ...
        "GameLiftServerSDK" # 添加这一行至此
    }
);

#include “GameLiftServerSDK.h”

void ALyraGameMode::BeginPlay()
{
    // Code enclosed with the WITH_GAMELIFT=1 flag is only processed if the following are true:
    // The plugin found the Amazon GameLift server SDK binary files.
    // The build is a game server : Target.Type == TargetRules.TargetType.Server

#if WITH_GAMELIFT
    InitGameLift();
#else
    UE_LOG(LogTemp, Warning, TEXT("WITH_GAMELIFT is false. InitGameLift() not called."));
#endif
}

void ALyraGameMode::InitGameLift()
{
    FString AuthToken;
    FString HostId;
    FString FleetId;
    FString WSSUrl;

    FServerParameters serverParameters;
    FGameLiftGenericOutcome initSdkOutcome;

    UE_LOG(LogLyra, Log, TEXT("Running on port %d"), GetWorld()->URL.Port);

    bool bIsAnywhereActive = false;
    if (FParse::Param(FCommandLine::Get(), TEXT("glanywhere")))
    {
        bIsAnywhereActive = true;
    }
    else
    {
        UE_LOG(LogLyra, Log, TEXT("The -glanywhere parameter is not active."));
    }

    //Getting the module first.
    FGameLiftServerSDKModule* gameLiftSdkModule = &FModuleManager::
        LoadModuleChecked<FGameLiftServerSDKModule>(FName("GameLiftServerSDK"));

    if (bIsAnywhereActive)
    {
        UE_LOG(LogLyra, Log, TEXT("Configuring server parameters for Anywhere..."));

        FParse::Value(FCommandLine::Get(), TEXT("-authtoken="), serverParameters.m_authToken);

        if (FParse::Value(FCommandLine::Get(), TEXT("-hostid="), serverParameters.m_hostId))
        {
            UE_LOG(LogLyra, Log, TEXT("HOST_ID: %s"), *serverParameters.m_hostId)
        }

        if (FParse::Value(FCommandLine::Get(), TEXT("-fleetid="), serverParameters.m_fleetId))
        {
            UE_LOG(LogLyra, Log, TEXT("FLEET_ID: %s"), *serverParameters.m_fleetId)
        }

        if (FParse::Value(FCommandLine::Get(), TEXT("-websocketurl="), serverParameters.m_webSocketUrl))
        {
            UE_LOG(LogLyra, Log, TEXT("WEBSOCKET_URL: %s"), *serverParameters.m_webSocketUrl)
        }

#ifndef __linux__
        serverParameters.m_processId = FString::Printf(TEXT("%d"), GetCurrentProcessId());
#else
        serverParameters.m_processId = FString::Printf(TEXT("%d"), getpid());
#endif

        UE_LOG(LogLyra, Log, TEXT("PID: %s"), *serverParameters.m_processId);

        UE_LOG(LogLyra, Log, TEXT("Initializing the GameLift Server"));

        //InitSDK will establish a local connection with GameLift's agent to enable further communication.
        initSdkOutcome = gameLiftSdkModule->InitSDK(serverParameters);
    }
    else 
    {
        UE_LOG(LogLyra, Log, TEXT("Configuring server parameters for Managed Fleet"));
        initSdkOutcome = gameLiftSdkModule->InitSDK();
    }

    if (initSdkOutcome.IsSuccess())
    {
        UE_LOG(LogLyra, Log, TEXT("GameLift InitSDK succeeded"));
    }
    else
    {
        UE_LOG(LogLyra, Log, TEXT("ERROR: InitSDK failed"));
        FGameLiftError gameLiftError = initSdkOutcome.GetError();
        UE_LOG(LogLyra, Log, TEXT("ERROR: %s"), *gameLiftError.m_errorMessage);
        return;
    }

    //When a game session is created, GameLift sends an activation request to the game server and passes along the game session object containing game properties and other settings.
    //Here is where a game server should take action based on the game session object.
    //Once the game server is ready to receive incoming player connections, it should invoke GameLiftServerAPI.ActivateGameSession()
    auto onGameSession = [=](Aws::GameLift::Server::Model::GameSession gameSession)
        {
            FString gameSessionId = FString(gameSession.GetGameSessionId());
            UE_LOG(LogLyra, Log, TEXT("GameSession Initializing: %s"), *gameSessionId);
            gameLiftSdkModule->ActivateGameSession();
        };
    FProcessParameters* params = new FProcessParameters();
    params->OnStartGameSession.BindLambda(onGameSession);

    //OnProcessTerminate callback. GameLift will invoke this callback before shutting down an instance hosting this game server.
    //It gives this game server a chance to save its state, communicate with services, etc., before being shut down.
    //In this case, we simply tell GameLift we are indeed going to shutdown.
    params->OnTerminate.BindLambda([=]() {
        UE_LOG(LogLyra, Log, TEXT("Game Server Process is terminating"));
        gameLiftSdkModule->ProcessEnding();
        });

    //This is the HealthCheck callback.
    //GameLift will invoke this callback every 60 seconds or so.
    //Here, a game server might want to check the health of dependencies and such.
    //Simply return true if healthy, false otherwise.
    //The game server has 60 seconds to respond with its health status. GameLift will default to 'false' if the game server doesn't respond in time.
    //In this case, we're always healthy!
    params->OnHealthCheck.BindLambda([]() {
        UE_LOG(LogLyra, Log, TEXT("Performing Health Check"));
        return true;
        });

    //The game server takes the port from the Unreal world.
    params->port = GetWorld()->URL.Port;

    //Here, the game server tells GameLift what set of files to upload when the game session ends.
    //GameLift will upload everything specified here for the developers to fetch later.

    TArray<FString> logfiles;
    logfiles.Add(TEXT("LyraStarterGame/Saved/Logs/LyraStarterGame"));
    params->logParameters = logfiles;
    //Calling ProcessReady tells GameLift this game server is ready to receive incoming game sessions!
    UE_LOG(LogLyra, Log, TEXT("Calling Process Ready"));
    FGameLiftGenericOutcome processReadyOutcome = gameLiftSdkModule->ProcessReady(*params);
    if (processReadyOutcome.IsSuccess())
    {
        UE_LOG(LogLyra, Log, TEXT("Process Ready Succeded"));
    }
    else
    {
        UE_LOG(LogLyra, Log, TEXT("ERROR: Process Ready Failed"));
        FGameLiftError processReadyError = processReadyOutcome.GetError();
        UE_LOG(LogLyra, Log, TEXT("ERROR: %s"), *processReadyError.m_errorMessage);
    }
    UE_LOG(LogLyra, Log, TEXT("Init GameLift complete"));
}

# 在下面的判断条件中添加: || Target.Platform == UnrealTargetPlatform.LinuxArm64,示例代码如下:
if (Target.Platform == UnrealTargetPlatform.Linux || Target.Platform == UnrealTargetPlatform.LinuxArm64)
{
    SDKDirectory = System.IO.Path.Combine(SDKDirectory, "x86_64-unknown-linux-gnu");
    string SDKLib = System.IO.Path.Combine(SDKDirectory, "libaws-cpp-sdk-gamelift-server.so");
                
    PublicAdditionalLibraries.Add(SDKLib);
    RuntimeDependencies.Add(SDKLib);
}

aws gamelift create-location --location-name custom-arm-test

aws gamelift create-fleet --name arm-test-fleet --compute-type ANYWHERE --locations "Location=custom-arm-test"

aws gamelift register-compute --fleet-id <fleet-id> --compute-name linux-server1 --ip-address <ipaddrees> --location custom-arm-test

{
    "Compute": {
        "FleetId": "fleet-daa90c56xxxxxx",
        "FleetArn": "arn:aws:gamelift:ap-northeast-1:1965xx:fleet/fleet-daa90c56xxx",
        "ComputeName": "linux-server1",
        "ComputeArn": "arn:aws:gamelift:ap-northeast-1:1965xx:compute/linux-server1",
        "IpAddress": "52.xxxxx",
        "ComputeStatus": "Active",
        "Location": "custom-arm-test",
        "CreationTime": "2025-03-07T15:56:xxx",
        "GameLiftServiceSdkEndpoint": "wss://ap-northeast-1.api.amazongamelift.com",
        "GameLiftAgentEndpoint": "wss://ap-northeast-1.process-manager-api.amazongamelift.com"
    }
}

aws gamelift get-compute-auth-token --fleet-id <FleetId> --compute-name linux-server1

./LyraServer-Arm64.sh -log -glanywhere -fleetid=<fleet-id> -hostid=linux-server1 -websocketurl=wss://ap-northeast-1.api.amazongamelift.com -authtoken=<上面获取到的token>

aws gamelift create-game-session —fleet-id <fleet-id> —maximum-player-session-count 2 —location custom-arm-test

{
    "GameSession": {
        "GameSessionId": "arn:aws:gamelift:ap-northeast-1::gamesession/fleet-daa90c56xxx/custom-arm-test/gsess-89447c93-cbcb-40xxx",
        "FleetId": "fleet-daa90c56xxx",
        "FleetArn": "arn:aws:gamelift:ap-northeast-1:19650xxx:fleet/fleet-daa90c56xxx",
        "CreationTime": "2025-03-07T16:02:25.763000+00:00",
        "CurrentPlayerSessionCount": 0,
        "MaximumPlayerSessionCount": 2,
        "Status": "ACTIVATING",
        "GameProperties": [],
        "IpAddress": "52.xxx",
        "Port": 7777,
        "PlayerSessionCreationPolicy": "ACCEPT_ALL",
        "Location": "custom-arm-test"
    }
}

npm install
node server.js

processKeyboardEvent(e)  // 处理键盘事件
processMouseEvent(e)     // 处理鼠标事件
processGamepads()        // 轮询游戏手柄状态

// 在客户端库中
createDataChannel("inputChannel", {
  ordered: false,
  maxRetransmits: 0
})

.\LyraClient.exe <IP>:7777