3.1 actor基本框架(c#的Akka.Actor模式)
1.最简单的一个框架
代码如下(代码容易理解):
using System;
using Akka.Actor;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Security.Cryptography.X509Certificates;namespace ConsoleApp11
{// 定义Actorpublic class MyActor:ReceiveActor{public MyActor(){// 定义接收消息的行为Receive<string>(message =>{// 定义接收消息的行为Console.WriteLine($"收到消息:{message}");});}}class Program{static void Main(string[] args){// 创建 Actor系统var actorSystem = ActorSystem.Create("MyActorSystem");// 创建一个Actorvar myActor = actorSystem.ActorOf<MyActor>("MyActor");// 向Actor 发送消息myActor.Tell("hello,actor!");// 停止 Actor 系统actorSystem.Terminate().Wait();}}
}
2.加入一个数据处理的功能
代码如下:
using System;
using Akka.Actor;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Security.Cryptography.X509Certificates;namespace ConsoleApp11
{public class MyActor : ReceiveActor { public MyActor() { Receive<string>(message => { Console.WriteLine($"Received: {message}"); // 输出: Received: 1}); }protected override void PreStart() => Console.WriteLine("Actor started"); //actor的重启, 输出: Actor startedprotected override void PostStop() => Console.WriteLine("Actor stopped"); //actor的停止, 输出: Actor stopped}// 添加信息获取和信息处理类public class cacus{public cacus() { }public double tt = 1; // 这里可以获取数据public double cas() // {return tt;}}class Program{static void Main(string[] args){// 1.创建 Actor系统var actorSystem = ActorSystem.Create("MyActorSystem");// 2.创建一个Actorvar myActor = actorSystem.ActorOf<MyActor>("MyActor");// 3.获得myActor的路径(每个myActor都有自己的路径)var actorPath = myActor.Path;Console.WriteLine($"Actor Path: {actorPath}"); // 输出: Actor Path: akka://MyActorSystem/user/MyActor// 4.向Actor 发送消息var st = new cacus();var ss = st.cas();string s1 = ss.ToString();myActor.Tell(s1);// 5.停止 Actor 系统actorSystem.Terminate().Wait();}}
}
运行结果如下:

3.两个actor同时运行
该内容看了博客C# Actor 如何理解和使用?-CSDN博客,作为笔记用。
以下是一个简单的例子,展示如何通过消息传递实现“A完成后再通知B执行”的逻辑。
1. 定义 Actor A 和 Actor B
- Actor A:完成任务后发送消息给Actor B。
- Actor B:接收到消息后执行自己的任务。
代码如下:
using System;
using Akka.Actor;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Security.Cryptography.X509Certificates;namespace ConsoleApp11
{// Actor Apublic class ActorA : ReceiveActor { private readonly IActorRef _actorB;public ActorA(IActorRef actorB) { _actorB = actorB; Receive<string>(message => { Console.WriteLine("Actor A is working..."); // 模拟任务完成Task.Delay(1000).Wait(); // 模拟耗时操作Console.WriteLine("Actor A has finished its task."); // 通知 Actor B_actorB.Tell("A has finished, B can start now."); });}} // Actor Bpublic class ActorB : ReceiveActor { public ActorB() { Receive<string>(message => {Console.WriteLine("Actor B received a message: " + message); Console.WriteLine("Actor B is working..."); // 模拟任务完成Task.Delay(1000).Wait(); // 模拟耗时操作Console.WriteLine("Actor B has finished its task."); }); } }class Program{static void Main(string[] args){//创建 ActorSystemvar system = ActorSystem.Create("MySystem"); // 创建 Actor Bvar actorB = system.ActorOf<ActorB>("actorB"); // 创建 Actor A,并传入 Actor B 的引用var actorA = system.ActorOf(Props.Create(() => new ActorA(actorB)), "actorA"); // 触发 Actor A 开始工作actorA.Tell("Start"); Console.ReadLine(); }}}
运行结果如下:

2.关键点
- 消息传递:Actor A完成任务后,通过
Tell方法发送消息给Actor B。 - 异步通信:Actor之间的通信是异步的,不会阻塞对方的执行。
- 解耦:Actor A和Actor B是完全独立的,它们之间没有直接的依赖,仅通过消息协作。
4.更复杂的协作
内容来自博客C# Actor 如何理解和使用?-CSDN博客,作为笔记用.
如果需要多个Actor协作(例如A -> B -> C),可以通过类似的方式实现:
- Actor A完成任务后通知Actor B。
- Actor B完成任务后通知Actor C。
代码如下:
using System;
using Akka.Actor;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Security.Cryptography.X509Certificates;namespace ConsoleApp11
{// Actor Apublic class ActorA : ReceiveActor { private readonly IActorRef _actorB;public ActorA(IActorRef actorB) { _actorB = actorB; Receive<string>(message => { Console.WriteLine("Actor A is working..."); // 模拟任务完成Task.Delay(1000).Wait(); // 模拟耗时操作Console.WriteLine("Actor A has finished its task."); // 通知 Actor B_actorB.Tell("A has finished, B can start now."); });}} // ctor B,使其完成任务后通知 Actor Cpublic class ActorB : ReceiveActor{ private readonly IActorRef _actorC;public ActorB(IActorRef actorC){ _actorC = actorC;Receive<string>(message => {Console.WriteLine("Actor B received a message: " + message); Console.WriteLine("Actor B is working..."); Task.Delay(1000).Wait(); // 模拟耗时操作Console.WriteLine("Actor B has finished its task."); // 通知Actor C _actorC.Tell("B has finished, C can start now."); }); }}// Actor Cpublic class ActorC : ReceiveActor {public ActorC(){ Receive<string>(message => { Console.WriteLine("Actor C received a message: " + message);Console.WriteLine("Actor C is working..."); Task.Delay(1000).Wait();// 模拟耗时操作Console.WriteLine("Actor C has finished its task."); });} } class Program{static void Main(string[] args){//创建 ActorSystemvar system = ActorSystem.Create("MySystem");// 创建 Actor Cvar actorC = system.ActorOf<ActorC>("actorC");// 创建 Actor B,并传入 Actor C 的引用var actorB = system.ActorOf(Props.Create(() => new ActorB(actorC)), "actorB");// 创建 Actor A,并传入 Actor B 的引用var actorA = system.ActorOf(Props.Create(() => new ActorA(actorB)), "actorA");// 触发 Actor A 开始工作actorA.Tell("Start"); Console.ReadLine();}}}
运行结果如下:

后续会继续更新
相关文章:
3.1 actor基本框架(c#的Akka.Actor模式)
1.最简单的一个框架 代码如下(代码容易理解): using System; using Akka.Actor; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Security.Cryptography.X509Certi…...
Git使用[同一电脑多个账户ssh-key的管理]
同一电脑多个账户ssh-key的管理 现在遇到一个问题,我同一台电脑既要通过VPN访问内网的git也要访问对外释放的gitee,刚开始我直接把原来的SSH-key添加到内网的gitlab发现可以访问,但是后来再方位外网的gitee就出问题了,看来要换一种手段才行 本文引用:https://cloud…...
使用Python结合`stable-baselines3`库(包含PPO和TD3算法)以及`gym`库来实现分层强化学习的示例代码
以下是一个使用Python结合stable-baselines3库(包含PPO和TD3算法)以及gym库来实现分层强化学习的示例代码。该代码将环境中的动作元组分别提供给高层处理器PPO和低层处理器TD3进行训练,并实现单独训练和共同训练的功能。 代码实现 import g…...
【论文笔记】MambaGlue: Fast and Robust Local Feature Matching With Mamba
【引用格式】:Ryoo K, Lim H, Myung H. MambaGlue: Fast and Robust Local Feature Matching With Mamba[J]. arXiv preprint arXiv:2502.00462, 2025. 【网址】:https://arxiv.org/pdf/2502.00462 【开源代码】:https://github.com/uri-Ka…...
基于 Stanford CoreNLP 的中文自然语言处理
一、概述 Stanford CoreNLP 是斯坦福大学开发的一款强大的自然语言处理(NLP)工具,支持多种语言的文本处理,包括中文。本文将详细介绍如何使用 Stanford CoreNLP 实现中文文本的分词、词性标注、命名实体识别、句法分析等功能&…...
python 量化交易入门到提升详细教程,python量化交易教程
文章目录 前言入门阶段1. 环境准备安装 Python选择开发环境安装必要的库 2. 金融数据获取3. 简单策略构建 - 移动平均线交叉策略 进阶阶段1. 策略回测2. 风险管理3. 多因子策略4. 机器学习在量化交易中的应用5. 高频交易策略 前言 Python 作为一门功能强大、易于学习且应用广泛…...
如何设置爬虫的访问频率?
设置爬虫的访问频率(即请求间隔)是确保爬虫稳定运行并避免对目标服务器造成过大压力的关键步骤。合理的访问频率不仅可以减少被目标网站封禁IP的风险,还能提高爬虫的效率。以下是一些设置爬虫访问频率的方法和最佳实践: 1. 使用s…...
前端循环全解析:JS/ES/TS 循环写法与实战示例
循环是编程中控制流程的核心工具。本文将详细介绍 JavaScript、ES6 及 TypeScript 中各种循环的写法、特性,并通过实际示例帮助你掌握它们的正确使用姿势。 目录 传统三剑客 for 循环 while 循环 do...while 循环 ES6 新特性 forEach for...of for...in 数组…...
大气体育直播模板赛事扁平自适应模板源码
源码名称:大气体育直播模板赛事网站源码 开发环境:帝国cms 7.5 安装环境:phpmysql 模板特点: 程序伪静态版本,实时采集更新,无人值守,省心省力。带火车头采集,可以挂着自动采集发布…...
vue3学习1
vite是新的官方构建工具,构建速度比webpack更快 vue项目的入口文件是index.html,一般在这里引入src/main.js,并且设置好容器#app App.vue放的是根组件,components里放分支组件 vue组件中写三种标签,template & s…...
java机器学习计算指标动态阈值
java机器学习计算指标动态阈值 最近听到有的人说要做机器学习就一定要学Python,我想他们掌握的知道还不够系统全面。本文作者以动态阈值需求场景给大家介绍几种常用Java实现的机器学习库,包括使用开源库如Weka或Deeplearning4j(DL4J…...
mac os设置jdk版本
打开环境变量配置文件 sudo vim ~/.bash_profile 设置不同的jdk版本路径 # 设置JAVA_HOME为jdk17路径 export JAVA_HOME$(/usr/libexec/java_home -v 17)# 设置JAVA_HOME为jdk8路径 export JAVA_HOME$(/usr/libexec/java_home -v 1.8) 设置环境变量 # 将jdk加入到环境变量…...
Python正则表达式学习
Python正则表达式全攻略 一、正则表达式基础 1. 什么是正则表达式? 用于描述字符串匹配规则的表达式广泛应用于文本处理、表单验证、数据清洗等领域 2. Python中的re模块 import re3. 基础语法 字符说明示例.匹配任意字符(除换行)a.c → abc\d数字 [0-9]\d\d …...
ShenNiusModularity项目源码学习(10:ShenNius.FileManagement项目分析)
ShenNiusModularity项目支持七牛云和本地图片存储,其文件上传接口及实现就位于ShenNius.FileManagement项目内,该项目内文件不多,主要就是围绕上传本地及七牛云的实现及相关类定义。 扩展类FileManagemenServiceExtensions的AddFileUploa…...
mysql查看binlog日志
mysql 配置、查看binlog日志: 示例为MySQL8.0 1、 检查binlog开启状态 SHOW VARIABLES LIKE ‘log_bin’; 如果未开启,修改配置my.ini 开启日志 安装目录配置my.ini(mysql8在data目录) log-binmysql-bin(开启日志并指定日志前缀ÿ…...
Node.js高频面试题精选及参考答案
目录 什么是 Node.js?它的主要特点有哪些? Node.js 的事件驱动和非阻塞 I/O 模型是如何工作的? 为什么 Node.js 适合处理高并发场景? Node.js 与传统后端语言(如 Java、Python)相比,有哪些优势和劣势? 简述 Node.js 的运行原理,包括 V8 引擎的作用。 什么是 Nod…...
TaskBuilder创建客户信息列表页面
3.4.1选择页面类型 点击上面创建的customer文件夹右侧的加号,打开“前端资源创建向导”对话框,选中“数据查询TFP”,资源名称会自动设置为index,这里我们不用改。 点“下一步”按钮,会弹出下图所示的“创建数据查询T…...
Linux Iptables示例一则
个人博客地址:Linux Iptables示例一则 | 一张假钞的真实世界 关于Iptables的介绍个人强烈推荐:iptables-朱双印博客-第2页。这位兄弟介绍的很详细。 我个人的需求是在同一个网络内从网络上把测试主机与正式环境主机间的网络进行隔离。我的思路是采用OU…...
新手小白如何挖掘cnvd通用漏洞之存储xss漏洞(利用xss钓鱼)
视频教程和更多福利在我主页简介或专栏里 (不懂都可以来问我 专栏找我哦) 如果对你有帮助你可以来专栏找我,我可以无偿分享给你对你更有帮助的一些经验和资料哦 目录: 一、XSS的三种类型: 二、XSS攻击的危害&#x…...
【CXX】4 跨平台构建系统特性对比
多语言构建系统选项为开发团队提供了灵活性和选择,以适应不同的项目需求和现有的技术栈。CXX作为一个设计灵活的工具,旨在与多种构建系统无缝集成。以下是对不同构建系统选项的简要概述和建议: 一、Cargo: 适用场景:…...
WEB3全栈开发——面试专业技能点P2智能合约开发(Solidity)
一、Solidity合约开发 下面是 Solidity 合约开发 的概念、代码示例及讲解,适合用作学习或写简历项目背景说明。 🧠 一、概念简介:Solidity 合约开发 Solidity 是一种专门为 以太坊(Ethereum)平台编写智能合约的高级编…...
Axios请求超时重发机制
Axios 超时重新请求实现方案 在 Axios 中实现超时重新请求可以通过以下几种方式: 1. 使用拦截器实现自动重试 import axios from axios;// 创建axios实例 const instance axios.create();// 设置超时时间 instance.defaults.timeout 5000;// 最大重试次数 cons…...
如何在最短时间内提升打ctf(web)的水平?
刚刚刷完2遍 bugku 的 web 题,前来答题。 每个人对刷题理解是不同,有的人是看了writeup就等于刷了,有的人是收藏了writeup就等于刷了,有的人是跟着writeup做了一遍就等于刷了,还有的人是独立思考做了一遍就等于刷了。…...
使用LangGraph和LangSmith构建多智能体人工智能系统
现在,通过组合几个较小的子智能体来创建一个强大的人工智能智能体正成为一种趋势。但这也带来了一些挑战,比如减少幻觉、管理对话流程、在测试期间留意智能体的工作方式、允许人工介入以及评估其性能。你需要进行大量的反复试验。 在这篇博客〔原作者&a…...
基于PHP的连锁酒店管理系统
有需要请加文章底部Q哦 可远程调试 基于PHP的连锁酒店管理系统 一 介绍 连锁酒店管理系统基于原生PHP开发,数据库mysql,前端bootstrap。系统角色分为用户和管理员。 技术栈 phpmysqlbootstrapphpstudyvscode 二 功能 用户 1 注册/登录/注销 2 个人中…...
为什么要创建 Vue 实例
核心原因:Vue 需要一个「控制中心」来驱动整个应用 你可以把 Vue 实例想象成你应用的**「大脑」或「引擎」。它负责协调模板、数据、逻辑和行为,将它们变成一个活的、可交互的应用**。没有这个实例,你的代码只是一堆静态的 HTML、JavaScript 变量和函数,无法「活」起来。 …...
关于uniapp展示PDF的解决方案
在 UniApp 的 H5 环境中使用 pdf-vue3 组件可以实现完整的 PDF 预览功能。以下是详细实现步骤和注意事项: 一、安装依赖 安装 pdf-vue3 和 PDF.js 核心库: npm install pdf-vue3 pdfjs-dist二、基本使用示例 <template><view class"con…...
Xela矩阵三轴触觉传感器的工作原理解析与应用场景
Xela矩阵三轴触觉传感器通过先进技术模拟人类触觉感知,帮助设备实现精确的力测量与位移监测。其核心功能基于磁性三维力测量与空间位移测量,能够捕捉多维触觉信息。该传感器的设计不仅提升了触觉感知的精度,还为机器人、医疗设备和制造业的智…...
pycharm 设置环境出错
pycharm 设置环境出错 pycharm 新建项目,设置虚拟环境,出错 pycharm 出错 Cannot open Local Failed to start [powershell.exe, -NoExit, -ExecutionPolicy, Bypass, -File, C:\Program Files\JetBrains\PyCharm 2024.1.3\plugins\terminal\shell-int…...
【Veristand】Veristand环境安装教程-Linux RT / Windows
首先声明,此教程是针对Simulink编译模型并导入Veristand中编写的,同时需要注意的是老用户编译可能用的是Veristand Model Framework,那个是历史版本,且NI不会再维护,新版本编译支持为VeriStand Model Generation Suppo…...
