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

ET ProcessInnerSender类(实体) 分析

ProcessInnerSender

  • 作用是进程内部发送Actor消息

字段

  • TIMEOUT_TIME 超时时间
  • RpcId 用来累加
  • requestCallback 存储RPC的回调事件
  • list 用来获取MessageQueue中的Actor消息

方法

  • Awake 初始化在MessageQueue中注册待处理的消息队列
  • Destroy 移除在MessageQueue中的消息队列
  • Update 获取MessageQueue中的待处理消息,处理消息
  • HandleMessage 处理Actor消息, 如果消息类型是Rpc的响应则执行HandleIActorResponse。否则找到Actor的MailBox,如果没有MailBox Reply(回复)ERR_NotFoundActor的错误,如果找到MailBox, 则根据MailBox 类型,分发消息处理。
  • HandleIActorResponse 回复一个Rpc消息结果
  • Reply 回复一条消息,跟发送没区别
  • Send 发送一条Actor消息。
  • SendInner 发送一条消息,实际就是添加到MessageQueue消息队列中,等待Update读取消息后进行处理
  • GetRpcId 获取一个rpcid
  • Call 发送一条Rpc 消息,如果超时会返回超时结果
http://www.dtcms.com/a/191228.html

相关文章:

  • 场景以及八股复习篇
  • 图像采集卡的核心功能功与应用详解
  • MQ防重复消费----去重表结合 Spring AOP 切面编程,抽象封装成通用幂等注解
  • Maplibgre-gl 学习1 初识
  • Maven构建流程详解:如何正确管理微服务间的依赖关系-当依赖的模块更新后,我应该如何重新构建主项目
  • ET MessageSender类(实体)分析
  • 第二十八节:直方图处理- 直方图计算与绘制
  • 智能化双语LaTeX系统,分阶段系统性开发技术实现路径:目标是实现语义级编译和认知增强写作,推动跨文明知识表达
  • stm32之FLASH
  • 嵌入式学习笔记 D20 :单向链表的基本操作
  • 黑马k8s(六)
  • Spring MVC数据绑定和响应 你了解多少?
  • 如何处理瀚高数据库与PG的冲突
  • nginx报错-[emerg] unknown directive “echo_reset_timer“
  • 【评测】免费体验dify工作流模式下腾讯语音转文字speech2text服务
  • 局部放电在线监测系统的数据传输协议选择研究:Modbus TCP 与 MQTT
  • libmemcached库api接口讲解五
  • 学习黑客NFC技术详解
  • day25 python异常处理
  • Leetcode209做题笔记
  • 常用的Java工具库
  • 【大模型面试每日一题】Day 18:大模型中KV Cache的作用是什么?如何通过Window Attention优化其内存占用?
  • AIX环境ORACLE RAC节点无法加入集群问题分析
  • Windows更新暂停七天关键注册表
  • centos中postfix的作用
  • 基于多目标进化算法的神经网络架构搜索及其高级可视化技术
  • Spring的Validation,这是一套基于注解的权限校验框架
  • 视网膜屏幕:重新定义数字显示的革命性技术
  • Windows系统Anaconda/Miniconda的安装、配置、基础使用、清理缓存空间和Pycharm/VSCode配置指南
  • 打破边界,智评未来:AI如何重塑学科交叉融合的评价体系?