PROTO.ACTOR Archives - icodebroker

[C#/COMMON/PROTO.ACTOR/.NET6] Props 클래스 : WithReceiverMiddleware/WithSenderMiddleware 메소드를 사용해 미들웨어 설정하기

■ Props 클래스의 WithReceiverMiddleware/WithSenderMiddleware 메소드를 사용해 미들웨어를 설정하는 방법을 보여준다. ▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        MessageHeader messageHeader = new MessageHeader
        (
            new Dictionary<string, string>
            {
                { "TraceID", Guid.NewGuid().ToString() },
                { "SpanID" , Guid.NewGuid().ToString() }
            }
        );

        ActorSystem actorSystem = new ActorSystem();

        RootContext rootContext = new RootContext
        (
            actorSystem,
            messageHeader,
            next => async (context, target, envelope) =>
            {
                MessageEnvelope newEnvelope = envelope
                    .WithHeader("TraceID"     , context.Headers.GetOrDefault("TraceID"))
                    .WithHeader("SpanID"      , Guid.NewGuid().ToString())
                    .WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

                Console.WriteLine("  1 루트 컨텍스트 발송자 미들웨어 진입");
                Console.WriteLine("  1 TraceID      : " + newEnvelope.Header.GetOrDefault("TraceID"     ));
                Console.WriteLine("  1 SpanID       : " + newEnvelope.Header.GetOrDefault("SpanID"      ));
                Console.WriteLine("  1 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

                await next(context, target, newEnvelope);

                Console.WriteLine("  1 루트 컨텍스트 발송자 미들웨어 이탈 - 송신은 비동기식입니다. 설계상 순서가 잘못되었습니다.");
            }
        );

        Props props = Props.FromFunc
        (
            context =>
            {
                if(context.Message is string)
                {
                    Console.WriteLine( "      3 액터 진입");
                    Console.WriteLine($"      3 TraceID      : {context.Headers.GetOrDefault("TraceID"     )}");
                    Console.WriteLine($"      3 SpanID       : {context.Headers.GetOrDefault("SpanID"      )}");
                    Console.WriteLine($"      3 ParentSpanID : {context.Headers.GetOrDefault("ParentSpanID")}");
                    Console.WriteLine($"      3 액터 수신    : {context.Message.GetType()}:{context.Message}");

                    context.Respond("세계!");

                    Console.WriteLine( "      3 액터 이탈");
                }

                return Task.CompletedTask;
            }
        )
        .WithReceiverMiddleware
        (
            receiver => async (context, envelope) =>
            {
                if(envelope.Message is string)
                {
                    MessageEnvelope newEnvelope = envelope
                        .WithHeader("TraceID"     , envelope.Header.GetOrDefault("TraceID"))
                        .WithHeader("SpanID"      , Guid.NewGuid().ToString())
                        .WithHeader("ParentSpanID", envelope.Header.GetOrDefault("SpanID"));

                    Console.WriteLine("    2 액터 수신자 미들웨어 진입");
                    Console.WriteLine("    2 TraceID      : " + newEnvelope.Header.GetOrDefault("TraceID"     ));
                    Console.WriteLine("    2 SpanID       : " + newEnvelope.Header.GetOrDefault("SpanID"      ));
                    Console.WriteLine("    2 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

                    await receiver(context, newEnvelope);

                    Console.WriteLine("    2 액터 수신자 미들웨어 이탈");
                }
                else
                {
                    await receiver(context, envelope);
                }
            }
        )
        .WithSenderMiddleware
        (
            sender => async (context, target, envelope) =>
            {
                MessageEnvelope newEnvelope = envelope
                    .WithHeader("TraceID"     , context.Headers.GetOrDefault("TraceID"))
                    .WithHeader("SpanID"      , Guid.NewGuid().ToString())
                    .WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

                Console.WriteLine("        4 액터 발송자 미들웨어 진입");
                Console.WriteLine("        4 TraceID      : " + newEnvelope.Header.GetOrDefault("TraceID"     ));
                Console.WriteLine("        4 SpanID       : " + newEnvelope.Header.GetOrDefault("SpanID"      ));
                Console.WriteLine("        4 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

                await sender(context, target, envelope);

                Console.WriteLine("        4 액터 발송자 미들웨어 이탈");
            }
        );

        PID pid = rootContext.Spawn(props);

        Task.Delay(500).Wait();

        Console.WriteLine("0 TraceID      : " + rootContext.Headers.GetOrDefault("TraceID"     ));
        Console.WriteLine("0 SpanID       : " + rootContext.Headers.GetOrDefault("SpanID"      ));
        Console.WriteLine("0 ParentSpanID : " + rootContext.Headers.GetOrDefault("ParentSpanID"));

        string result = rootContext.RequestAsync<string>(pid, "안녕하세요").Result;

        Console.WriteLine("결과 : " + result);

        Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

        Console.ReadKey(false);
    }

    #endregion
}

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

140

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

MessageHeader messageHeader = new MessageHeader

(

new Dictionary<string, string>

{

{ "TraceID", Guid.NewGuid().ToString() },

{ "SpanID" , Guid.NewGuid().ToString() }

}

);

ActorSystem actorSystem = new ActorSystem();

RootContext rootContext = new RootContext

(

actorSystem,

messageHeader,

next => async (context, target, envelope) =>

{

MessageEnvelope newEnvelope = envelope

.WithHeader("TraceID" , context.Headers.GetOrDefault("TraceID"))

.WithHeader("SpanID" , Guid.NewGuid().ToString())

.WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

Console.WriteLine(" 1 루트 컨텍스트 발송자 미들웨어 진입");

Console.WriteLine(" 1 TraceID : " + newEnvelope.Header.GetOrDefault("TraceID" ));

Console.WriteLine(" 1 SpanID : " + newEnvelope.Header.GetOrDefault("SpanID" ));

Console.WriteLine(" 1 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

await next(context, target, newEnvelope);

Console.WriteLine(" 1 루트 컨텍스트 발송자 미들웨어 이탈 - 송신은 비동기식입니다. 설계상 순서가 잘못되었습니다.");

}

);

Props props = Props.FromFunc

(

context =>

{

if(context.Message is string)

{

Console.WriteLine( " 3 액터 진입");

Console.WriteLine($" 3 TraceID : {context.Headers.GetOrDefault("TraceID" )}");

Console.WriteLine($" 3 SpanID : {context.Headers.GetOrDefault("SpanID" )}");

Console.WriteLine($" 3 ParentSpanID : {context.Headers.GetOrDefault("ParentSpanID")}");

Console.WriteLine($" 3 액터 수신 : {context.Message.GetType()}:{context.Message}");

context.Respond("세계!");

Console.WriteLine( " 3 액터 이탈");

}

return Task.CompletedTask;

}

)

.WithReceiverMiddleware

(

receiver => async (context, envelope) =>

{

if(envelope.Message is string)

{

MessageEnvelope newEnvelope = envelope

.WithHeader("TraceID" , envelope.Header.GetOrDefault("TraceID"))

.WithHeader("SpanID" , Guid.NewGuid().ToString())

.WithHeader("ParentSpanID", envelope.Header.GetOrDefault("SpanID"));

Console.WriteLine(" 2 액터 수신자 미들웨어 진입");

Console.WriteLine(" 2 TraceID : " + newEnvelope.Header.GetOrDefault("TraceID" ));

Console.WriteLine(" 2 SpanID : " + newEnvelope.Header.GetOrDefault("SpanID" ));

Console.WriteLine(" 2 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

await receiver(context, newEnvelope);

Console.WriteLine(" 2 액터 수신자 미들웨어 이탈");

}

else

{

await receiver(context, envelope);

}

)

.WithSenderMiddleware

(

sender => async (context, target, envelope) =>

{

MessageEnvelope newEnvelope = envelope

.WithHeader("TraceID" , context.Headers.GetOrDefault("TraceID"))

.WithHeader("SpanID" , Guid.NewGuid().ToString())

.WithHeader("ParentSpanID", context.Headers.GetOrDefault("SpanID"));

Console.WriteLine(" 4 액터 발송자 미들웨어 진입");

Console.WriteLine(" 4 TraceID : " + newEnvelope.Header.GetOrDefault("TraceID" ));

Console.WriteLine(" 4 SpanID : " + newEnvelope.Header.GetOrDefault("SpanID" ));

Console.WriteLine(" 4 ParentSpanID : " + newEnvelope.Header.GetOrDefault("ParentSpanID"));

await sender(context, target, envelope);

Console.WriteLine(" 4 액터 발송자 미들웨어 이탈");

}

);

PID pid = rootContext.Spawn(props);

Task.Delay(500).Wait();

Console.WriteLine("0 TraceID : " + rootContext.Headers.GetOrDefault("TraceID" ));

Console.WriteLine("0 SpanID : " + rootContext.Headers.GetOrDefault("SpanID" ));

Console.WriteLine("0 ParentSpanID : " + rootContext.Headers.GetOrDefault("ParentSpanID"));

string result = rootContext.RequestAsync<string>(pid, "안녕하세요").Result;

Console.WriteLine("결과 : " + result);

Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] MessageHeader 클래스 : 메시지 헤더에서 데이터 전파하기

■ MessageHeader 클래스를 사용해 메시지 헤더에서 데이터를 전파하는 방법을 보여준다. ▶ CustomMessage.cs


namespace TestProject;

/// <summary>
/// 커스텀 메시지
/// </summary>
/// <param name="Message">메시지</param>
public record CustomMessage(string Message);

namespace TestProject;

/// <summary>

/// 커스텀 메시지

/// </summary>

/// <param name="Message">메시지</param>

public record CustomMessage(string Message);

▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 헤더 전파하기 - PropagateHeader(sender)

    /// <summary>
    /// 헤더 전파하기
    /// </summary>
    /// <param name="sender">발송자</param>
    /// <returns>발송자</returns>
    private static Sender PropagateHeader(Sender sender)
    {
        return (context, target, envelope) => sender(context, target, envelope.WithHeader(context.Headers));
    }

    #endregion
    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        MessageHeader messageHeader = MessageHeader
            .Empty
            .With("UserID"  , "사용자1")
            .With("Language", "한국어");

        ActorSystem actorSystem = new ActorSystem
        (
            ActorSystemConfig.Setup() with
            {
                ConfigureRootContext = context => context.WithHeaders(messageHeader)
            }
        );

        Props props = Props.FromFunc
        (
            context =>
            {
                if(context.Message is CustomMessage message)
                {
                    Console.WriteLine($"메시지 : {message.Message}");

                    foreach((string key, string value) in context.Headers)
                    {
                        Console.WriteLine($"  키 : {key}, 값 : {value}");
                    }
                }

                return Task.CompletedTask;
            }
        );

        PID pid = actorSystem.Root.Spawn(props);

        IRootContext rootContext = actorSystem
            .Root
            .WithSenderMiddleware(PropagateHeader);

        rootContext.Send(pid, new CustomMessage("메시지1"));

        Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

        Console.ReadKey(false);
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 헤더 전파하기 - PropagateHeader(sender)

/// <summary>

/// 헤더 전파하기

/// </summary>

/// <param name="sender">발송자</param>

/// <returns>발송자</returns>

private static Sender PropagateHeader(Sender sender)

{

return (context, target, envelope) => sender(context, target, envelope.WithHeader(context.Headers));

}

#endregion

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

MessageHeader messageHeader = MessageHeader

.Empty

.With("UserID" , "사용자1")

.With("Language", "한국어");

ActorSystem actorSystem = new ActorSystem

(

ActorSystemConfig.Setup() with

{

ConfigureRootContext = context => context.WithHeaders(messageHeader)

}

);

Props props = Props.FromFunc

(

context =>

{

if(context.Message is CustomMessage message)

{

Console.WriteLine($"메시지 : {message.Message}");

foreach((string key, string value) in context.Headers)

{

Console.WriteLine($" 키 : {key}, 값 : {value}");

}

return Task.CompletedTask;

}

);

PID pid = actorSystem.Root.Spawn(props);

IRootContext rootContext = actorSystem

.Root

.WithSenderMiddleware(PropagateHeader);

rootContext.Send(pid, new CustomMessage("메시지1"));

Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러 주시기 바랍니다.");

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] EventStream 클래스 : Subscribe 메소드에서 특정 주제에 일치하는 경우만 처리하기

■ EventStream 클래스의 Subscribe 메소드에서 특정 주제에 일치하는 경우만 처리하는 방법을 보여준다. ▶ ITopicMessage.cs


namespace TestProject;

/// <summary>
/// 주제 메시지 인터페이스
/// </summary>
public interface ITopicMessage
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 주제 - Topic

    /// <summary>
    /// 주제
    /// </summary>
    string Topic { get; }

    #endregion
}

namespace TestProject;

/// <summary>

/// 주제 메시지 인터페이스

/// </summary>

public interface ITopicMessage

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 주제 - Topic

/// <summary>

/// 주제

/// </summary>

string Topic { get; }

#endregion

}

▶ TopicMessage.cs


namespace TestProject;

/// <summary>
/// 커스텀 메시지
/// </summary>
/// <param name="Name">명칭</param>
/// <param name="Topic">주제</param>
public record TopicMessage(string Name, string Topic) : ITopicMessage;

namespace TestProject;

/// <summary>

/// 커스텀 메시지

/// </summary>

/// <param name="Name">명칭</param>

/// <param name="Topic">주제</param>

public record TopicMessage(string Name, string Topic) : ITopicMessage;

▶ EventStreamExtension.cs


using Microsoft.VisualBasic;
using Microsoft.VisualBasic.CompilerServices;

using Proto;

namespace TestProject;

/// <summary>
/// 이벤트 스트림 확장
/// </summary>
public static class EventStreamExtension
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Public

    #region 주제에 구독하기 - SubscribeToTopic<T>(eventStream, topic, action)

    /// <summary>
    /// 주제에 구독하기
    /// </summary>
    /// <typeparam name="T">주제 메시지 인터페이스</typeparam>
    /// <param name="eventStream">이벤트 스트림</param>
    /// <param name="topic">주제</param>
    /// <param name="action">액션</param>
    /// <returns>이벤트 스트림 구독</returns>
    public static EventStreamSubscription<object> SubscribeToTopic<T>(this EventStream eventStream, string topic, Action<T> action) where T : ITopicMessage
    {
        return eventStream.Subscribe<T>
        (
            x =>
            {
                if(!LikeOperator.LikeString(x.Topic, topic, CompareMethod.Binary))
                {
                    return;
                }

                action(x);
            }
        );
    }

    #endregion
}

using Microsoft.VisualBasic;

using Microsoft.VisualBasic.CompilerServices;

using Proto;

namespace TestProject;

/// <summary>

/// 이벤트 스트림 확장

/// </summary>

public static class EventStreamExtension

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Public

#region 주제에 구독하기 - SubscribeToTopic<T>(eventStream, topic, action)

/// <summary>

/// 주제에 구독하기

/// </summary>

/// <typeparam name="T">주제 메시지 인터페이스</typeparam>

/// <param name="eventStream">이벤트 스트림</param>

/// <param name="topic">주제</param>

/// <param name="action">액션</param>

/// <returns>이벤트 스트림 구독</returns>

public static EventStreamSubscription<object> SubscribeToTopic<T>(this EventStream eventStream, string topic, Action<T> action) where T : ITopicMessage

{

return eventStream.Subscribe<T>

(

x =>

{

if(!LikeOperator.LikeString(x.Topic, topic, CompareMethod.Binary))

{

return;

}

action(x);

}

);

}

#endregion

}

