《通過C#學Proto.Actor模型》之Prpos

在第一篇Proto.Actor博文中，HelloWorld的第一行真正代碼是：

   var props = Actor.FromProducer(() => new HelloActor());

這個返回的變量props就是一個Props的對象，它是負責創Actor實例，以及配置Actor實例，並且產Actor上下文Context（類似asp.net中的Context）。

Props對象產生通常是用Actor.FromProducer或Actor.FromFunc產生，不過也可能實例化，實體例時可以給Actor做一系列配置，如下代碼：

using Proto;
using Proto.Mailbox;
using System;
using System.Threading.Tasks;

namespace P002_CustomProps
{
    class Program
    {
        static void Main(string[] args)
        {
            var props = new Props()
                //用道具代理返回一個IActor實例
                .WithProducer(() => new MyActor())
                //默認調度器用線程池，郵箱中最多300個消息吞吐量
                .WithDispatcher(new ThreadPoolDispatcher { Throughput = 300 })
                //默認郵箱使用無界隊列
                .WithMailbox(() => UnboundedMailbox.Create())
                //默認策略在10秒的窗口內最多重新啟動子Actor 10次
                .WithChildSupervisorStrategy(new OneForOneStrategy((who, reason) =>
                SupervisorDirective.Restart, 10, TimeSpan.FromSeconds(10)))
                //可以將中間件鏈接起來以攔截傳入和傳出消息 
                //接收中間件在Actor接收消息之前被調用
                //發送者中間件在消息發送到目標PID之前被調用
                .WithReceiveMiddleware(
                next => async c =>
                {
                    Console.WriteLine($"Receive中間件 1 開始，{c.Message.GetType()}:{c.Message}");
                    await next(c);
                    Console.WriteLine($"Receive中間件 1 結束，{c.Message.GetType()}:{c.Message}");
                },
                next => async c =>
                {
                    Console.WriteLine($"Receive中間件 2 開始，{c.Message.GetType()}:{c.Message}");
                    await next(c);
                    Console.WriteLine($"Receive中間件 2 結束，{c.Message.GetType()}:{c.Message}");
                })
                .WithSenderMiddleware(
                next => async (c, target, envelope) =>
                {
                    Console.WriteLine($"Sender中間件 1 開始, {c.Message.GetType()}:{c.Message}");
                    await next(c, target, envelope);
                    Console.WriteLine($"Sender中間件 1 結束，{c.Message.GetType()}:{c.Message}");
                },
                next => async (c, target, envelope) =>
                {
                    Console.WriteLine($"Sender中間件 2 開始，{c.Message.GetType()}:{c.Message}");
                    await next(c, target, envelope);
                    Console.WriteLine($"Sender中間件 2 結束，{c.Message.GetType()}:{c.Message}");
                })
                // 默認的 spawner 構造  Actor, Context 和 Process
                .WithSpawner(Props.DefaultSpawner);

            //從props衍生pid，pid代理一個actor的地址
            var pid = Actor.Spawn(props);       
            //把Hello對象交給HelloActor處理
            pid.Tell(new MyEntity
            {
                Message = "我是MyEntity的Message，請求"
            });
            Console.ReadLine();    
        }
    }

    public class MyActor : IActor
    {
        public Task ReceiveAsync(IContext context)
        {
            if (context.Message is MyEntity myEntity)
            {
                Console.WriteLine(myEntity.Message);
                context.Tell(context.Sender, new MyEntity() { Message = "我是MyEntity的Message,應答" });
            }
            return Actor.Done;
        }
    }
    public class MyEntity
    {
        public string Message { get; set; }
    }
}

你會發現，Demo中，總有一個實例類+一個Actor類，這是構成Actor模型的必備，Actor類就是主體，實體類就是Actor類運算的載體，所以它們總是如影隨形。

 第15 行到第21 行代碼含意以后會解釋。 

這里說Recevie和Sender的中間件，這里很像一個AOP，可以在調用某個行為前后作處理統一的處理，比如日志，權限等統一的規則，也和asp.net core里的中件間如出一轍【如里你是一個asp.net core碼友，熟悉的Context，熟悉的next()，還有熟悉的Middleware】。

現在可以自己運行一下分析一下結果吧：