خادم اللعبة على MS Orleans - الجزء 1: ما هي الجهات الفاعلة

المحتوى

• خادم اللعبة على MS Orleans - الجزء 1: ما هي الجهات الفاعلة

ممثلين

مثال

    class Program
    {
        interface IMessage { }

        class IncrementCommand : IMessage { }

        class TellCountCommand : IMessage { }

        class SaidCountEvent : IMessage
        {
            public int Count { get; }
            public int ActorId { get; }

            public SaidCountEvent(int count, int actorId)
            {
                Count = count;
                ActorId = actorId;
            }
        }

        class WriteMessageCommand : IMessage
        {
            public string Message { get; }

            public WriteMessageCommand(string message)
            {
                Message = message;
            }
        }

        static Task CreateCounterActor(
            BlockingCollection<IMessage> output,
            BlockingCollection<IMessage> input,
            int id
            )
        {
            return Task.Run(() =>
             {
                 var count = 0;

                 while (true)
                 {
                     var m = input.Take();
                     if (m is IncrementCommand)
                         count++;
                     if (m is TellCountCommand)
                         output.Add(new SaidCountEvent(count, id));
                 }
             });
        }

        static Task CreateWriterActor(BlockingCollection<IMessage> input)
        {
            return Task.Run(() =>
             {
                 while (true)
                 {
                     var m = input.Take();
                     if (m is WriteMessageCommand write)
                         Console.WriteLine(write.Message);
                     if (m is SaidCountEvent sc)
                         Console.WriteLine(
                             $"Counter   {sc.Count}   {sc.ActorId}"
                             );
                 }
             });
        }

        static void Main(string[] args)
        {
            var writerInput = new BlockingCollection<IMessage>();
            var firstInput = new BlockingCollection<IMessage>();
            var secondInput = new BlockingCollection<IMessage>();
            var writer = CreateWriterActor(writerInput);
            var firstCounter = CreateCounterActor(writerInput, firstInput, 1);
            var secondCounter = CreateCounterActor(writerInput, secondInput, 2);
            for (int i = 0; i < 5; i++)
            {
                firstInput.Add(new IncrementCommand());
            }
            for (int i = 0; i < 9; i++)
            {
                secondInput.Add(new IncrementCommand());
            }
            firstInput.Add(new TellCountCommand());
            secondInput.Add(new TellCountCommand());
            writerInput.Add(new WriteMessageCommand("  Main"));
            Console.ReadLine();
        }
    }

1. الواجهة التي نميز بواسطتها الرسائل التي يستقبلها الفاعل أو يرسلها:
   

   interface IMessage { }
   

   
   
2. الأمر الذي نطلب منه من الممثل زيادة عداده (الحالة الداخلية):
   

   class IncrementCommand : IMessage { }
   

   
   
3. الأمر الذي نساعد به الممثل أن يخبر حالته الحالية (العداد) للآخرين:
   

   class TellCountCommand : IMessage { }
   

   
   
4. حدث يخبر الممثلين الآخرين أن الممثل قد أخبر الجميع حالته الحالية (العداد). يتم إنشاؤه عند معالجة أمر TellCountCommand:
   

   class SaidCountEvent : IMessage
   {
       public int Count { get; }
       public int ActorId { get; }
   
       public SaidCountEvent(int count, int actorId)
       {
           Count = count;
           ActorId = actorId;
       }
   }
   

   
   العدد هو المبلغ الذي يتم طلبه الآن على عداد ممثل بمعرف يساوي ActorId
   
5. يخبر هذا الأمر الفاعل بطباعة هذه الرسالة إلى وحدة التحكم:
   

   class WriteMessageCommand : IMessage
   {
       public string Message { get; }
   
       public WriteMessageCommand(string message)
       {
           Message = message;
       }
   }
   

   
   
6. يبدأ مثيل الممثل الذي يتحكم في الحالة الحالية للعداد:
   

           static Task CreateCounterActor(
            //   
               BlockingCollection<IMessage> output,
             // 
               BlockingCollection<IMessage> input,
            //              
               int id
               )
           {
               return Task.Run(() =>
                { 
                    //  .    
                    var count = 0;
   
                    while (true)
                    {
                      //     
                     //             
                        var m = input.Take();
                        if (m is IncrementCommand)
                            count++;
                        if (m is TellCountCommand)
                            output.Add(new SaidCountEvent(count, id));
                    }
                });
           }
   

   
   
7. ينشئ ممثلاً يكتب الرسائل ببساطة إلى وحدة التحكم:
   

           static Task CreateWriterActor(BlockingCollection<IMessage> input)
           {
               return Task.Run(() =>
                {
                    while (true)
                    {
                        var m = input.Take();
                        if (m is WriteMessageCommand write)
                            Console.WriteLine(write.Message);
                        if (m is SaidCountEvent sc)
                            Console.WriteLine(
                                $"Counter   {sc.Count}   {sc.ActorId}"
                                );
                    }
                });
           }
   

   
   

8.         static void Main(string[] args)
           {
               var writerInput = new BlockingCollection<IMessage>();
               var firstInput = new BlockingCollection<IMessage>();
               var secondInput = new BlockingCollection<IMessage>();
               var writer = CreateWriterActor(writerInput);
             //       
               var firstCounter = CreateCounterActor(writerInput, firstInput, 1);
               var secondCounter = CreateCounterActor(writerInput, secondInput, 2);
               //       
               for (int i = 0; i < 5; i++)
               {
                   firstInput.Add(new IncrementCommand());
               }
               //       .
               for (int i = 0; i < 9; i++)
               {
                   secondInput.Add(new IncrementCommand());
               }
               //         .
               //      writer      
               firstInput.Add(new TellCountCommand());
               secondInput.Add(new TellCountCommand());
              // writer     .
               writerInput.Add(new WriteMessageCommand("  Main"));
               Console.ReadLine();
           }
   

   
   

    public interface ICounterActor
    {
        void Increment();
        void TellCount();
    }

    public class CounterActor : ICounterActor
    {
        private readonly Task _taks;
        private readonly BlockingCollection<IMessage> _input;
        private readonly BlockingCollection<IMessage> _output;

        public CounterActor(BlockingCollection<IMessage> output)
        {
            _input = new BlockingCollection<IMessage>(); ;
            _output = output;
            _taks = Task.Run(() =>
            {
                //State
                var count = 0;

                while (true)
                {
                    var m = _input.Take();
                    if (m is IncrementCommand)
                        count++;
                    if (m is TellCountCommand)
                        _output.Add(new SaidCountEvent(count, _taks.Id));
                }
            });
        }

        public void Increment()
        {
            _input.Add(new IncrementCommand());
        }

        public void TellCount()
        {
            _input.Add(new TellCountCommand());
        }
    }