Commit 24e9ddb3 authored by duanruiming's avatar duanruiming

[update] 优化测试工具类

parent 261d00b0
......@@ -43,11 +43,11 @@ public class KafkaUtil {
public static void main(String []arags){
Map<String,String> param= Maps.newHashMap();
param.put("servers","121.36.56.157:9092");
param.put("groupId","gis-t");
param.put("servers","10.102.1.182:9092");
param.put("groupId","cross_free_flow_speed");
try {
KafkaUtil.connect(param);
System.out.println(KafkaUtil.comsumeTopic("gis-t"));
System.out.println(KafkaUtil.comsumeTopic("cross_free_flow_speed"));
}catch (Exception ex){
ex.printStackTrace();
}
......
......@@ -29,7 +29,7 @@ public class RedisUtil {
}
public static void main(String []args){
RedisUtil.getInstance("115.28.212.232",6379,14,"Mapabc@2020");
RedisUtil.getInstance("10.102.1.182",6379,7,"Wanji300552");
System.out.println(RedisUtil.checkConn());
}
}
......@@ -65,7 +65,7 @@ public class WebSocketUtil {
}
public static void main(String []args){
String socketUrl = "ws://121.40.165.18:8800";
String socketUrl = "ws://10.102.1.182:9000/utc/signalStatus/13NGH0B5RC0,stateMonitor";
System.out.println(WebSocketUtil.connect(socketUrl));
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment