行为分析
2021-12-02 15:33:20 8 举报
行为分析
作者其他创作
大纲/内容
可以改一下规则，如：rule=\"0/5 * * * * ? *\"
TemplateMainActivity.onCreate
KafkaConsumer.consumer0
DefaultKafkaProducer.producer0
UDP
写入模拟数据
IpuTcpServer.getInstance(Integer.parseInt(tcpPort)).start();
MysqlManager.executeInsert
ServerStart收集服务启动类
IpuMobileActivity.onCreate
tcpLong
// 触发时间 每30分钟执行一次String cronScheduleHour = System.getProperty(\"cronScheduleHour\
SimulateDataJob.send
IpuTcpLongConnectServer.getInstance(Integer.parseInt(tcpLongConnectPort)).start();
common.propertie文件配置了topic与数据库表的关系及消息格式
Application.java启动类
UdpServerHandler.channelRead0
ipu-contact-biz业务组件
Android客户端启动消息发送
Postman 发送POST请求：http://localhost:9000/ipu//simulator/initDevices
com.ai.ipu.count.IpuCount.init
kafka
MqManager.producer
AbstractKafka.consumer
MessageDeal.dealMessage
{\"eventType\":\"AppStart\
MainActivity.onCreate
SchedulerManagerUtil.startScheduler();
Android客户端心跳发送
IpuHttpServer.getInstance(Integer.parseInt(httpPort)).start();
ipu-contact-simulator 模拟服务
客户端启动，发送UDP消息到收集服务，收集服务将接收到的消息发送给kafka
MySQL
ipu-ca-collect收集服务
发送模拟数据的消息
SimulateDataJob.execute
IpuMqttServer.getInstance(port).start();
读取
IpuCountUtil.sendOper(\"start\
IpuCountUtil.init(IpuMobileActivity.this.getApplication());
http
district.json等、、读取许多个json文件
mqtt
IpuUdpServer.getInstance(Integer.parseInt(udpPort)).start();
HeartBeatService.onCreate()
ipu-consumer-app-mysql版本的消费者流程
tcp
ump
MessageDealManager.dealMessage(strContentDecode);
device.json
提供接口，具体接口的使用及参数等请看postman，共计43个接口
ConsumerServer.main消费者服务启动类
IpuCount.sendHeartBeat(HeartBeatService.this.period);
UdpServer.start
0 条评论
回复 删除
下一页
