Unity+MagicOnion4.1. StreamingHub의 실시간 통신 편 테스트

49488 단어 Unity gRPC ASP.NET Core MagicOnion tech

장절

환경 구축 & 서비스 통신편

StreamingHub의 실시간 통신 편

EC2 환경에서 서버 편 실행

IL2CPP 스마트폰 실기구 건편

이마

환경 구축 & 서비스 통신편의 계속

환경 구축, 전제 등은 상술한 문장

을 참조하십시오.

샘플에 사용된 코드는 기본적으로MagicOn의 README

를 사용했다
연결 동작 확인으로 제작되었기 때문에 매직넘버를 사용했고 오류도 제대로 처리하지 못한 점 양해 부탁드립니다.

고객 환경 구축

클라이언트<-> 서버 일반 클래스 만들기

Assets/Scripts/MyApp/Shared/MessagePackObjects/Player.cs

using MessagePack;
using UnityEngine;

namespace MyApp.Shared.MessagePackObjects
{
    [MessagePackObject]
    public class Player
    {
        [Key(0)] public string Name { get; set; }
        [Key(1)] public Vector3 Position { get; set; }
        [Key(2)] public Quaternion Rotation { get; set; }
    }
}

서버 연결을 위한 인터페이스 만들기

Assets/Scripts/MyApp/Shared/Hubs/IGamingHub.cs

using System.Threading.Tasks;
using MagicOnion;
using MyApp.Shared.MessagePackObjects;
using UnityEngine;

namespace MyApp.Shared.Hubs
{
    public interface IGamingHubReceiver
    {
        // return type shuold be `void` or `Task`, parameters are free.
        void OnJoin(Player player);
        void OnLeave(Player player);
        void OnMove(Player player);
    }

// Client -> Server definition
// implements `IStreamingHub<TSelf, TReceiver>`  and share this type between server and client.
    public interface IGamingHub : IStreamingHub<IGamingHub, IGamingHubReceiver>
    {
        // return type shuold be `Task` or `Task<T>`, parameters are free.
        Task<Player[]> JoinAsync(string roomName, string userName, Vector3 position, Quaternion rotation);
        Task LeaveAsync();
        Task MoveAsync(Vector3 position, Quaternion rotation);
    }
}

서버에 연결된 클래스 만들기

Assets/Scripts/MyApp/GamingHubClient.cs

using System.Collections.Generic;
using System.Threading.Tasks;
using Grpc.Core;
using MagicOnion.Client;
using MyApp.Shared.Hubs;
using MyApp.Shared.MessagePackObjects;
using UnityEngine;

namespace MyApp
{
    public class GamingHubClient : IGamingHubReceiver
    {
        Dictionary<string, GameObject> _players = new Dictionary<string, GameObject>();
        IGamingHub _client;

        public async Task<GameObject> ConnectAsync(Channel grpcChannel, string roomName, string playerName)
        {
            _client = StreamingHubClient.Connect<IGamingHub, IGamingHubReceiver>(grpcChannel, this);

            var roomPlayers = await _client.JoinAsync(roomName, playerName, Vector3.zero, Quaternion.identity);
            foreach (var player in roomPlayers)
            {
                (this as IGamingHubReceiver).OnJoin(player);
            }

            return _players[playerName];
        }

        // methods send to server.

        public Task LeaveAsync()
        {
            return _client.LeaveAsync();
        }

        public Task MoveAsync(Vector3 position, Quaternion rotation)
        {
            return _client.MoveAsync(position, rotation);
        }

        // dispose client-connection before channel.ShutDownAsync is important!
        public Task DisposeAsync()
        {
            return _client.DisposeAsync();
        }

        // You can watch connection state, use this for retry etc.
        public Task WaitForDisconnect()
        {
            return _client.WaitForDisconnect();
        }

        // Receivers of message from server.

        void IGamingHubReceiver.OnJoin(Player player)
        {
            Debug.Log("Join Player:" + player.Name);

            var cube = GameObject.CreatePrimitive(PrimitiveType.Cube);
            cube.name = player.Name;
            cube.transform.SetPositionAndRotation(player.Position, player.Rotation);
            _players[player.Name] = cube;
        }

        void IGamingHubReceiver.OnLeave(Player player)
        {
            Debug.Log("Leave Player:" + player.Name);

            if (_players.TryGetValue(player.Name, out var cube))
            {
                GameObject.Destroy(cube);
                _players.Remove(player.Name);
            }
        }

        void IGamingHubReceiver.OnMove(Player player)
        {
            Debug.Log("Move Player:" + player.Name);

            if (_players.TryGetValue(player.Name, out var cube))
            {
                cube.transform.SetPositionAndRotation(player.Position, player.Rotation);
            }
        }
    }
}