云快充协议核心架构与初始化

graph TB
subgraph "协议层"
Bootstrap[协议引导器]
Processor[消息处理器]
Constants[协议常量]
end
subgraph "版本管理"
V150[V150协议]
V160[V160协议]
V170[V170协议]
end
subgraph "基础设施"
Context[协议上下文]
Router[命令路由器]
Listener[TCP监听器]
end
Bootstrap --> Processor
Bootstrap --> V150
Bootstrap --> V160
Bootstrap --> V170
Processor --> Router
Processor --> Context
Bootstrap --> Listener

classDiagram
class ProtocolBootstrap {
<<abstract>>
#ProtocolContext protocolContext
#ProtocolCfg protocolCfg
#Listener listener
#Forwarder forwarder
+init() void
+destroy() void
+health() Health
#getProtocolName()* String
#_init()* void
#_destroy()* void
#messageProcessor()* ProtocolMessageProcessor
}
class YunkuaichongV150ProtocolBootstrap {
+String PROTOCOL_NAME
+getProtocolName() String
+_init() void
+_destroy() void
+messageProcessor() ProtocolMessageProcessor
}
class YunkuaichongV160ProtocolBootstrap {
+String PROTOCOL_NAME
+getProtocolName() String
+_init() void
+_destroy() void
+messageProcessor() ProtocolMessageProcessor
}
class YunkuaichongV170ProtocolBootstrap {
+String PROTOCOL_NAME
+getProtocolName() String
+_init() void
+_destroy() void
+messageProcessor() ProtocolMessageProcessor
}
class YunKuaiChongProtocolMessageProcessor {
-ProtocolCommandRouter~YunKuaiChongUplinkCmdExe~ uplinkRouter
-ProtocolCommandRouter~YunKuaiChongDownlinkCmdExe~ downlinkRouter
-DownlinkCmdConverter downlinkCmdConverter
+uplinkHandle(ListenerToHandlerMsg) void
+doDownlinkHandle(SessionToHandlerMsg) void
-exeCmd(YunKuaiChongUplinkMessage, TcpSession) void
-exeCmd(YunKuaiChongDwonlinkMessage, TcpSession) void
}
ProtocolBootstrap <|-- YunkuaichongV150ProtocolBootstrap
ProtocolBootstrap <|-- YunkuaichongV160ProtocolBootstrap
ProtocolBootstrap <|-- YunkuaichongV170ProtocolBootstrap
ProtocolBootstrap --> YunKuaiChongProtocolMessageProcessor

sequenceDiagram
participant Client as 客户端设备
participant Listener as TCP监听器
participant Processor as 消息处理器
participant Router as 命令路由器
participant Executor as 命令执行器
Client->>Listener : 发送原始字节流
Listener->>Processor : uplinkHandle(ListenerToHandlerMsg)
Processor->>Processor : 解析协议头
Processor->>Processor : 校验和验证
Processor->>Processor : 构建YunKuaiChongUplinkMessage
Processor->>Router : getExecutor(protocolName, cmd)
Router->>Executor : 返回对应的命令执行器
Executor->>Executor : execute(session, message, context)
Executor-->>Processor : 处理结果
Processor-->>Listener : 处理完成
Listener-->>Client : 响应消息

flowchart TD
Start([启动初始化]) --> GetProtocolName["获取协议名称<br/>getProtocolName()"]
GetProtocolName --> LoadConfig["加载协议配置<br/>protocolContext.getProtocolsConfigProvider()"]
LoadConfig --> CheckForwarder{"检查转发器类型"}
CheckForwarder --> |内存模式| CreateMemoryForwarder["创建内存转发器<br/>MemoryForwarder"]
CheckForwarder --> |Kafka模式| CreateKafkaForwarder["创建Kafka转发器<br/>KafkaForwarder"]
CreateMemoryForwarder --> LoadTcpConfig["加载TCP配置<br/>protocolCfg.getListener().getTcp()"]
CreateKafkaForwarder --> LoadTcpConfig
LoadTcpConfig --> CreateTcpListener["创建TCP监听器<br/>TcpListener"]
CreateTcpListener --> CallOnInit["_init()回调"]
CallOnInit --> CreateMessageProcessor["创建消息处理器<br/>messageProcessor()"]
CreateMessageProcessor --> Complete([初始化完成])

