Actor的目的是為了解決分布式編程中的一系列問題。所有消息都是異步交付的，因此將消息發(fā)送方與接收方分開，正是由于這種分離，導(dǎo)致actor系統(tǒng)具有內(nèi)在的并發(fā)性：可以不受限制地并行執(zhí)行任何擁有輸入消息的 actor。用Actor寫的程序可以不用管是怎么實(shí)現(xiàn)的，只用傳遞數(shù)據(jù)就可以，操作簡(jiǎn)單。當(dāng)然Actor的NB之處，還在于可以遠(yuǎn)程連接，像RPC一樣。下面的例子用的是Nuget中的【Akka】、遠(yuǎn)程的【Akka.Remote】

#Actor的特點(diǎn)

> 1. 系統(tǒng)由Actor構(gòu)成
> 2. Actor完全獨(dú)立
> 3. 消息傳遞是非阻塞和異步的
> 4. 所有消息都是并行的

#Actor使用

> 可以通過特定的Actor工具或直接使用編程語言實(shí)現(xiàn)Actor模型，目前C#語言中有兩類比較流行，Akka.NET框架和Orleans框架。
> 1. Akka是一個(gè)基于scala語言的Actor模型庫(kù)，旨在構(gòu)建一套高并發(fā)、分布式、自動(dòng)容錯(cuò)、消息驅(qū)動(dòng)應(yīng)用的工具集。
> 2. Orleans框架可以構(gòu)建大規(guī)模、高并發(fā)、分布式應(yīng)用程序，而不需要學(xué)習(xí)專業(yè)分布式以及并發(fā)知識(shí)框架。它是由微軟研究和設(shè)計(jì)應(yīng)用于云計(jì)算。

簡(jiǎn)單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(() => //異步發(fā)送數(shù)據(jù) {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($"當(dāng)前時(shí)間：{DateTime.Now.Ticks}, Name:{greet.Name}, Id:{greet.Id} ");});} }/// <summary> /// 用于傳遞消息的實(shí)體類 /// </summary> public class JasonMessage {public long Id { get; set; }public string Name { get; set; } }

遠(yuǎn)程Actor

/// <summary> /// 用于傳遞消息的實(shí)體類（公共類庫(kù)） /// </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 = tcpport = 0hostname = localhost}} } ");using (var system = ActorSystem.Create("MyClient", config)){var greeting = system.ActorSelection("akka.tcp://MyServer@localhost: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服務(wù)端 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 = tcpport = 51179hostname = 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($"當(dāng)前時(shí)間：{DateTime.Now.Ticks}, Name:{greet1.Name}, Id:{greet1.Id} ");}} }

?其他的分布式文章

.net core中的分布式緩存和負(fù)載均衡

轉(zhuǎn)載于:https://www.cnblogs.com/zhao123/p/11039836.html

總結(jié)

以上是生活随笔為你收集整理的Actor模型（分布式编程）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。