MagicOnion を使って AWS で専用ゲームサーバーを作ろう

dotnet new web -o MagicOnionServer

cd MagicOnionServer
dotnet add package Grpc.AspNetCore
dotnet add package MagicOnion.Server

using MagicOnion;
using MagicOnion.Server;

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddGrpc();
builder.Services.AddMagicOnion();

var app = builder.Build();

app.MapMagicOnionService();

app.Run();

using System;
using MagicOnion;

namespace MyApp.Shared
{
    // Defines .NET interface as a Server/Client IDL.
    // The interface is shared between server and client.
    public interface IMyFirstService : IService<IMyFirstService>
    {
        // The return type must be `UnaryResult<T>` or `UnaryResult`.
        UnaryResult<int> SumAsync(int x, int y);
    }
}

using MagicOnion;
using MagicOnion.Server;
using MyApp.Shared;

namespace MyApp.Services;

// Implements RPC service in the server project.
// The implementation class must inherit `ServiceBase<IMyFirstService>` and `IMyFirstService`
public class MyFirstService : ServiceBase<IMyFirstService>, IMyFirstService
{
    // `UnaryResult<T>` allows the method to be treated as `async` method.
    public async UnaryResult<int> SumAsync(int x, int y)
    {
        Console.WriteLine($"Received:{x}, {y}");
        return x + y;
    }
}

{
    "Logging": {
    ...(省略)...
    },
    "Kestrel": {
        "Endpoints": {
            "Grpc": {
                "Url": "http://localhost:5000",
                "Protocols": "Http2"
            }
        }
    },
    "AllowedHosts": "*"
}

dotnet new console -o MagicOnionClient 

cd MagicOnionClient
dotnet add package MagicOnion.Client

using Grpc.Net.Client;
using MagicOnion.Client;
using MyApp.Shared;

// Connect to the server using gRPC channel.
var channel = GrpcChannel.ForAddress("http://localhost:5000");

// NOTE: If your project targets non-.NET Standard 2.1, use `Grpc.Core.Channel` class instead.
// var channel = new Channel("localhost", 5001, new SslCredentials());

// Create a proxy to call the server transparently.
var client = MagicOnionClient.Create<IMyFirstService>(channel);

// Call the server-side method using the proxy.
var result = await client.SumAsync(123, 456);
Console.WriteLine($"Result: {result}");

dotnet run 

dotnet build -f net6.0 -c Debug .\GameLiftServerSDK.sln

<Project Sdk="Microsoft.NET.Sdk.Web">
    ...(省略)...
  <ItemGroup>
    <Reference Include="GameLiftServerSDK">
      <HintPath>lib/GameLiftServerSDK.dll</HintPath>
    </Reference>
  </ItemGroup>
</Project>

dotnet add package log4net
dotnet add package websocketsharp.core
dotnet add package Polly
dotnet add package NewtonSoft.Json
dotnet add package SonarAnalyzer.CSharp 

using Aws.GameLift.Server;
using Aws.GameLift.Server.Model;


public class GameLiftServer
{
    private bool initialized = false;

    public ServerParameters initParameters(){
        //WebSocketUrl from RegisterHost call
        var webSocketUrl = Environment.GetEnvironmentVariable("websocketurl") ?? "wss://ap-northeast-1.api.amazongamelift.com";

        //Unique identifier for this process
        var processId = Guid.NewGuid().ToString();

        //Unique identifier for your host that this process belongs to
        var hostId = Environment.GetEnvironmentVariable("hostid") ?? "";

        //Unique identifier for your fleet that this host belongs to
        var fleetId = Environment.GetEnvironmentVariable("fleetid") ?? "";

        //Authentication token for this host process.
        var authToken = Environment.GetEnvironmentVariable("authtoken") ?? "";

        return new ServerParameters(
            webSocketUrl,
            processId,
            hostId,
            fleetId,
            authToken);
    }

    //This is an example of a simple integration with Amazon GameLift server SDK that will make game server processes go active on Amazon GameLift!
    public void start(int port, ServerParameters serverParameters)
    {
        //Identify port number (hard coded here for simplicity) the game server is listening on for player connections
        var listeningPort = port;

        //InitSDK will establish a local connection with Amazon GameLift's agent to enable further communication.
        var initSDKOutcome = GameLiftServerAPI.InitSDK(serverParameters);
        if (initSDKOutcome.Success)
        {
            ProcessParameters processParameters = new ProcessParameters(
                (GameSession gameSession) =>
                {
                    //When a game session is created, Amazon 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()
                    Console.WriteLine("ActivateGameSession");
                    GameLiftServerAPI.ActivateGameSession();
                },
                (UpdateGameSession updateGameSession) =>
                {
                    //When a game session is updated (e.g. by FlexMatch backfill), Amazon GameLift sends a request to the game
                    //server containing the updated game session object.  The game server can then examine the provided
                    //matchmakerData and handle new incoming players appropriately.
                    //updateReason is the reason this update is being supplied.
                    Console.WriteLine("updateGameSession");

                },
                () =>
                {
                    //OnProcessTerminate callback. Amazon 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 Amazon GameLift we are indeed going to shutdown.
                    GameLiftServerAPI.ProcessEnding();
                    Console.WriteLine("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. Amazon GameLift will default to 'false' if the game server doesn't respond in time.
                    //In this case, we're always healthy!
                    Console.WriteLine("healthcheck");
                    return true;
                },
                listeningPort, //This game server tells Amazon GameLift that it will listen on port 7777 for incoming player connections.
                new LogParameters(new List<string>()
                {
                    //Here, the game server tells Amazon GameLift what set of files to upload when the game session ends.
                    //Amazon GameLift will upload everything specified here for the developers to fetch later.
                    "/local/game/logs/myserver.log"
                }));

            //Calling ProcessReady tells Amazon GameLift this game server is ready to receive incoming game sessions!
            var processReadyOutcome = GameLiftServerAPI.ProcessReady(processParameters);
            if (processReadyOutcome.Success)
            {
                Console.WriteLine("ProcessReady success.");
                this.initialized = true;
            }
            else
            {
                Console.WriteLine("ProcessReady failure : " + processReadyOutcome.Error.ToString());
            }
        }
        else
        {
            Console.WriteLine("InitSDK failure : " + initSDKOutcome.Error.ToString());
        }
    }
}

using MagicOnion;
using MagicOnion.Server;

// 追加
var gl = new GameLiftServer();
var serverParameters = gl.initParameters();
gl.start(5000, serverParameters);
// 追加ここまで

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddGrpc();
builder.Services.AddMagicOnion();

var app = builder.Build();

app.MapMagicOnionService();

app.Run();

aws gamelift register-compute --fleet-id $env:FLEETID --compute-name $env:HOSTID --location $env:LOCATION --ip-address 127.0.0.1

aws gamelift list-compute --fleet-id $env:FLEETID

aws gamelift get-compute-auth-token --fleet-id $env:FLEETID --compute-name $env:HOSTID

$env:AUTHTOKEN="< AuthToken に記載の文字列>"

dotnet run

aws gamelift create-game-session --fleet-id $env:FLEETID --maximum-player-session-count 2 --location $env:LOCATION

aws gamelift describe-game-sessions --fleet-id $env:FLEETID