当前位置: 首页 > news >正文

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.关键点

  1. 消息传递:Actor A完成任务后,通过Tell方法发送消息给Actor B。
  2. 异步通信:Actor之间的通信是异步的,不会阻塞对方的执行。
  3. 解耦: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.最简单的一个框架 代码如下&#xff08;代码容易理解&#xff09;&#xff1a; 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就出问题了,看来要换一种手段才行 本文引用&#xff1a;https://cloud…...

使用Python结合`stable-baselines3`库(包含PPO和TD3算法)以及`gym`库来实现分层强化学习的示例代码

以下是一个使用Python结合stable-baselines3库&#xff08;包含PPO和TD3算法&#xff09;以及gym库来实现分层强化学习的示例代码。该代码将环境中的动作元组分别提供给高层处理器PPO和低层处理器TD3进行训练&#xff0c;并实现单独训练和共同训练的功能。 代码实现 import g…...

【论文笔记】MambaGlue: Fast and Robust Local Feature Matching With Mamba

【引用格式】&#xff1a;Ryoo K, Lim H, Myung H. MambaGlue: Fast and Robust Local Feature Matching With Mamba[J]. arXiv preprint arXiv:2502.00462, 2025. 【网址】&#xff1a;https://arxiv.org/pdf/2502.00462 【开源代码】&#xff1a;https://github.com/uri-Ka…...

基于 Stanford CoreNLP 的中文自然语言处理

一、概述 Stanford CoreNLP 是斯坦福大学开发的一款强大的自然语言处理&#xff08;NLP&#xff09;工具&#xff0c;支持多种语言的文本处理&#xff0c;包括中文。本文将详细介绍如何使用 Stanford CoreNLP 实现中文文本的分词、词性标注、命名实体识别、句法分析等功能&…...

python 量化交易入门到提升详细教程,python量化交易教程

文章目录 前言入门阶段1. 环境准备安装 Python选择开发环境安装必要的库 2. 金融数据获取3. 简单策略构建 - 移动平均线交叉策略 进阶阶段1. 策略回测2. 风险管理3. 多因子策略4. 机器学习在量化交易中的应用5. 高频交易策略 前言 Python 作为一门功能强大、易于学习且应用广泛…...

如何设置爬虫的访问频率?

设置爬虫的访问频率&#xff08;即请求间隔&#xff09;是确保爬虫稳定运行并避免对目标服务器造成过大压力的关键步骤。合理的访问频率不仅可以减少被目标网站封禁IP的风险&#xff0c;还能提高爬虫的效率。以下是一些设置爬虫访问频率的方法和最佳实践&#xff1a; 1. 使用s…...

前端循环全解析:JS/ES/TS 循环写法与实战示例

循环是编程中控制流程的核心工具。本文将详细介绍 JavaScript、ES6 及 TypeScript 中各种循环的写法、特性&#xff0c;并通过实际示例帮助你掌握它们的正确使用姿势。 目录 传统三剑客 for 循环 while 循环 do...while 循环 ES6 新特性 forEach for...of for...in 数组…...

大气体育直播模板赛事扁平自适应模板源码

源码名称&#xff1a;大气体育直播模板赛事网站源码 开发环境&#xff1a;帝国cms 7.5 安装环境&#xff1a;phpmysql 模板特点&#xff1a; 程序伪静态版本&#xff0c;实时采集更新&#xff0c;无人值守&#xff0c;省心省力。带火车头采集&#xff0c;可以挂着自动采集发布…...

vue3学习1

vite是新的官方构建工具&#xff0c;构建速度比webpack更快 vue项目的入口文件是index.html&#xff0c;一般在这里引入src/main.js&#xff0c;并且设置好容器#app App.vue放的是根组件&#xff0c;components里放分支组件 vue组件中写三种标签&#xff0c;template & s…...

java机器学习计算指标动态阈值

