后端微服务【免费下载链接】akka.netCanonical actor model implementation for .NET with local distributed actors in C# and F#.项目地址https://gitcode.com/gh_mirrors/ak/akka.net点击查看免费下载Actor 是 Akka.NET 中消息传递的基本单元而在一个可能跨越多台主机、多个 CLR 的分布式 Actor 系统中如何唯一定位一个 Actor、如何向它发送消息、如何按路径批量匹配一组 Actor 是理解整个框架的基石。本文以 Akka.NET 官方概念文档《Actor References, Paths and Addresses》为核心骨架结合 ActorRef.cs、ActorPath.cs、ActorSelection.cs 等仓库源码系统讲解 Actor 引用的类型体系、Actor 路径的语法与语义、逻辑路径与物理路径的区别以及ActorOf与ActorSelection两种获取引用方式的取舍。读完本文你将能准确解释任意一条形如akka://my-sys/user/service-a/worker1的路径能熟练运用通配符做批量消息投递也能理解为什么路径相同并不等于是同一个 Actor。上图展示了 Actor 系统内最重要的几个实体之间的关系Actor 路径由锚点anchor包含地址 路径元素组成路径元素对应从根守护者到目标 Actor 一路的父子监督链。什么是 Actor 引用Actor ReferenceActor 引用Actor Reference是ActorRef的一个子类型其首要职责是支持向它所代表的 Actor 发送消息。在 Akka.NET 中IActorRef接口定义了引用与消息发送的基本契约每个 Actor 都可以通过Self属性访问自己规范的本地的引用默认情况下该引用也会作为所有发送给其他 Actor 消息的发送者sender引用。反过来在处理消息的过程中Actor 可以通过Sender方法访问代表当前消息发送者的引用。在源码层面IActorRef 定义在 ActorRef.cs 中它继承自ICanTell即消息发送能力、IEquatableIActorRef引用相等比较、IComparableIActorRef可排序与ISurrogated可序列化。其核心成员只有一个public interface IActorRef : ICanTell, IEquatableIActorRef, IComparableIActorRef, ISurrogated, IComparable { /// summary /// The path of this actor. Can be used to extract information about whether or not this actor is local or remote. /// /summary ActorPath Path { get; } }也就是说一个引用通过它的Path承载了它在哪的全部信息而Tell/Forward/Ask等扩展方法则负责把消息送达。根据 Actor 系统配置的不同Akka.NET 支持多种类型的 Actor 引用纯本地引用purely local用于未配置网络功能的 Actor 系统。这类引用一旦被通过网络发送到远端 CLR 将无法工作因为它不包含协议与远程地址信息。启用远程时的本地引用local with remoting用于支持网络功能的 Actor 系统代表同一 CLR 内的 Actor。为了让引用发送到其他网络节点后依然可达这些引用会携带协议和远程寻址信息。路由器的本地引用子类型router逻辑结构与上述本地引用相同但向其发送消息会直接分发dispatch给它的某个子 Actor。远程引用remote代表可通过远程通信到达的 Actor。向它发送消息会透明地序列化消息并发送到远端 CLR。源码中的实现类是 RemoteActorRef其IsLocal恒为false构造时会校验路径地址必须具有全局作用域否则抛出ArgumentException。若干行为上等同于本地引用的特殊引用PromiseActorRefTask的一种特殊表示目的是让 Actor 的响应来完成该Task。ICanTell.Ask会创建这种引用。其实现位于 Futures.cs它通过向/temp路径注册唯一临时路径把一次Ask包装成一个可被 Actor 回信的临时收件人。DeadLetterActorRef死信服务的默认实现Akka 会把所有发送给已停止或不存在的 Actor 的消息路由到这里。实现见 BuiltInActors.cs它继承自EmptyLocalActorRef将未处理消息作为DeadLetter发布到EventStream。EmptyLocalActorRef当查找一个不存在的本地 Actor 路径时返回的引用。它等价于DeadLetterActorRef但保留了路径本身这样 Akka 可以把它发送到网络上并与该路径此前可能获取到的其他引用做比较。实现见 EmptyLocalActorRef.cs。一些用户永远不应该见到的内部一次性实现一个不代表任何 Actor、仅作为根守护者伪监督者的引用文档中戏称为 the one who walks the bubbles of space-time对应源码中的RootGuardianSupervisor。第一个日志服务在 Actor 创建设施真正启动前存在一个接受日志事件并直接打印到标准输出的假 Actor 引用即Logging.StandardOutLogger。什么是 Actor 路径Actor Path由于 Actor 严格按照层级方式创建沿着子 → 父的监督链递归回溯到 Actor 系统的根会得到一条唯一的 Actor 名字序列。这条序列在概念上很像文件系统中层层嵌套的文件夹因此 Akka 借用路径path一词来称呼它——尽管 Actor 层级与文件系统层级存在本质差异。一条 Actor 路径由两部分组成锚点anchor标识 Actor 系统路径元素path elements从根守护者到目标 Actor 的拼接各元素之间用斜杠/分隔。在源码中ActorPath 是一个抽象类其子类RootActorPath深度为 0与ChildActorPath深度大于 0通过Parent指针串成一条链表并暴露Address、Name、Uid、Elements、Depth等只读属性。Elements按从根到当前节点的顺序返回各段名字ToString()输出带地址的完整路径ToStringWithoutAddress()则只输出从/开始的元素部分例如/user/a/b。引用与路径的本质区别Actor 引用指向单个 Actor其生命周期与对应 Actor 的生命周期一致Actor 路径代表一个名字该名字下可能居住着 Actor也可能没有路径本身没有生命周期永远不会失效。你可以只创建一条 Actor 路径而不创建 Actor但无法不创建 Actor 就得到一个对应它的引用。更关键的是你可以创建一个 Actor终止它然后用相同路径再创建一个新 Actor。新 Actor 是旧 Actor 的新化身incarnation两者不是同一个 Actor。指向旧化身的引用对新化身无效——即使路径相同发给旧引用的消息也绝不会投递到新化身。这正对应 ActorRef.cs 中ActorRefBase.Equals的实现两个引用相等必须同时满足Path.Uid相等并且Path相等——Uid就是区分化身的唯一标识。路径锚点Actor Path Anchors每条 Actor 路径都包含一个地址address组件描述对应 Actor 的协议与物理位置其后是从根开始的 Actor 名字层级。例如akka://my-sys/user/service-a/worker1 // 纯本地 akka.tcp://my-syshost.example.com:5678/user/service-b // 远程这里akka.tcp是示例中的默认远程传输其他传输是可插拔的例如使用 UDP 的远端主机可通过akka.udp访问。主机与端口部分即示例中的host.example.com:5678的具体解释取决于所使用的传输机制但必须符合 URI 的结构规则。地址在源码中由 sealed 类 Address 表示包含四个字段Protocol、SystemActor 系统名、Host、Port。Address还提供了两个语义判断属性HasLocalScopeHost为空即仅在本地有效不能安全地发送给远端主机HasGlobalScopeHost非空可以安全地跨主机发送因为它全局唯一标识了一个可寻址实体。Address.ToString()的拼接逻辑Address.cs正是我们看到的protocol://systemhost:port或protocol://system两种形态。逻辑 Actor 路径Logical Actor Paths沿着父子监督链回溯到根守护者所得到的唯一路径称为逻辑路径。它与 Actor 的创建谱系完全一致因此只要 Actor 系统的远程配置以及随之确定的路径地址组件确定逻辑路径就是完全确定的。物理 Actor 路径Physical Actor Paths逻辑路径描述的是在一个 Actor 系统内部的职能位置但基于配置的远程部署remote deployment意味着一个 Actor 可能被创建在与父 Actor 不同的网络主机上——即不同的 Actor 系统内。此时若仍沿逻辑路径从根守护者一路回溯就需要穿越网络代价高昂。因此每个 Actor 还有一个物理路径从真实 Actor 对象所在 Actor 系统的根守护者开始。当查询其他 Actor 时如果用物理路径作为 sender 引用对方就能直接回复到这个 Actor从而最小化路由带来的延迟。一个重要的特征是物理路径永远不会跨越多个 Actor 系统或 CLR。这意味着当某个祖先被远程监督时Actor 的逻辑路径监督层级与物理路径部署位置可能发生分歧。路径别名或符号链接如同某些真实文件系统你可能会想到为 Actor 建立路径别名或符号链接让一个 Actor 可以通过多条路径访问。但请务必注意Actor 层级与文件系统层级是不同的你不能像创建符号链接那样自由地为任意 Actor 创建路径。正如逻辑路径与物理路径所说明的一条 Actor 路径要么是代表监督层级的逻辑路径要么是代表部署位置的物理路径仅此而已。如何获取 Actor 引用获取 Actor 引用有两大类途径创建 Actor与查找 Actor后者又分为由具体路径构造引用与查询逻辑 Actor 层级两种形态。创建 ActorCreating Actors一个 Actor 系统通常这样启动先用ActorSystem.ActorOf在守护者之下创建 Actor再在已创建的 Actor 内部用ActorContext.ActorOf繁衍 Actor 树。这两个方法都返回新建 Actor 的引用。每个 Actor 通过其ActorContext直接访问父、自身与子 Actor 的引用这些引用可以放进消息中发送给其他 Actor使对方能够直接回复。从源码看ActorSystemImpl.ActorOfActorSystemImpl.cs最终调用_provider.Guardian.Cell.AttachChild(props, false, name)把新 Actor 作为用户守护者/user的直接子级挂载而ActorCell.ActorOfActorCell.Children.cs则负责在其父上下文中繁衍子级。按具体路径查找 ActorLooking up Actors by Concrete Path此外还可以用ActorSystem.ActorSelection方法按路径查找引用。Selection选择可用于与该 Actor 通信并且在每次投递消息时才解析该选择对应的 Actor。若要获得一个与某个具体 Actor 生命周期绑定的ActorRef需要向该 Actor 发送消息——例如内置的Identify消息——然后使用回复中的Sender引用。绝对路径与相对路径Absolute vs. Relative Paths除了ActorSystem.ActorSelection还有ActorContext.ActorSelection在任意 Actor 内部写作Context.ActorSelection。它生成的 selection 与ActorSystem上的孪生方法类似但解析起点不是 Actor 树的根而是当前 Actor。路径元素中可用两个点..访问父 Actor。例如向某个兄弟 Actor 发消息Context.ActorSelection(../brother).Tell(msg);当然在 context 上以通常方式查找绝对路径也可以例如Context.ActorSelection(/user/serviceA).Tell(msg);会如预期般工作。这一逻辑在 ActorRefFactoryShared.cs 中实现路径以/开头时视为绝对路径锚定到provider.RootGuardian若字符串是格式良好的完整 URI则解析地址并锚定到provider.RootGuardianAt(actorPath.Address)否则视为相对路径锚定到调用者传入的lookupRoot即当前 Actor。查询逻辑 Actor 层级Querying the Logical Actor Hierarchy由于 Actor 系统形成了类似文件系统的层级路径匹配可以采用与 Unix shell 相同的方式用通配符*与?替换部分路径元素名构造一个可能匹配零个或多个实际 Actor 的选择。因为结果不是单个 Actor 引用所以类型不同——ActorSelection——并且不支持IActorRef的全部操作。Selection 可用ActorSystem.ActorSelection与IActorContext.ActorSelection构造并支持发送消息Context.ActorSelection(../*).Tell(msg);这段代码会把msg发送给所有兄弟 Actor包括当前 Actor 自己。在 ActorSelection.cs 的构造函数中路径元素被分类解析..→SelectParent父级含*或?的元素 →SelectChildPattern按模式匹配子级**→SelectChildRecursive递归匹配所有后代只能出现在路径末尾否则抛出IllegalActorNameException其余普通名字 →SelectChildName。投递时DeliverSelectionActorSelection.cs会从锚点出发逐段解析普通名字调用GetSingleChild获取子引用模式匹配会对所有子 Actor 名字做Like(pattern)匹配并扇出fan-out..则回溯到父引用若某段解析不到 Actor 且非通配扇出则构造一个EmptyLocalActorRef并投递最终落入死信。ActorSelection.ResolveOne(timeout)ActorSelection.cs是由选择解析为单一引用的便捷入口它内部通过AskActorIdentity(new Identify(null), timeout)与目标 Actor 通信验证其存在超时或不存在则抛出ActorNotFoundException。仓库中的 ActorSelectionSpec.cs 对绝对路径、相对路径、..回溯以及通配符扇出都有完整的测试覆盖。小结ActorOfvs.ActorSelection[!NOTE] 以上各节所述内容可以浓缩并方便地记忆为ActorOf只创建新 Actor并且把它创建为调用该方法所在 context可以是任意 Actor 或 Actor 系统的直接子级。ActorSelection只在消息投递时查找已有 Actor即它既不创建 Actor也不在创建 selection 时验证 Actor 是否存在。Actor 引用与路径的相等性ActorRef的相等性语义与引用对应目标 Actor 的化身这一意图一致两个引用相等的条件是路径相同并且指向同一个 Actor 化身。指向已终止 Actor 的引用与指向同路径下另一个重新创建的Actor 的引用不相等。注意Actor 因故障触发的重启仍然意味着它是同一个化身——对ActorRef的使用者来说重启是不可见的。源码层面ActorRefBase.EqualsActorRef.cs正是按Path.Uid other.Path.Uid Path.Equals(other.Path)判等的GetHashCode也同时混合了Path.Uid与Path的哈希。如果你需要在集合中跟踪 Actor 引用但不关心具体化身可以用ActorPath作为键——因为路径比较时不会考虑目标 Actor 的唯一标识。这一点在 ActorPath.cs 的ActorPath.Equals实现中有明确体现比较只涉及地址与各层名字不涉及Uid。复用 Actor 路径Reusing Actor Paths当一个 Actor 被终止后它的引用会指向死信邮箱dead letter mailboxDeathWatch会发布它的最终状态转变Terminated一般情况下它不会再复活Actor 生命周期不允许这样做。虽然由于无法在技术上强制禁止同名重建除非保留所有曾创建 Actor 的集合代价过高在稍后时间用完全相同的路径创建 Actor 是可能的但这不是良好实践使用ActorSelection发送给已死亡 Actor 的消息会突然又开始生效而且这一转变与其他事件之间没有任何顺序保证——路径的新住户可能收到原本发给前任住户的消息。在非常特定的场景下这样做或许是合适的但请务必把这一处理严格限制在 Actor 的**监督者supervisor**内因为只有监督者才能可靠地探测到名字的正式注销de-registration在注销完成之前创建同名的子 Actor 会失败。测试中也可能需要这样做——当被测对象依赖在特定路径上被实例化时。此时最好的做法是 mock 其监督者让它把Terminated消息转发到测试流程中的合适位置使测试能够等待名字正式注销后再重建。与远程部署的交互The Interplay with Remote Deployment当一个 Actor 创建子级时Actor 系统的 deployer 会决定新 Actor 位于同一 CLR 还是另一节点。若是后者创建动作将通过网络连接在另一个 CLR因而也是另一个 Actor 系统中触发。远程系统会把新 Actor 放在一个为此保留的特殊路径之下而新 Actor 的监督者将是一个远程 Actor 引用代表触发其创建的 Actor。在这种情况下context.parent监督者引用与context.path.parentActor 路径中的父节点不代表同一个 Actor但在监督者内查找子级名字仍能在远程节点上找到它——例如在向未解析的 Actor 引用发消息时逻辑结构依然得以保留。在源码中远程部署由RemoteActorRefProvider实现RemoteActorRefProvider.cs它注册了一个名为remote的顶层名字对应RemoteSystemDaemon位于RootPath / remote远程创建的 Actor 全部挂在其下RemoteActorRef.GetChildRemoteActorRef.cs则负责在远端路径上继续解析子级。地址部分的作用What Is the Address Part Used For?当 Actor 引用被发送到网络上时它由自己的路径表示。因此路径必须完整编码发送消息所需的全部信息——这正是通过在路径字符串的地址部分编码协议、主机与端口实现的。当一个 Actor 系统从远端节点收到一条 Actor 路径时它会检查该路径的地址是否与本 Actor 系统的地址匹配匹配 → 解析为该 Actor 的本地引用不匹配 → 用远程 Actor 引用表示它。Actor 路径的顶层作用域Top-Level Scopes for Actor Paths路径层级的最顶端是根守护者root guardian所有其他 Actor 都在它之下其名字为/。下一层由以下作用域组成作用域用途/user所有用户创建的顶层 Actor 的守护者用ActorSystem.ActorOf创建的 Actor 都在它之下/system所有系统创建的顶层 Actor 的守护者例如日志监听器、或由配置在 Actor 系统启动时自动部署的 Actor/deadLetters死信 Actor所有发送给已停止或不存在的 Actor 的消息都会被重新路由到这里尽力而为即使在本地 CLR 内消息也可能丢失/temp所有短生命周期系统创建 Actor 的守护者例如用于实现ActorRef.Ask的临时 Actor/remote一个人为构造的路径所有监督者为远程 Actor 引用的 Actor 都位于其下这一命名空间结构源于一个核心而简单的设计目标层级中的一切都是 Actor且所有 Actor 以相同方式运转。因此你不仅能查找自己创建的 Actor还能查找系统守护者并向它发送消息此时它会有意地丢弃。这一强有力原则意味着没有需要记忆的特殊例外使整个系统更加统一与一致。源码中的印证LocalActorRefProvider构造时ActorRefProvider.cs以new RootActorPath(new Address(akka, systemName))建立根路径创建_rootPath / deadLetters的死信引用与_rootPath / temp的临时节点随后分别以CreateUserGuardian(_rootGuardian, user)与CreateSystemGuardian(_rootGuardian, system, _userGuardian)创建用户与系统守护者ActorRefProvider.cs。RootGuardianActorRef.GetSingleChildRootGuardianActorRef.cs专门处理temp与deadLetters两个内置名字其余名字回落到普通子级查找。/temp下的临时 Actor 名字由原子计数器生成并做 Base64 编码保证全局唯一GetNextTempNameActorRefProvider.cs。/remote由远程 Provider 通过RegisterExtraName(remote, internals.RemoteDaemon)注册RemoteActorRefProvider.cs。如果你想进一步了解 Actor 系统的顶层结构可以阅读仓库中的 The Top-Level Supervisors 一节以及作为本文前提的 Actor Systems 概念文档。结语把寻址当作理解 Akka.NET 的地图Actor 引用ActorRef是活的——绑定具体化身Actor 路径ActorPath是死的——只是一个永不失效的名字而 Actor 选择ActorSelection是二者的桥梁——它用路径语法表达我想要谁在每次投递时动态解析。掌握了akka://system/user/...的锚点语义、*/?/**/..的匹配规则、逻辑路径与物理路径的分野以及/user、/system、/deadLetters、/temp、/remote五大顶层作用域你就拥有了一张完整的 Akka.NET 分布式寻址地图——无论是本地单体应用还是跨节点集群消息投递、远程部署、死信排查都建立在这套统一模型之上。赞分享后端微服务【免费下载链接】akka.netCanonical actor model implementation for .NET with local distributed actors in C# and F#.项目地址https://gitcode.com/gh_mirrors/ak/akka.net点击查看免费下载相关推荐POINTS-Seeker部署指南从本地安装到云端服务的完整方案POINTS Seeker部署指南从本地安装到云端服务的完整方案 POINTS Seeker是一款功能强大的AI模型工具本指南将为您提供从本地环境搭建到云端Akka.NET中的Actor模型核心概念与实现原理Akka.NET中的Actor模型核心概念与实现原理 引言 在分布式系统开发中如何优雅地处理并发和容错一直是开发者面临的挑战。Akka.NET作为.NET平后端微服务Akka.NET 依赖注入实战指南从 Akka.DependencyInjection 到 Actor 生命周期管理Akka.NET 依赖注入实战指南从 Akka.DependencyInjection 到 Actor 生命周期管理 本文围绕 Akka.NET 官方推荐的依后端微服务创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考