▶

[C#/COMMON/PROTO.ACTOR/.NET6] 액터의 수신 타임 아웃 처리하기

■ 액터가 수신 타임 아웃을 처리하는 방법을 보여준다. ▶ NoInfluenceMessage.cs


using Proto;

namespace TestProject;

/// <summary>
/// 영향을 주지 않는 메시지
/// </summary>
public class NoInfluenceMessage : INotInfluenceReceiveTimeout
{
}

using Proto;

namespace TestProject;

/// <summary>

/// 영향을 주지 않는 메시지

/// </summary>

public class NoInfluenceMessage : INotInfluenceReceiveTimeout

{

}

▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        RootContext rootContext = new RootContext(new ActorSystem());

        int count = 0;

        Props props = Props.FromFunc
        (
            context =>
            {
                switch(context.Message)
                {
                    case Started _ :

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 시작");

                        context.SetReceiveTimeout(TimeSpan.FromSeconds(1));

                        break;

                    case ReceiveTimeout _ :

                        count++;

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 수신 타임아웃 : {count}");

                        break;

                    case NoInfluenceMessage _ :

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 영향을 주지 않는 메시지 수신");

                        break;

                    case string message :

                        Console.WriteLine($"{DateTime.Now:HH:mm:ss} 메시지 수신 : {message}");

                        break;
                }

                return Task.CompletedTask;
            }
        );

        PID pid = rootContext.Spawn(props);

        for(int i = 0; i < 6; i++)
        {
            rootContext.Send(pid, "안녕하세요.");

            Thread.Sleep(500);
        }

        Console.WriteLine("영향을 주지 않는 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

        Console.ReadLine();

        for(int i = 0; i < 6; i++)
        {
            rootContext.Send(pid, new NoInfluenceMessage());

            Thread.Sleep(500);
        }

        Console.WriteLine("타임아웃을 취소하기 위한 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

        Console.ReadLine();

        rootContext.Send(pid, "취소");

        Console.WriteLine("종료하기 위해서 RETURN 키를 눌러 주세요.");

        Console.ReadLine();
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

RootContext rootContext = new RootContext(new ActorSystem());

int count = 0;

Props props = Props.FromFunc

(

context =>

{

switch(context.Message)

{

case Started _ :

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 시작");

context.SetReceiveTimeout(TimeSpan.FromSeconds(1));

break;

case ReceiveTimeout _ :

count++;

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 수신 타임아웃 : {count}");

break;

case NoInfluenceMessage _ :

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 영향을 주지 않는 메시지 수신");

break;

case string message :

Console.WriteLine($"{DateTime.Now:HH:mm:ss} 메시지 수신 : {message}");

break;

}

return Task.CompletedTask;

}

);

PID pid = rootContext.Spawn(props);

for(int i = 0; i < 6; i++)

{

rootContext.Send(pid, "안녕하세요.");

Thread.Sleep(500);

}

Console.WriteLine("영향을 주지 않는 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

Console.ReadLine();

for(int i = 0; i < 6; i++)

{

rootContext.Send(pid, new NoInfluenceMessage());

Thread.Sleep(500);

}

Console.WriteLine("타임아웃을 취소하기 위한 메시지를 보내기 위해서 RETURN 키를 눌러 주세요.");

Console.ReadLine();

rootContext.Send(pid, "취소");

Console.WriteLine("종료하기 위해서 RETURN 키를 눌러 주세요.");

Console.ReadLine();

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] ActorSystemConfig 레코드 : WithDeadLetterThrottleInterval/WithDeadLetterThrottleCount 메소드를 사용해 데드 레터 쓰로틀링 만들기

■ ActorSystemConfig 레코드의 WithDeadLetterThrottleInterval/WithDeadLetterThrottleCount 메소드를 사용해 데드 레터 쓰로틀링을 만드는 방법을 보여준다. ▶ Program.cs


using Proto;
using Proto.Extensions;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    /// <returns></returns>
    private static async Task Main()
    {
        ActorSystem actorSystem = new ActorSystem
        (
            new ActorSystemConfig()
                .WithDeadLetterThrottleInterval(TimeSpan.FromSeconds(1))
                .WithDeadLetterThrottleCount(3)
        );

        actorSystem.EventStream.Subscribe<DeadLetterEvent>
        (
            deadLetter => Console.WriteLine
            (
                $"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"
            )
        );

        Props props = Props.FromFunc(context => Task.CompletedTask);

        PID pid = actorSystem.Root.Spawn(props);

        await actorSystem.Root.StopAsync(pid);

        for(int i = 0; i < 1000; i++)
        {
            actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));
        }

        await Task.Delay(TimeSpan.FromSeconds(2));

        for(int i = 0; i < 1000; i++)
        {
            actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));
        }
    }

    #endregion
}

