Actor模型

Posted 2022-01-18 zhao123

#Actor模型

Actor的目的是为了解决分布式编程中的一系列问题。所有消息都是异步交付的，因此将消息发送方与接收方分开，正是由于这种分离，导致actor系统具有内在的并发性：可以不受限制地并行执行任何拥有输入消息的 actor。用Actor写的程序可以不用管是怎么实现的，只用传递数据就可以，操作简单。当然Actor的NB之处，还在于可以远程连接，像RPC一样。下面的例子用的是Nuget中的【Akka】、远程的【Akka.Remote】

#Actor的特点

> 1. 系统由Actor构成
> 2. Actor完全独立
> 3. 消息传递是非阻塞和异步的
> 4. 所有消息都是并行的

#Actor使用

> 可以通过特定的Actor工具或直接使用编程语言实现Actor模型，目前C#语言中有两类比较流行，Akka.NET框架和Orleans框架。
> 1. Akka是一个基于scala语言的Actor模型库，旨在构建一套高并发、分布式、自动容错、消息驱动应用的工具集。
> 2. Orleans框架可以构建大规模、高并发、分布式应用程序，而不需要学习专业分布式以及并发知识框架。它是由微软研究和设计应用于云计算。

简单Actor例子

public class ActorDemo

    public static void Test()
    
        var system = ActorSystem.Create("test");
        var greeter = system.ActorOf<JasonActor>("jason");

        for (int i = 0; i < 100; i++) 
            Task.Run(() =>  //异步发送数据
            
                var id = Math.Abs(Guid.NewGuid().GetHashCode());
                greeter.Tell(new JasonMessage()  Id = id, Name = $"DateTime.Now.Ticks id  i  " );
            );
        
    


/// <summary>
/// Actor可接受消息处理
/// </summary>
public class JasonActor : ReceiveActor 
    public JasonActor() 
        Receive<JasonMessage>(greet => 
            Console.WriteLine($"当前时间：DateTime.Now.Ticks, Name:greet.Name, Id:greet.Id ");
        );
    


/// <summary>
/// 用于传递消息的实体类
/// </summary>
public class JasonMessage 
    public long Id  get; set; 
    public string Name  get; set; 

远程Actor

/// <summary>
/// 用于传递消息的实体类（公共类库）
/// </summary>
public class JasonMessage

    public long Id  get; set; 
    public string Name  get; set; 

//Actor客户端
namespace AkkaClient

    class Program
    
        static void Main(string[] args)
        
            var config = ConfigurationFactory.ParseString(@"
akka   
    actor 
        provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
    
    remote 
        helios.tcp 
            transport-class = ""Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote""
            applied-adapters = []
            transport-protocol = tcp
            port = 0
            hostname = localhost
        
    

");

            using (var system = ActorSystem.Create("MyClient", config))
            
                var greeting = system.ActorSelection("akka.tcp://[email protected]:51179/user/Greeting");

                while (true)
                
                    var input = Console.ReadLine();
                    if (input != "exit")
                    
                        var id = Math.Abs(Guid.NewGuid().GetHashCode());
                        greeting.Tell(new JasonMessage()  Id = id, Name = $"DateTime.Now input " );
                    
                    else
                    
                        break;
                    

                
            

            Console.WriteLine("Hello World!");
        
    

//Actor服务端
namespace ServerAkka

    class Program
    
        static void Main(string[] args)
        
            var config = ConfigurationFactory.ParseString(@"
akka   
    actor 
        provider = ""Akka.Remote.RemoteActorRefProvider, Akka.Remote""
    
    remote 
        helios.tcp 
            transport-class = ""Akka.Remote.Transport.Helios.HeliosTcpTransport, Akka.Remote""
            applied-adapters = []
            transport-protocol = tcp
            port = 51179
            hostname = localhost
        
    

");

            using (var system = ActorSystem.Create("MyServer", config))
            
                system.ActorOf<JasonActor>("Greeting");

                Console.ReadLine();
            

            Console.WriteLine("Hello World!");
        
    

    public class JasonActor : UntypedActor
    
        protected override void OnReceive(object greet)
        
            var greet1 = (JasonMessage)greet;
            Console.WriteLine($"当前时间：DateTime.Now.Ticks, Name:greet1.Name, Id:greet1.Id ");