java机器学习计算指标动态阈值 最近听到有的人说要做机器学习就一定要学Python&#xff0c;我想他们掌握的知道还不够系统全面。本文作者以动态阈值需求场景给大家介绍几种常用Java实现的机器学习库&#xff0c;包括使用开源库如Weka或Deeplearning4j&#xff08;DL4J&#xf…...

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. 什么是正则表达式&#xff1f; 用于描述字符串匹配规则的表达式广泛应用于文本处理、表单验证、数据清洗等领域 2. Python中的re模块 import re3. 基础语法 字符说明示例.匹配任意字符(除换行)a.c → abc\d数字 [0-9]\d\d …...

ShenNiusModularity项目源码学习(10:ShenNius.FileManagement项目分析)

ShenNiusModularity项目支持七牛云和本地图片存储&#xff0c;其文件上传接口及实现就位于ShenNius.FileManagement项目内&#xff0c;该项目内文件不多&#xff0c;主要就是围绕上传本地及七牛云的实现及相关类定义。   扩展类FileManagemenServiceExtensions的AddFileUploa…...

mysql查看binlog日志

mysql 配置、查看binlog日志&#xff1a; 示例为MySQL8.0 1、 检查binlog开启状态 SHOW VARIABLES LIKE ‘log_bin’; 如果未开启&#xff0c;修改配置my.ini 开启日志 安装目录配置my.ini(mysql8在data目录) log-binmysql-bin&#xff08;开启日志并指定日志前缀&#xff…...

Node.js高频面试题精选及参考答案

目录 什么是 Node.js?它的主要特点有哪些? Node.js 的事件驱动和非阻塞 I/O 模型是如何工作的? 为什么 Node.js 适合处理高并发场景? Node.js 与传统后端语言(如 Java、Python)相比,有哪些优势和劣势? 简述 Node.js 的运行原理,包括 V8 引擎的作用。 什么是 Nod…...

TaskBuilder创建客户信息列表页面

3.4.1选择页面类型 点击上面创建的customer文件夹右侧的加号&#xff0c;打开“前端资源创建向导”对话框&#xff0c;选中“数据查询TFP”&#xff0c;资源名称会自动设置为index&#xff0c;这里我们不用改。 点“下一步”按钮&#xff0c;会弹出下图所示的“创建数据查询T…...

Linux Iptables示例一则

个人博客地址&#xff1a;Linux Iptables示例一则 | 一张假钞的真实世界 关于Iptables的介绍个人强烈推荐&#xff1a;iptables-朱双印博客-第2页。这位兄弟介绍的很详细。 我个人的需求是在同一个网络内从网络上把测试主机与正式环境主机间的网络进行隔离。我的思路是采用OU…...

新手小白如何挖掘cnvd通用漏洞之存储xss漏洞(利用xss钓鱼)

视频教程和更多福利在我主页简介或专栏里 &#xff08;不懂都可以来问我 专栏找我哦&#xff09; 如果对你有帮助你可以来专栏找我&#xff0c;我可以无偿分享给你对你更有帮助的一些经验和资料哦 目录&#xff1a; 一、XSS的三种类型&#xff1a; 二、XSS攻击的危害&#x…...

【CXX】4 跨平台构建系统特性对比

多语言构建系统选项为开发团队提供了灵活性和选择&#xff0c;以适应不同的项目需求和现有的技术栈。CXX作为一个设计灵活的工具&#xff0c;旨在与多种构建系统无缝集成。以下是对不同构建系统选项的简要概述和建议&#xff1a; 一、Cargo&#xff1a; 适用场景&#xff1a;…...

Vue记事本应用实现教程

文章目录 1. 项目介绍2. 开发环境准备3. 设计应用界面4. 创建Vue实例和数据模型5. 实现记事本功能5.1 添加新记事项5.2 删除记事项5.3 清空所有记事 6. 添加样式7. 功能扩展&#xff1a;显示创建时间8. 功能扩展&#xff1a;记事项搜索9. 完整代码10. Vue知识点解析10.1 数据绑…...