using Proto;

using Proto.Extensions;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

/// <returns></returns>

private static async Task Main()

{

ActorSystem actorSystem = new ActorSystem

(

new ActorSystemConfig()

.WithDeadLetterThrottleInterval(TimeSpan.FromSeconds(1))

.WithDeadLetterThrottleCount(3)

);

actorSystem.EventStream.Subscribe<DeadLetterEvent>

(

deadLetter => Console.WriteLine

(

$"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"

)

);

Props props = Props.FromFunc(context => Task.CompletedTask);

PID pid = actorSystem.Root.Spawn(props);

await actorSystem.Root.StopAsync(pid);

for(int i = 0; i < 1000; i++)

{

actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));

}

await Task.Delay(TimeSpan.FromSeconds(2));

for(int i = 0; i < 1000; i++)

{

actorSystem.EventStream.Publish(new DeadLetterEvent(pid, i, null));

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] ActorSystem 클래스 : EventStream 속성을 사용해 메시지 구독/발행하기

■ ActorSystem 클래스의 EventStream 속성을 사용해 메시지를 구독/발행하는 방법을 보여준다. ▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 테스트 메시지
/// </summary>
/// <param name="Text">텍스트</param>
public record TestMessage(string Text);

/// <summary>
/// 프로그램
/// </summary>
static class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        ActorSystem actorSystem = new ActorSystem();

        actorSystem.EventStream.Subscribe<TestMessage>(message => Console.WriteLine($"구독 메시지 : {message.Text}"));

        actorSystem.EventStream.Publish(new TestMessage("메시지1"));
        actorSystem.EventStream.Publish(new TestMessage("메시지2"));

        Console.ReadKey(false);
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 테스트 메시지

