mtr监控策略初版

.gitignore

@@ -0,0 +1,46 @@
+######################################################################
+# Build Tools
+
+.gradle
+/build/
+!gradle/wrapper/gradle-wrapper.jar
+
+target/
+!.mvn/wrapper/maven-wrapper.jar
+
+######################################################################
+# IDE
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### JRebel ###
+rebel.xml
+### NetBeans ###
+nbproject/private/
+build/*
+nbbuild/
+dist/
+nbdist/
+.nb-gradle/
+
+######################################################################
+# Others
+*.log
+*.xml.versionsBackup
+*.swp
+
+!*/build/*.java
+!*/build/*.html
+!*/build/*.xml

src/main/java/com/tongran/agent/server/core/enums/MsgEnum.java

@@ -77,6 +77,8 @@ public enum MsgEnum {
 
     Agent版本更新应答("AGENT_VERSION_UPDATE_RSP"),
 
+    MTR探测上报("MTR_DETECT"),
+
     多网IP探测上报("NETWORK_DETECT");
 
     private String value;

src/main/java/com/tongran/agent/server/netty/enpoint/AgentEndpoint.java

@@ -414,6 +414,20 @@ public class AgentEndpoint {
         }
     }
 
+    @AgentDispatcher(msgId = MsgEnum.MTR探测上报)
+    public class DetectMtrHandler implements AgentHandler {
+        @Override
+        public UpMsgResponse upHandle(String data, String clientId) {
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("clientId", clientId);
+            jsonObject.put("dataType", MsgEnum.MTR探测上报.getValue());
+            jsonObject.put("data", data);
+            MqMsg mqMsg = MqMsg.builder().topic(agentMqConfig.getAgentTopic()).content(jsonObject.toString()).build();
+            agentProducer.asyncSend(mqMsg);
+            return null;
+        }
+    }
+
 
 
 

src/main/java/com/tongran/agent/server/rockermq/listener/AgentConsumerDownListener.java

@@ -18,7 +18,7 @@ import java.util.Objects;
 
 @Component
 @ConditionalOnProperty(name = "rocketmq.enabled", havingValue = "true")
-@RocketMQMessageListener(topic = "tr_agent_down", consumerGroup = "tr_agent_down_group")
+@RocketMQMessageListener(topic = "tr_mtragent_down", consumerGroup = "tr_mtragent_down_group")
 public class AgentConsumerDownListener implements RocketMQListener<String> {
 
 	protected final SessionManager sessionManager;

src/main/resources/application-dev.yml

@@ -12,11 +12,11 @@ knife4j:
 logging:
   file:
 #    path: /usr/local/tongran/logs
-    path: /usr/local/tongran_server/logs
+    path: /usr/local/tongran_mtrserver/logs
 #    path: D:/job/agent-logs/logs
 
 rocketmq:
-  name-server: 172.16.15.103:9876
+  name-server: 172.16.15.52:9876
   enabled: true
 
 tcp:
@@ -24,6 +24,6 @@ tcp:
     charge:
       enable: true
       name: AGENT-SERVER-服务
-      port: 6620
+      port: 6610
       readerIdleTime: 300
 

src/main/resources/application.yml

@@ -34,10 +34,10 @@ rocketmq:
   producer:
     group: tongran-group
     topic: default_topic
-    agent-group: tr_agent_up_group
-    agent-topic: tr_agent_up
+    agent-group: tr_mtragent_up_group
+    agent-topic: tr_mtragent_up
   consumer:
     group: tongran-group
     topic: default_topic
-    agent-group: tr_agent_down_group
-    agent-topic: tr_agent_down
+    agent-group: tr_mtragent_down_group
+    agent-topic: tr_mtragent_down