[C#/COMMON/PROTO.ACTOR/.NET6] 가상 액터/그레인을 사용해 멤버 클러스터에서 그레인 간 통신하기
■ 가상 액터/그레인을 사용해 멤버 클러스터에서 그레인 간 통신하는 방법을 보여준다. ▶ Messages.proto
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
syntax = "proto3"; option csharp_namespace = "TestProject"; message GetSmartBulbStateResponse { string state = 1; } message ChangeSmartBulbStateRequest { string smart_bulb_identity = 1; bool is_on = 2; } |
▶ Grains.proto
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
syntax = "proto3"; option csharp_namespace = "TestProject"; import "google/protobuf/empty.proto"; import "Messages.proto"; service SmartBulbGrain { rpc TurnOn (google.protobuf.Empty) returns (google.protobuf.Empty); rpc TurnOff (google.protobuf.Empty) returns (google.protobuf.Empty); rpc GetState (google.protobuf.Empty) returns (GetSmartBulbStateResponse); } service SmartHouseGrain { rpc ChangeSmartBulbState (ChangeSmartBulbStateRequest) returns (google.protobuf.Empty); } |
▶ SmartBulbGrain.cs
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 |
using Proto; using Proto.Cluster; namespace TestProject; /// <summary> /// 스마트 전구 그레인 /// </summary> public class SmartBulbGrain : SmartBulbGrainBase { //////////////////////////////////////////////////////////////////////////////////////////////////// Enumeration ////////////////////////////////////////////////////////////////////////////////////////// Private #region 스마트 전구 상태 - SmartBulbState /// <summary> /// 스마트 전구 상태 /// </summary> private enum SmartBulbState { Unknown, On, Off } #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Field ////////////////////////////////////////////////////////////////////////////////////////// Private #region Field /// <summary> /// 클러스터 ID /// </summary> private readonly ClusterIdentity clusterIdentity; /// <summary> /// 스마트 전구 상태 /// </summary> private SmartBulbState state = SmartBulbState.Unknown; #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor ////////////////////////////////////////////////////////////////////////////////////////// Public #region 생성자 - SmartBulbGrain(context, clusterIdentity) /// <summary> /// 생성자 /// </summary> /// <param name="context">컨텍스트</param> /// <param name="clusterIdentity">클러스터 ID</param> public SmartBulbGrain(IContext context, ClusterIdentity clusterIdentity) : base(context) { this.clusterIdentity = clusterIdentity; Console.WriteLine($"스마트 전구 생성 : {this.clusterIdentity.Identity}"); } #endregion //////////////////////////////////////////////////////////////////////////////////////////////////// Method ////////////////////////////////////////////////////////////////////////////////////////// Public #region 켜기 - TurnOn() /// <summary> /// 켜기 /// </summary> /// <returns>태스크</returns> public override async Task TurnOn() { if(this.state != SmartBulbState.On) { Console.WriteLine($"스마트 전구 켜기 : {this.clusterIdentity.Identity}"); this.state = SmartBulbState.On; await NotifyHouse(); } } #endregion #region 끄기 - TurnOff() /// <summary> /// 끄기 /// </summary> /// <returns>태스크</returns> public override async Task TurnOff() { if(this.state != SmartBulbState.Off) { Console.WriteLine($"스마트 전구 끄기 : {this.clusterIdentity.Identity}"); this.state = SmartBulbState.Off; await NotifyHouse(); } } #endregion #region 상태 구하기 - GetState() /// <summary> /// 상태 구하기 /// </summary> /// <returns>스마트 전구 상태 구하기 결과</returns> public override Task<GetSmartBulbStateResponse> GetState() { return Task.FromResult(new GetSmartBulbStateResponse { State = this.state.ToString() }); } #endregion ////////////////////////////////////////////////////////////////////////////////////////// Private #region 하우스 통지하기 - NotifyHouse() /// <summary> /// 하우스 통지하기ㄴ /// </summary> /// <returns>태스크</returns> private async Task NotifyHouse() { await Context .GetSmartHouseGrain("마이하우스") .ChangeSmartBulbState ( new ChangeSmartBulbStateRequest { SmartBulbIdentity = this.clusterIdentity.Identity, IsOn = this.state == SmartBulbState.On }, CancellationToken.None ); } #endregion } |
▶ SmartHouseGrain.cs