/// </summary>

/// <param name="Text">텍스트</param>

public record TestMessage(string Text);

/// <summary>

/// 프로그램

/// </summary>

static class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

ActorSystem actorSystem = new ActorSystem();

actorSystem.EventStream.Subscribe<TestMessage>(message => Console.WriteLine($"구독 메시지 : {message.Text}"));

actorSystem.EventStream.Publish(new TestMessage("메시지1"));

actorSystem.EventStream.Publish(new TestMessage("메시지2"));

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] IActor 인터페이스 : ReceiveAsync 메소드를 사용해 액터 수명주기 이벤트 처리하기

■ IActor 인터페이스의 ReceiveAsync 메소드를 사용해 액터 수명주기 이벤트를 처리하는 방법을 보여준다. ▶ HelloMessage.cs


using TestProject;

/// <summary>
/// 헬로우 메시지
/// </summary>
public class HelloMessage
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Field
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region Field

    /// <summary>
    /// 이름
    /// </summary>
    public string Name;

    #endregion
}

using TestProject;

/// <summary>

/// 헬로우 메시지

/// </summary>

public class HelloMessage

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Field

////////////////////////////////////////////////////////////////////////////////////////// Public

#region Field

/// <summary>

/// 이름

/// </summary>

public string Name;

#endregion

}

