ET框架学习——消息系统之一

2024-04-16 21:58
文章标签 系统 学习 框架 消息 et

本文主要是介绍ET框架学习——消息系统之一,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

       OpcodeTypeComponent组件和MessageDispatherComponent组件都是消息系统的组成部分。这里就来好好捋一捋ET的消息系统。从我目前看到现在来说,这个消息系统包括一系列的事件接口,特性,和消息类型的识别码等等部分,这里先撇开前后端通讯部分的消息。

  • 消息系统中的抽象类,接口

public interface IMHandler
{void Handle(Session session, object message);Type GetMessageType();
}

        IMHandler接口是一个比较基本的接口,可以看到其内部有一个Hadle方法和一个GetMessageType方法。Handle方法接受Sessionobject两个类型的参数。这两个方法在MessageDispatherComponent类中都被执行了,具体可以看我的这篇文章。

public abstract class AMHandler<Message> : IMHandler where Message: class
{protected abstract void Run(Session session, Message message);public void Handle(Session session, object msg){Message message = msg as Message;if (message == null){Log.Error($"消息类型转换错误: {msg.GetType().Name} to {typeof(Message).Name}");return;}if (session.IsDisposed){Log.Error($"session disconnect {msg}");return;}this.Run(session, message);}public Type GetMessageType(){return typeof(Message);}
}

       AMHandler抽象类内部有一个抽象方法Run和一个Handle方法,Handle方法会在判断消息内部不为空后执行Run方法。Module层和Hotfix层,Handle的调用时机不是尽然相同的,Module层是在Module.Session中调用,Hotfix层是在Hotfix.Session中调用。该类的作用在于将接受服务端消息的方法,包装成类,配合MessageHandlerAttribute特性来做一个区分,便于反射来收集。

public interface IRequest: IMessage
{int RpcId { get; set; }
}public interface IResponse : IMessage
{int Error { get; set; }string Message { get; set; }int RpcId { get; set; }
}

       IMessage接口是一个空接口,可以不用理会,两个接口都实现了IMessage接口。单单从接口名字上来看,IRequest接口应该使用与请求消息的,里面一个RpcId的属性。IResponse接口是响应消息的,定义了Error错误码属性,Message消息内容属性,RpcId属性。

public interface IMessageDispatcher
{void Dispatch(Session session, ushort opcode, object message);
}

      IMessageDispatcher接口,应该是用于派发消息的接口。里面有一个派发消息的方法Dispatch

  • 消息系统中的特性

public class MessageAttribute: BaseAttribute
{public ushort Opcode { get; }public MessageAttribute(ushort opcode){this.Opcode = opcode;}
}

       MessageAttribute特性中有一个Opcode,这是为特性修饰的类分配的消息类型的识别码,在指定特性的时候会直接分配。

public class MessageHandlerAttribute : BaseAttribute
{public AppType Type { get; }public MessageHandlerAttribute(){}public MessageHandlerAttribute(AppType appType){this.Type = appType;}
}

       MessageHandlerAttribute特性中有一个AppType类型的Type值,AppType是一个枚举,具体可以自己去看看,这个枚举使用了Flags特性,关于该特性,可以看这篇文章。

 

这篇关于ET框架学习——消息系统之一的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/910004

相关文章

Linux系统中查询JDK安装目录的几种常用方法

《Linux系统中查询JDK安装目录的几种常用方法》:本文主要介绍Linux系统中查询JDK安装目录的几种常用方法,方法分别是通过update-alternatives、Java命令、环境变量及目... 目录方法 1:通过update-alternatives查询(推荐)方法 2:检查所有已安装的 JDK方

Linux系统之lvcreate命令使用解读

《Linux系统之lvcreate命令使用解读》lvcreate是LVM中创建逻辑卷的核心命令,支持线性、条带化、RAID、镜像、快照、瘦池和缓存池等多种类型,实现灵活存储资源管理,需注意空间分配、R... 目录lvcreate命令详解一、命令概述二、语法格式三、核心功能四、选项详解五、使用示例1. 创建逻

Python Web框架Flask、Streamlit、FastAPI示例详解

《PythonWeb框架Flask、Streamlit、FastAPI示例详解》本文对比分析了Flask、Streamlit和FastAPI三大PythonWeb框架:Flask轻量灵活适合传统应用... 目录概述Flask详解Flask简介安装和基础配置核心概念路由和视图模板系统数据库集成实际示例Stre

Olingo分析和实践之OData框架核心组件初始化(关键步骤)

《Olingo分析和实践之OData框架核心组件初始化(关键步骤)》ODataSpringBootService通过初始化OData实例和服务元数据,构建框架核心能力与数据模型结构,实现序列化、URI... 目录概述第一步:OData实例创建1.1 OData.newInstance() 详细分析1.1.1

RabbitMQ消息总线方式刷新配置服务全过程

《RabbitMQ消息总线方式刷新配置服务全过程》SpringCloudBus通过消息总线与MQ实现微服务配置统一刷新,结合GitWebhooks自动触发更新,避免手动重启,提升效率与可靠性,适用于配... 目录前言介绍环境准备代码示例测试验证总结前言介绍在微服务架构中,为了更方便的向微服务实例广播消息,

使用Python构建一个高效的日志处理系统

《使用Python构建一个高效的日志处理系统》这篇文章主要为大家详细讲解了如何使用Python开发一个专业的日志分析工具,能够自动化处理、分析和可视化各类日志文件,大幅提升运维效率,需要的可以了解下... 目录环境准备工具功能概述完整代码实现代码深度解析1. 类设计与初始化2. 日志解析核心逻辑3. 文件处

golang程序打包成脚本部署到Linux系统方式

《golang程序打包成脚本部署到Linux系统方式》Golang程序通过本地编译(设置GOOS为linux生成无后缀二进制文件),上传至Linux服务器后赋权执行,使用nohup命令实现后台运行,完... 目录本地编译golang程序上传Golang二进制文件到linux服务器总结本地编译Golang程序

Linux系统性能检测命令详解

《Linux系统性能检测命令详解》本文介绍了Linux系统常用的监控命令(如top、vmstat、iostat、htop等)及其参数功能,涵盖进程状态、内存使用、磁盘I/O、系统负载等多维度资源监控,... 目录toppsuptimevmstatIOStatiotopslabtophtopdstatnmon

Spring 框架之Springfox使用详解

《Spring框架之Springfox使用详解》Springfox是Spring框架的API文档工具,集成Swagger规范,自动生成文档并支持多语言/版本,模块化设计便于扩展,但存在版本兼容性、性... 目录核心功能工作原理模块化设计使用示例注意事项优缺点优点缺点总结适用场景建议总结Springfox 是

java向微信服务号发送消息的完整步骤实例

《java向微信服务号发送消息的完整步骤实例》:本文主要介绍java向微信服务号发送消息的相关资料,包括申请测试号获取appID/appsecret、关注公众号获取openID、配置消息模板及代码... 目录步骤1. 申请测试系统2. 公众号账号信息3. 关注测试号二维码4. 消息模板接口5. Java测试