flowchart TD
Start([开始销毁]) --> LogDestroy["记录销毁日志<br/>log.info('{} destroy...', getProtocolName())"]
LogDestroy --> CheckListener{"监听器存在?"}
CheckListener --> |是| DestroyListener["销毁TCP监听器<br/>listener.destroy()"]
CheckListener --> |否| CheckForwarder{"转发器存在?"}
DestroyListener --> CheckForwarder
CheckForwarder --> |是| DestroyForwarder["销毁转发器<br/>forwarder.destroy()"]
CheckForwarder --> |否| CallOnDestroy["_destroy()回调"]
DestroyForwarder --> CallOnDestroy
CallOnDestroy --> Complete([销毁完成])

flowchart TD
Start([接收原始字节流]) --> QuickFail["快速失败检查<br/>长度 & 起始标志"]
QuickFail --> ParseHeader["解析协议头<br/>dataLength, seqNo, encryptFlag, frameType"]
ParseHeader --> BoundaryCheck["边界检查<br/>dataLength & 可读字节数"]
BoundaryCheck --> FieldParse["字段快速解析<br/>序列号、加密标志、帧类型"]
FieldParse --> ChecksumCheck["校验和验证<br/>CRC LE & BE两种模式"]
ChecksumCheck --> BuildMessage["构建消息对象<br/>YunKuaiChongUplinkMessage"]
BuildMessage --> RouteMessage["消息路由<br/>ProtocolCommandRouter"]
RouteMessage --> ExecuteCmd["执行命令<br/>命令执行器"]
ExecuteCmd --> Complete([处理完成])
QuickFail --> |失败| DropMessage["丢弃消息"]
BoundaryCheck --> |失败| DropMessage
ChecksumCheck --> |失败| DropMessage
DropMessage --> Complete

graph LR
subgraph "协议版本"
V150[V150<br/>基础功能]
V160[V160<br/>并行启动]
V170[V170<br/>交易记录增强]
end
subgraph "版本特性"
V150Features[登录认证<br/>心跳检测<br/>充电控制]
V160Features[远程并行启动<br/>批量操作]
V170Features[增强交易记录<br/>详细状态上报]
end
V150 --> V150Features
V160 --> V160Features
V170 --> V170Features
V150 -.-> V160
V160 -.-> V170

classDiagram
class ProtocolContext {
-StatsFactory statsFactory
-ProtocolsConfigProvider protocolsConfigProvider
-ProtocolSessionRegistryProvider protocolSessionRegistryProvider
-ServiceInfoProvider serviceInfoProvider
-PartitionProvider partitionProvider
-AppQueueFactory appQueueFactory
-ShardingThreadPool shardingThreadPool
+init() void
}
class StatsFactory {
+createMessagesStats() MessagesStats
}
class ProtocolsConfigProvider {
+loadConfig(protocolName) ProtocolCfg
}
class ShardingThreadPool {
+execute(shardingKey, runnable) void
}
ProtocolContext --> StatsFactory
ProtocolContext --> ProtocolsConfigProvider
ProtocolContext --> ShardingThreadPool

flowchart TD
Start([消息到达]) --> FastPath["快速路径<br/>长度检查 & 起始标志"]
FastPath --> SliceBuffer["切片缓冲区<br/>避免数据复制"]
SliceBuffer --> PoolAllocation["池化分配<br/>减少GC压力"]
PoolAllocation --> AsyncProcess["异步处理<br/>非阻塞"]
AsyncProcess --> ReleaseBuffer["释放缓冲区<br/>及时回收"]
ReleaseBuffer --> Complete([处理完成])