▶ HelloActor.cs


using Proto;

namespace TestProject;

/// <summary>
/// 헬로우 액터
/// </summary>
public class HelloActor : IActor
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 수신하기 (비동기) - ReceiveAsync(context)

    /// <summary>
    /// 수신하기 (비동기)
    /// </summary>
    /// <param name="context">컨텍스트</param>
    /// <returns>태스크</returns>
    public Task ReceiveAsync(IContext context)
    {
        switch(context.Message)
        {
            case HelloMessage helloMessage :

                Console.WriteLine($"안녕하세요, {helloMessage.Name}");

                break;

            case Started _ :

                Console.WriteLine("시작했습니다, 여기서 액터를 초기화합니다.");

                break;

            case Stopping _ :

                Console.WriteLine("중단중입니다, 액터가 곧 셧 다운됩니다.");

                break;

            case Stopped _ :

                Console.WriteLine("중단했습니다, 액터와 그 자식들이 중단되었습니다.");

                break;

            case Restarting _ :

                Console.WriteLine("재시작하고 있습니다, 액터가 곧 재시작됩니다.");

                break;
        }

        return Task.CompletedTask;
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 헬로우 액터

/// </summary>

public class HelloActor : IActor

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 수신하기 (비동기) - ReceiveAsync(context)

/// <summary>

/// 수신하기 (비동기)

/// </summary>

/// <param name="context">컨텍스트</param>

/// <returns>태스크</returns>

public Task ReceiveAsync(IContext context)

{

switch(context.Message)

{

case HelloMessage helloMessage :

Console.WriteLine($"안녕하세요, {helloMessage.Name}");

break;

case Started _ :

Console.WriteLine("시작했습니다, 여기서 액터를 초기화합니다.");

break;

case Stopping _ :

Console.WriteLine("중단중입니다, 액터가 곧 셧 다운됩니다.");

break;

case Stopped _ :

Console.WriteLine("중단했습니다, 액터와 그 자식들이 중단되었습니다.");

break;

case Restarting _ :

Console.WriteLine("재시작하고 있습니다, 액터가 곧 재시작됩니다.");

break;

}

return Task.CompletedTask;

}

#endregion

}

