.NET のための通信フレームワーク MagicOnion 入門 / Introduction to MagicOnion

.NET のための通信フレームワーク MagicOnion 入門

- MagicOnion で Unary API を実装するデモ: https://youtu.be/LoL_pRjC2sU
- サーバーとクライアントを一つの IDE でステップ実行するデモ: https://youtu.be/aioFKsX1GuA
- StreamingHub でリアルタイムにクライアントへ配信するデモ: https://youtu.be/Vj18oXv5LgM

Transcript

1. .NET MagicOnion Mayuki Sawatari <mayuki@misuzilla.org>
2. About Me Mayuki Sawatari @mayuki http://github.com/mayuki Working at Cysharp, Inc. MagicOnion Maintainer Microsoft MVP for Developer Technologies
3. [PR]WeekRef.NET .NET https://WeekRef.NET/
4. MagicOnion
5. MagicOnion .NET RPC Cysharp MIT https://github.com/Cysharp/MagicOnion
6. MagicOnion .NET .NET/C# (IDL) 1 /1 RPC ORM
7. MagicOnion .NET .NET/C# (IDL) 1 /1 RPC
8. .NET/C# IDL IDL Client Server (IDL) API
9. .NET/C# IDL / .NET C# IDL C# ? (MagicOnion ) C# interface C# Client C# Server C# interface .NET .NET interface API interface
10. .NET/C# IDL API C# C# interface namespace ApiService1; public interface IGreeterService { string SayHello(string name); } IGreeterService SayHello string string
11. .NET/C# IDL C# // var client = Client.Create<IGreeterService>(); var result = client.SayHello("Alice"); Console.WriteLine(result); // => Hello Alice // public class GreeterService : IGreeterService { public string SayHello(string name) => $"Hello {name}"; } // public interface IGreeterService { string SayHello(string name); }
12. .NET/C# IDL MagicOnion // var client = MagicOnionClient.Create<IGreeterService>(channel); var result = await client.SayHelloAsync("Alice"); Console.WriteLine(result); // => Hello Alice // public class GreeterService : ServiceBase<IGreeterService>, IGreeterService { public async UnaryResult<string> SayHelloAsync(string name) => $"Hello {name}"; } // public interface IGreeterService : IService<IGreeterService> { UnaryResult<string> SayHelloAsync(string name); }
13. .NET/C# IDL C#/.NET interface .NET
14. =
15. Client Server API API API Client Server API API : 1:1
16. MagicOnion / Server Client Client Client リクエスト レスポンス Server Client Client Client 通知 通知 リクエスト API
17. MagicOnion .NET .NET/C# (IDL) 1 /1 RPC
18. SignalR MagicOnion SignalR (= ) MagicOnion .NET (.NET, Unity) (= ) Strongly-typed MagicOnion .NET interface object
20. .NET 8+ .NET Standard 2.x .NET 8+ Unity (Windows, iOS, Android) .NET C#
24. .NET Runtime ASP.NET Core Grpc.AspNetCore.Server MagicOnion.Server OS (Windows, Linux, macOS) OS (Windows, Linux, macOS, iOS, Android) .NET Runtime Unity SocketsHttpHandler YetAnotherHttpHandler HttpClient Grpc.Net.Client MagicOnion.Client gRPC HTTP/2 MessagePack TCP/IP TLS UDS/Named Pipe
25. ASP.NET Core gRPC gRPC over HTTP/2 gRPC MessagePack HttpClient C# gRPC
26. Demo: API
28. IDE IDE .NET
30. Tips Visual Studio 2022 17.11 Multiple Startup Projects https://learn.microsoft.com/en-us/visualstudio/ide/how-to-set-multiple-startup-projects?view=vs-2022
31. MagicOnion
32. MagicOnion Unary StreamingHub
33. Unary
34. Unary 1 1 HTTP API Client Server API API : 1:1
35. Unary: IService<T> Task<T>/Task UnaryResult<T>/UnaryResult MagicOnion Protocol Buffer public interface IGreeterService : IService<IGreeterService> { UnaryResult<string> SayHelloAsync(string name); } UnaryResult Task/ValueTask
36. Unary: ServiceBase ASP.NET Core MVC Web API Controller public class GreeterService : ServiceBase<IGreeterService>, IGreeterService { public async UnaryResult<string> SayHelloAsync(string name) => $"Hello {name}"; }
37. Unary: MagicOnionClient.Create<IService> // var channel = GrpcChannel.ForAddress("https://localhost:7127"); var client = MagicOnionClient.Create<IGreeterService>(channel); var result = await client.SayHelloAsync("Alice"); Console.WriteLine(result); // => Hello Alice
38. Unary: Web → MagicOnion ( ) public class MyFilterAttribute : MagicOnionFilterAttribute { public override async ValueTask Invoke(ServiceContext context, Func<ServiceContext, ValueTask> next) { // var request = context.GetRawRequest(); // … // await next(context); // var response = context.GetRawResponse(); // … context.SetRawResponse(response); // … } }
39. Unary: ASP .NET Core HTTP RateLimiting Authorize RateLimitingMiddleware (ASP.NET Core) AuthorizeMiddleware (ASP.NET Core) MetricsFilter MyFilter SayHelloAsync
40. StreamingHub
41. StreamingHub Client Server API
42. Demo: StreamingHub OpenAI
44. StreamingHub: IStreamingHub ValueTask/ValueTask<T> ( ) // public interface IGreeterHub : IStreamingHub<IGreeterHub, IGreeterHubReceiver> { ValueTask<string> HelloAsync(string name); } // ( ) public interface IGreeterHubReceiver { void OnMessageReceived(string message); } void
45. StreamingHub: StreamingHubBase Unary Controller SignalR Hub Client public class GreeterHub : StreamingHubBase<IGreeterHub, IGreeterHubReceiver>, IGreeterHub { public async ValueTask<string> HelloAsync(string name) { // _ = Task.Run(async () => { await Task.Delay(1000); Client.OnMessageReceived($" {name}"); }); return $"Hello {name}"; } } Client.OnMessageReceived vNext
46. StreamingHub: StreamingHubClient.ConnectAsync & var channel = GrpcChannel.ForAddress("https://localhost:7127"); var receiver = new GreeterHubReceiver(); var hub = await StreamingHubClient.ConnectAsync<IGreeterHub, IGreeterHubReceiver>(channel, receiver); var result = await hub.HelloAsync("Alice"); Console.WriteLine(result); // => Hello Alice // 1 " Alice" ( ) class GreeterHubReceiver : IGreeterHubReceiver { public void OnMessageReceived(string message) => Console.WriteLine(message); }
47. StreamingHub 1 1Hub Hub Client Hub Client Hub Client Hub Client …
48. StreamingHub Hub Hub Hub Client Hub Client Hub Client Hub Client …
49. StreamingHub: … Hub Client Hub Client Hub Client Hub Client Group: Room-B Group: Room-A
50. StreamingHub: (JoinAsync) (SendMessageAsync) OnMessage public interface IChatHub : IStreamingHub<IChatHub, IChatHubReceiver> { ValueTask JoinAsync(string roomName, string name); ValueTask SendMessageAsync(string message); } public interface IChatHubReceiver { void OnMessage(string name, string message); }
51. StreamingHub: v6.x public class ChatHub : StreamingHubBase<IChatHub, IChatHubReceiver>, IChatHub { private IGroup? _group; private string? _name; public async ValueTask JoinAsync(string roomName, string name) { // roomName _group = await Group.AddAsync(roomName); _name = name; } public ValueTask SendMessageAsync(string message) { // OnMessage Broadcast(_group).OnMessage(_name, message); return default; } }
52. StreamingHub: v7 public class ChatHub : StreamingHubBase<IChatHub, IChatHubReceiver>, IChatHub { private IGroup<IChatHubReceiver>? _group; private string? _name; public async ValueTask JoinAsync(string roomName, string name) { // roomName _group = await Group.AddAsync(roomName); _name = name; } public ValueTask SendMessageAsync(string message) { // OnMessage _group.All.OnMessage(_name, message); return default; } } ( All) vNext
53. Demo: StreamingHub public class BroadcastHub(ILogger<BroadcastHub> logger) : StreamingHubBase<IBroadcastHub, IBroadcastHubReceiver>, IBroadcastHub { private IGroup? _group; protected override async ValueTask OnConnected() { logger.LogInformation($"Client: {ConnectionId} Connected. (User-Agent: {Context.CallContext.GetHttpContext().Request.Headers.UserAgent})"); _group = await Group.AddAsync("All"); } public async ValueTask CompleteAsync(string message) { logger.LogInformation($"Begin CompleteAsync: Input={message}"); var client = new OpenAIClient("<OpenAI API Token>").AsChatClient(modelId: "gpt-4o-mini"); var stream = client.CompleteStreamingAsync([new ChatMessage(ChatRole.User, message)]); Broadcast(_group).OnCompleteStarted(message); await foreach (var response in stream) { Broadcast(_group).OnMessageReceived(response.Text); } Broadcast(_group).OnCompleteFinished(); logger.LogInformation($"Finished CompleteAsync"); } }
54. StreamingHub: SignalR vNext
55. .NET
56. Metrics / .NET Aspire .NET 8 Metrics API MeterSource Aspire Dashboard
57. Source Generator / Native AOT Native AOT/IL2CPP MagicOnion Source Generator Native AOT Unity IL2CPP
58. Source Generator / Native AOT MagicOnion.Client Native AOT Native AOT
59. Blazor WASM + gRPC-Web gRPC-Web Blazor WebAssembly Grpc.Net.Client.Web, Grpc.AspNet.Core.Web Unary StreamingHub grpc-web
61. .NET RPC C# API Unary StraemingHub API C# API .NET ASP .NET Core ASP.NET Core grpc-dotnet Source Generator Metrics API
62. MagicOnion - C# .NET Core/Unity | Cygames Engineers' Blog https://tech.cygames.co.jp/archives/3181/ NextGen Server/Client Architecture - gRPC + Unity + C# https://www.slideshare.net/slideshow/nextgen-serverclient-architecture-grpc-unity-c/72604810