Linux 文件类型,目录与路径,文件与目录管理

文件类型 后面的字符表示文件类型标志 普通文件&#xff1a;-&#xff08;纯文本文件&#xff0c;二进制文件&#xff0c;数据格式文件&#xff09; 如文本文件、图片、程序文件等。 目录文件&#xff1a;d&#xff08;directory&#xff09; 用来存放其他文件或子目录。 设备…...

stm32G473的flash模式是单bank还是双bank?

今天突然有人stm32G473的flash模式是单bank还是双bank&#xff1f;由于时间太久&#xff0c;我真忘记了。搜搜发现&#xff0c;还真有人和我一样。见下面的链接&#xff1a;https://shequ.stmicroelectronics.cn/forum.php?modviewthread&tid644563 根据STM32G4系列参考手…...

【Zephyr 系列 10】实战项目:打造一个蓝牙传感器终端 + 网关系统(完整架构与全栈实现)

🧠关键词:Zephyr、BLE、终端、网关、广播、连接、传感器、数据采集、低功耗、系统集成 📌目标读者:希望基于 Zephyr 构建 BLE 系统架构、实现终端与网关协作、具备产品交付能力的开发者 📊篇幅字数:约 5200 字 ✨ 项目总览 在物联网实际项目中,**“终端 + 网关”**是…...

今日科技热点速览

&#x1f525; 今日科技热点速览 &#x1f3ae; 任天堂Switch 2 正式发售 任天堂新一代游戏主机 Switch 2 今日正式上线发售&#xff0c;主打更强图形性能与沉浸式体验&#xff0c;支持多模态交互&#xff0c;受到全球玩家热捧 。 &#x1f916; 人工智能持续突破 DeepSeek-R1&…...

Angular微前端架构:Module Federation + ngx-build-plus (Webpack)

以下是一个完整的 Angular 微前端示例&#xff0c;其中使用的是 Module Federation 和 npx-build-plus 实现了主应用&#xff08;Shell&#xff09;与子应用&#xff08;Remote&#xff09;的集成。 &#x1f6e0;️ 项目结构 angular-mf/ ├── shell-app/ # 主应用&…...

纯 Java 项目(非 SpringBoot)集成 Mybatis-Plus 和 Mybatis-Plus-Join

纯 Java 项目&#xff08;非 SpringBoot&#xff09;集成 Mybatis-Plus 和 Mybatis-Plus-Join 1、依赖1.1、依赖版本1.2、pom.xml 2、代码2.1、SqlSession 构造器2.2、MybatisPlus代码生成器2.3、获取 config.yml 配置2.3.1、config.yml2.3.2、项目配置类 2.4、ftl 模板2.4.1、…...

在 Spring Boot 中使用 JSP

jsp&#xff1f; 好多年没用了。重新整一下 还费了点时间&#xff0c;记录一下。 项目结构&#xff1a; pom: <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0" xmlns:xsi"http://ww…...

ubuntu22.04有线网络无法连接,图标也没了

今天突然无法有线网络无法连接任何设备&#xff0c;并且图标都没了 错误案例 往上一顿搜索&#xff0c;试了很多博客都不行&#xff0c;比如 Ubuntu22.04右上角网络图标消失 最后解决的办法 下载网卡驱动&#xff0c;重新安装 操作步骤 查看自己网卡的型号 lspci | gre…...

软件工程 期末复习

瀑布模型&#xff1a;计划 螺旋模型&#xff1a;风险低 原型模型: 用户反馈 喷泉模型:代码复用 高内聚 低耦合&#xff1a;模块内部功能紧密 模块之间依赖程度小 高内聚&#xff1a;指的是一个模块内部的功能应该紧密相关。换句话说&#xff0c;一个模块应当只实现单一的功能…...