▶ Program.cs


using Proto;
using Proto.Extensions;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
static class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 시작하기 - Main()

    /// <summary>
    /// 시작하기
    /// </summary>
    /// <returns>태스크</returns>
    private static async Task Main()
    {
        ActorSystem actorSystem = new ActorSystem();

        actorSystem.EventStream.Subscribe<DeadLetterEvent>
        (
            deadLetter => Console.WriteLine
            (
                $"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"
            )
        );

        RootContext rootContext = new RootContext(actorSystem);

        Props helloProps = Props.FromProducer(() => new HelloActor());

        PID helloActorPID = rootContext.Spawn(helloProps);

        rootContext.Send(helloActorPID, new HelloMessage { Name = "홍길동" });

        await actorSystem.Root.PoisonAsync(helloActorPID);
    }

    #endregion
}

using Proto;

using Proto.Extensions;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

static class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 시작하기 - Main()

/// <summary>

/// 시작하기

/// </summary>

/// <returns>태스크</returns>

private static async Task Main()

{

ActorSystem actorSystem = new ActorSystem();

actorSystem.EventStream.Subscribe<DeadLetterEvent>

(

deadLetter => Console.WriteLine

(

$"DeadLetter from {deadLetter.Sender} to {deadLetter.Pid} : {deadLetter.Message.GetMessageTypeName()} = '{deadLetter.Message}'"

)

);

RootContext rootContext = new RootContext(actorSystem);

Props helloProps = Props.FromProducer(() => new HelloActor());

PID helloActorPID = rootContext.Spawn(helloProps);

rootContext.Send(helloActorPID, new HelloMessage { Name = "홍길동" });

await actorSystem.Root.PoisonAsync(helloActorPID);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] 가상 액터/그레인을 사용해 멤버 클러스터에서 그레인 간 통신하기

■ 가상 액터/그레인을 사용해 멤버 클러스터에서 그레인 간 통신하는 방법을 보여준다. ▶ Messages.proto


syntax = "proto3";

option csharp_namespace = "TestProject";

message GetSmartBulbStateResponse
{
    string state = 1;
}

message ChangeSmartBulbStateRequest
{
    string smart_bulb_identity = 1;
    bool   is_on = 2;
}

syntax = "proto3";

option csharp_namespace = "TestProject";

message GetSmartBulbStateResponse

{

string state = 1;

}

message ChangeSmartBulbStateRequest

{

string smart_bulb_identity = 1;

bool is_on = 2;

}

▶ Grains.proto


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);
}

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


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
}

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

