当前位置: 首页 > 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 消息,如果超时会返回超时结果

相关文章:

  • 场景以及八股复习篇
  • 图像采集卡的核心功能功与应用详解
  • 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做题笔记
  • 时隔3年俄乌直接谈判今日有望重启:谁参加,谈什么
  • “80后”北京市东城区副区长王智勇获公示拟任区委常委
  • 云南威信麟凤镇通报“有人穿‘警察’字样雨衣参与丧事”:已立案查处
  • 多地警务新媒体整合:关停交警等系统账号,统一信息发布渠道
  • 训练孩子的科学思维,上海虹口推出“六个一百”旗舰工程
  • 长沙查处疑似非法代孕:有人企图跳窗,有女子被麻醉躺手术台