停掉任务
MessageDistribute根据消息内容选择具体的服务层
调用任务列表接口
服务启动/初始化完成
发送hello
根据用户配置的OID指标
根据修改时间排序
DMServerDistributionManager.handle(消息拦截分发)
判断计划时间/执行次数
每5秒重新注册
响应升级成功
响应本地设备状态
DMServerStopTaskResponse.handle
服务启动
DMServerDownloadLogResponse.handle
checkParams
根据用户配置
获取对应的执行器
SSHServiceImpl SNMPClientServiceImpl SNMPServerServiceImpl SyslogServerServiceImplHttpServiceImpl..
DMServerReportTaskResultRequest.send(数据结果上报)
返回日志文件
得到任务列表
Runnable
DMServerUpgradeAgentService.execute
CreateTaskExecutorFactory.getTaskExecutor(responseCreateTaskDto).execute();
dmServerStopTaskService.execute
ConsumeMessage消息消费者开始批量消费
接收到探针升级消息时
判断pm是否执行
DMServerGetSystemStatusService.execute
DMServerCreateTaskService.execute
获取远程设备状态
执行
DMServerGetDeviceSystemStatusService.execute
SyslogServerServiceImpl
RMRemoteSSHTaskExecutorRMRemoteSNMPTaskExecutorRMServerSNMPTaskExecutorRMLocalAgentTaskExecutorRMServerSyslogTaskExecutorRMRemoteHttpTaskExecutor
注册
执行重装命令
MessageContainer指标数值结果容器(按照时间/条数进行批量发送)
DMServerCreateTaskResponse.handle
判断任务是否在执行中
响应停止任务成功
像server端发起register
解析参数获取任务列表
获取本地设备状态
DMServerRegisterResponse.handle
下载服务日志
获取服务日志列表
TaskManager.stop(taskId);
DMServerGetDeviceSystemStatusResponse.handle
响应日志列表
接收到停止任务消息时
根据用户配置脚本
randomKey(秘钥)
结束
发送同步任务消息时
DMServerHelloRequest.send(发送后同步等待)
获取任务ID
响应重装成功
DMServerCreateTaskRequest.sendMsg(响应服务端创建任务成功)
register
根据用户连接配置
接收到探针重装消息时
DMServerGetSystemStatusResponse.handle
DMServerReinstallAgentResponse.handle
DMServerSyncTaskListResponse.handle
获取日志目录下的所有文件
DMServerDownloadLogService.execute
DMServerStopTaskRequest.sendMsg
HttpServiceImpl
校验MD5
DMServerLogListResponse.handle
读取本地网络状态读取本地磁盘状态读取本地内存状态读取本地CPU状态
DMServerHelloResponse.handle
下载jar包
DMServerLogListService.execute
DMServerSyncTaskListRequest.send(发送后同步等待)
websocket注册服务端
SSHServiceImpl
延时队列(任务消费者)
SNMPClientServiceImpl
启动任务
接收到创建任务消息时
DMServerUpgradeAgentResponse.handle
DMServerReinstallAgentService.execute
进行base64编码