[C#/COMMON/PROTO.ACTOR/.NET6] 가상 액터/그레인을 사용해 멤버 클러스터에서 스마트 전구 모델링하기 (기능 추가)

■ 가상 액터/그레인을 사용해 멤버 클러스터에서 스마트 전구를 모델링하는 방법을 보여준다. (기능 추가) ▶ TestProject.csproj


<Project Sdk="Microsoft.NET.Sdk.Web">
    <PropertyGroup>
        <TargetFramework>net6.0</TargetFramework>
        <Nullable>enable</Nullable>
        <ImplicitUsings>enable</ImplicitUsings>
    </PropertyGroup>
    <ItemGroup>
        <PackageReference Include="Grpc.Tools" Version="2.58.0">
            <PrivateAssets>all</PrivateAssets>
            <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
        </PackageReference>
        <PackageReference Include="Proto.Actor"                Version="1.3.0" />
        <PackageReference Include="Proto.Cluster"              Version="1.3.0" />
        <PackageReference Include="Proto.Cluster.CodeGen"      Version="1.3.0" />
        <PackageReference Include="Proto.Cluster.TestProvider" Version="1.3.0" />
        <PackageReference Include="Proto.Remote"               Version="1.3.0" />
    </ItemGroup>
    <ItemGroup>
        <Protobuf Include="Messages.proto" />
    </ItemGroup>
    <ItemGroup>
        <ProtoGrain Include="Grains.proto"
            AdditionalImportDirs="." />
    </ItemGroup>
</Project>

<Nullable>enable</Nullable>

<ImplicitUsings>enable</ImplicitUsings>

</PropertyGroup>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

</ItemGroup>

</ItemGroup>

<ProtoGrain Include="Grains.proto"

AdditionalImportDirs="." />

</ItemGroup>

</Project>

▶ Messages.proto


syntax = "proto3";

option csharp_namespace = "TestProject";

message GetSmartBulbStateResponse
{
    string state = 1;
}

syntax = "proto3";

option csharp_namespace = "TestProject";

message GetSmartBulbStateResponse

{

string state = 1;

}

▶ Grains.proto


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);
}

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);

}

[C#/COMMON/PROTO.ACTOR/.NET6] 가상 액터/그레인을 사용해 멤버 클러스터에서 스마트 전구 모델링하기

■ 가상 액터/그레인을 사용해 멤버 클러스터에서 스마트 전구를 모델링하는 방법을 보여준다. ▶ TestProject.csproj


<Project Sdk="Microsoft.NET.Sdk.Web">
    <PropertyGroup>
        <TargetFramework>net6.0</TargetFramework>
        <Nullable>enable</Nullable>
        <ImplicitUsings>enable</ImplicitUsings>
    </PropertyGroup>
    <ItemGroup>
        <PackageReference Include="Grpc.Tools" Version="2.58.0">
            <PrivateAssets>all</PrivateAssets>
            <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
        </PackageReference>
        <PackageReference Include="Proto.Actor"                Version="1.3.0" />
        <PackageReference Include="Proto.Cluster"              Version="1.3.0" />
        <PackageReference Include="Proto.Cluster.CodeGen"      Version="1.3.0" />
        <PackageReference Include="Proto.Cluster.TestProvider" Version="1.3.0" />
        <PackageReference Include="Proto.Remote"               Version="1.3.0" />
    </ItemGroup>
    <ItemGroup>
        <ProtoGrain Include="Grains.proto" />
    </ItemGroup>
</Project>

<Nullable>enable</Nullable>

<ImplicitUsings>enable</ImplicitUsings>

</PropertyGroup>

<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

</PackageReference>

</ItemGroup>

</ItemGroup>

</Project>

▶ Grains.proto


syntax = "proto3";

option csharp_namespace = "TestProject";

import "google/protobuf/empty.proto";

service SmartBulbGrain
{
    rpc TurnOn (google.protobuf.Empty) returns (google.protobuf.Empty);
    rpc TurnOff (google.protobuf.Empty) returns (google.protobuf.Empty);
}

syntax = "proto3";

option csharp_namespace = "TestProject";

import "google/protobuf/empty.proto";

service SmartBulbGrain

{

rpc TurnOn (google.protobuf.Empty) returns (google.protobuf.Empty);

rpc TurnOff (google.protobuf.Empty) returns (google.protobuf.Empty);

}

▶ SmartBulbGrain.cs


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;
        }
    }

    #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;
        }
    }

    #endregion
}

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;

}

#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;

}

#endregion

}

▶ SmartBulbSimulator.cs

[C#/COMMON/PROTO.ACTOR/.NET6] Proto.Cluster.TestProvider 누겟 설치하기

■ Proto.Cluster.TestProvider 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/COMMON/PROTO.ACTOR/.NET6] Proto.Cluster.CodeGen 누겟 설치하기

■ Proto.Cluster.CodeGen 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/COMMON/PROTO.ACTOR/.NET6] Proto.Cluster 누겟 설치하기

■ Proto.Cluster 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/COMMON/PROTO.ACTOR/.NET6] Proto.Remote 누겟 설치하기

■ Proto.Remote 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.

[C#/COMMON/PROTO.ACTOR/.NET6] Proto.Actor 시작하기

■ Proto.Actor를 시작하는 방법을 보여준다. ▶ HelloMessage.cs


namespace TestProject;

/// <summary>
/// 헬로우 메시지
/// </summary>
public class HelloMessage
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Property
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 이름 - Name

    /// <summary>
    /// 이름
    /// </summary>
    public string Name { get;private set; }

    #endregion

    //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 생성자 - HelloMessage(name)

    /// <summary>
    /// 생성자
    /// </summary>
    /// <param name="name">이름</param>
    public HelloMessage(string name)
    {
        Name = name;
    }

    #endregion
}

namespace TestProject;

/// <summary>

/// 헬로우 메시지

/// </summary>

public class HelloMessage

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Property

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 이름 - Name

/// <summary>

/// 이름

/// </summary>

public string Name { get;private set; }

#endregion

//////////////////////////////////////////////////////////////////////////////////////////////////// Constructor

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 생성자 - HelloMessage(name)

/// <summary>

/// 생성자

/// </summary>

/// <param name="name">이름</param>

public HelloMessage(string name)

{

Name = name;

}

#endregion

}

▶ HelloActor.cs


using Proto;

namespace TestProject;

/// <summary>
/// 헬로우 액터
/// </summary>
public class HelloActor : IActor
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Public

    #region 수신하기 (비동기) - ReceiveAsync(context)

    /// <summary>
    /// 수신하기 (비동기)
    /// </summary>
    /// <param name="context">컨텍스트</param>
    /// <returns>태스크</returns>
    public Task ReceiveAsync(IContext context)
    {
        if(context.Message is HelloMessage helloMessage)
        {
            Console.WriteLine($"Hello {helloMessage.Name}");
        }

        return Task.CompletedTask;
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 헬로우 액터

/// </summary>

public class HelloActor : IActor

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Public

#region 수신하기 (비동기) - ReceiveAsync(context)

/// <summary>

/// 수신하기 (비동기)

/// </summary>

/// <param name="context">컨텍스트</param>

/// <returns>태스크</returns>

public Task ReceiveAsync(IContext context)

{

if(context.Message is HelloMessage helloMessage)

{

Console.WriteLine($"Hello {helloMessage.Name}");

}

return Task.CompletedTask;

}

#endregion

}

▶ Program.cs


using Proto;

namespace TestProject;

/// <summary>
/// 프로그램
/// </summary>
class Program
{
    //////////////////////////////////////////////////////////////////////////////////////////////////// Method
    ////////////////////////////////////////////////////////////////////////////////////////// Static
    //////////////////////////////////////////////////////////////////////////////// Private

    #region 프로그램 시작하기 - Main()

    /// <summary>
    /// 프로그램 시작하기
    /// </summary>
    private static void Main()
    {
        ActorSystem system = new ActorSystem();

        Props helloProps = Props.FromProducer(() => new HelloActor());

        PID helloPID = system.Root.Spawn(helloProps);

        system.Root.Send(helloPID, new HelloMessage("World"));

        Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러주시기 바랍니다.");

        Console.ReadKey(false);
    }

    #endregion
}

using Proto;

namespace TestProject;

/// <summary>

/// 프로그램

/// </summary>

class Program

{

//////////////////////////////////////////////////////////////////////////////////////////////////// Method

////////////////////////////////////////////////////////////////////////////////////////// Static

//////////////////////////////////////////////////////////////////////////////// Private

#region 프로그램 시작하기 - Main()

/// <summary>

/// 프로그램 시작하기

/// </summary>

private static void Main()

{

ActorSystem system = new ActorSystem();

Props helloProps = Props.FromProducer(() => new HelloActor());

PID helloPID = system.Root.Spawn(helloProps);

system.Root.Send(helloPID, new HelloMessage("World"));

Console.WriteLine("프로그램을 종료하기 위해서 아무 키나 눌러주시기 바랍니다.");

Console.ReadKey(false);

}

#endregion

}

TestProject.zip

[C#/COMMON/PROTO.ACTOR/.NET6] Proto.Actor 누겟 설치하기

■ Proto.Actor 누겟을 설치하는 방법을 보여준다. 1. Visual Studio를 실행한다. 2. [도구] / [NuGet 패키지 관리자] / [패키지 관리자 콘솔] 메뉴를 실행한다.