diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java index 11b3357..5eaec39 100644 --- a/src/main/java/org/well/mysql/sink/WellSink.java +++ b/src/main/java/org/well/mysql/sink/WellSink.java @@ -136,7 +136,7 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"13131313135\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":98,\"datas\":[{\"level\":6.73,\"uptime\":\"20191217161000\"},{\"level\":5.72,\"uptime\":\"20191217162000\"},{\"level\":7.71,\"uptime\":\"20200211103000\"}],\"logTime\":\"20200211103000\"},\"ts\":1556186030842}"; // temp="{\"mType\":\"SetResponse\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidConfigSuccess\"},\"ts\":1556182310514}"; // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":97,\"datas\":[{\"level\":4,\"uptime\":\"20201219150000\"},{\"level\":4,\"uptime\":\"20191219151000\"},{\"level\":6.5,\"uptime\":\"20191219152000\"}],\"logTime\":\"20191219152000\"},\"ts\":1556186030842}"; - temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; +// temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; // temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019060037\",\"mBody\":{\"eventType\":[\"WellOpenAlarm\"],\"logTime\":\"20191017154056\",\"bType\":\"WellEvent\"},\"ts\":1571298056241}"; // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312018020163\",\"mBody\":{\"cell\":95,\"datas\":[{\"gas\":0.064453125,\"uptime\":\"20200925173900\"},{\"gas\":0.080566406,\"uptime\":\"20200925175400\"},{\"gas\":25,\"uptime\":\"20200925165400\"},{\"gas\":0.09990235,\"uptime\":\"20200925085400\"},{\"gas\":0.070898436,\"uptime\":\"20200407085400\"},{\"gas\":60,\"uptime\":\"20200509085400\"}],\"logTime\":\"20200407085400\",\"bType\":\"MethaneData\"},\"ts\":1571292084960}"; @@ -147,12 +147,14 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312020030044\",\"mBody\":{\"cell\":49,\"pci\":272,\"rsrp\":-88,\"snr\":25,\"datas\":[{\"gas\":1.8,\"uptime\":\"20210610160600\"},{\"gas\":1.8,\"uptime\":\"20210610170600\"},{\"gas\":1.8,\"uptime\":\"20210610180600\"}],\"logTime\":\"20210610180304\",\"bType\":\"MethaneData\"},\"ts\":1623319384413}"; // temp="{\"mType\":\"Data\",\"devType\":\"LG\",\"devCode\":\"322020080276\",\"mBody\":{\"cell\":96,\"datas\":[{\"gas\":0.0,\"uptime\":\"20210610181200\"}],\"logTime\":\"20210610180245\",\"bType\":\"LGData\"},\"ts\":1623319365811}"; - AbstractResponse resp = ResponseResolver.makeResponse(temp); - resp.setAc(ac); - resp.process(temp); +// AbstractResponse resp = ResponseResolver.makeResponse(temp); +// resp.setAc(ac); +// resp.process(temp); // DeviceManager deviceManager = ac.getBean(DeviceManager.class); // deviceManager.updateDeviceStatus(); + System.out.println("已经起来了,可以处理数据了。。。。。"); + } } diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java index 11b3357..5eaec39 100644 --- a/src/main/java/org/well/mysql/sink/WellSink.java +++ b/src/main/java/org/well/mysql/sink/WellSink.java @@ -136,7 +136,7 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"13131313135\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":98,\"datas\":[{\"level\":6.73,\"uptime\":\"20191217161000\"},{\"level\":5.72,\"uptime\":\"20191217162000\"},{\"level\":7.71,\"uptime\":\"20200211103000\"}],\"logTime\":\"20200211103000\"},\"ts\":1556186030842}"; // temp="{\"mType\":\"SetResponse\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidConfigSuccess\"},\"ts\":1556182310514}"; // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":97,\"datas\":[{\"level\":4,\"uptime\":\"20201219150000\"},{\"level\":4,\"uptime\":\"20191219151000\"},{\"level\":6.5,\"uptime\":\"20191219152000\"}],\"logTime\":\"20191219152000\"},\"ts\":1556186030842}"; - temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; +// temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; // temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019060037\",\"mBody\":{\"eventType\":[\"WellOpenAlarm\"],\"logTime\":\"20191017154056\",\"bType\":\"WellEvent\"},\"ts\":1571298056241}"; // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312018020163\",\"mBody\":{\"cell\":95,\"datas\":[{\"gas\":0.064453125,\"uptime\":\"20200925173900\"},{\"gas\":0.080566406,\"uptime\":\"20200925175400\"},{\"gas\":25,\"uptime\":\"20200925165400\"},{\"gas\":0.09990235,\"uptime\":\"20200925085400\"},{\"gas\":0.070898436,\"uptime\":\"20200407085400\"},{\"gas\":60,\"uptime\":\"20200509085400\"}],\"logTime\":\"20200407085400\",\"bType\":\"MethaneData\"},\"ts\":1571292084960}"; @@ -147,12 +147,14 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312020030044\",\"mBody\":{\"cell\":49,\"pci\":272,\"rsrp\":-88,\"snr\":25,\"datas\":[{\"gas\":1.8,\"uptime\":\"20210610160600\"},{\"gas\":1.8,\"uptime\":\"20210610170600\"},{\"gas\":1.8,\"uptime\":\"20210610180600\"}],\"logTime\":\"20210610180304\",\"bType\":\"MethaneData\"},\"ts\":1623319384413}"; // temp="{\"mType\":\"Data\",\"devType\":\"LG\",\"devCode\":\"322020080276\",\"mBody\":{\"cell\":96,\"datas\":[{\"gas\":0.0,\"uptime\":\"20210610181200\"}],\"logTime\":\"20210610180245\",\"bType\":\"LGData\"},\"ts\":1623319365811}"; - AbstractResponse resp = ResponseResolver.makeResponse(temp); - resp.setAc(ac); - resp.process(temp); +// AbstractResponse resp = ResponseResolver.makeResponse(temp); +// resp.setAc(ac); +// resp.process(temp); // DeviceManager deviceManager = ac.getBean(DeviceManager.class); // deviceManager.updateDeviceStatus(); + System.out.println("已经起来了,可以处理数据了。。。。。"); + } } diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java index 3f8cbcf..c2ad4bf 100644 --- a/src/main/java/org/well/well/kafka/KafkaConsumer.java +++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java @@ -8,5 +8,6 @@ @Override public void onMessage(ConsumerRecord record) { String value = record.value(); + System.out.println(value); } } diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java index 11b3357..5eaec39 100644 --- a/src/main/java/org/well/mysql/sink/WellSink.java +++ b/src/main/java/org/well/mysql/sink/WellSink.java @@ -136,7 +136,7 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"13131313135\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":98,\"datas\":[{\"level\":6.73,\"uptime\":\"20191217161000\"},{\"level\":5.72,\"uptime\":\"20191217162000\"},{\"level\":7.71,\"uptime\":\"20200211103000\"}],\"logTime\":\"20200211103000\"},\"ts\":1556186030842}"; // temp="{\"mType\":\"SetResponse\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidConfigSuccess\"},\"ts\":1556182310514}"; // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":97,\"datas\":[{\"level\":4,\"uptime\":\"20201219150000\"},{\"level\":4,\"uptime\":\"20191219151000\"},{\"level\":6.5,\"uptime\":\"20191219152000\"}],\"logTime\":\"20191219152000\"},\"ts\":1556186030842}"; - temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; +// temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; // temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019060037\",\"mBody\":{\"eventType\":[\"WellOpenAlarm\"],\"logTime\":\"20191017154056\",\"bType\":\"WellEvent\"},\"ts\":1571298056241}"; // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312018020163\",\"mBody\":{\"cell\":95,\"datas\":[{\"gas\":0.064453125,\"uptime\":\"20200925173900\"},{\"gas\":0.080566406,\"uptime\":\"20200925175400\"},{\"gas\":25,\"uptime\":\"20200925165400\"},{\"gas\":0.09990235,\"uptime\":\"20200925085400\"},{\"gas\":0.070898436,\"uptime\":\"20200407085400\"},{\"gas\":60,\"uptime\":\"20200509085400\"}],\"logTime\":\"20200407085400\",\"bType\":\"MethaneData\"},\"ts\":1571292084960}"; @@ -147,12 +147,14 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312020030044\",\"mBody\":{\"cell\":49,\"pci\":272,\"rsrp\":-88,\"snr\":25,\"datas\":[{\"gas\":1.8,\"uptime\":\"20210610160600\"},{\"gas\":1.8,\"uptime\":\"20210610170600\"},{\"gas\":1.8,\"uptime\":\"20210610180600\"}],\"logTime\":\"20210610180304\",\"bType\":\"MethaneData\"},\"ts\":1623319384413}"; // temp="{\"mType\":\"Data\",\"devType\":\"LG\",\"devCode\":\"322020080276\",\"mBody\":{\"cell\":96,\"datas\":[{\"gas\":0.0,\"uptime\":\"20210610181200\"}],\"logTime\":\"20210610180245\",\"bType\":\"LGData\"},\"ts\":1623319365811}"; - AbstractResponse resp = ResponseResolver.makeResponse(temp); - resp.setAc(ac); - resp.process(temp); +// AbstractResponse resp = ResponseResolver.makeResponse(temp); +// resp.setAc(ac); +// resp.process(temp); // DeviceManager deviceManager = ac.getBean(DeviceManager.class); // deviceManager.updateDeviceStatus(); + System.out.println("已经起来了,可以处理数据了。。。。。"); + } } diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java index 3f8cbcf..c2ad4bf 100644 --- a/src/main/java/org/well/well/kafka/KafkaConsumer.java +++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java @@ -8,5 +8,6 @@ @Override public void onMessage(ConsumerRecord record) { String value = record.value(); + System.out.println(value); } } diff --git a/src/main/resources/wellSensor/application.properties b/src/main/resources/wellSensor/application.properties index 5446317..0135bc0 100644 --- a/src/main/resources/wellSensor/application.properties +++ b/src/main/resources/wellSensor/application.properties @@ -169,7 +169,7 @@ # ============================================================================ bootstrap.servers = 111.198.10.15:12502 kafka.topic = test -bootstrap.groupid =0 +bootstrap.groupid = 0 # ============================================================================ # 告警、工单推送地址 diff --git a/src/main/java/org/well/mysql/sink/WellSink.java b/src/main/java/org/well/mysql/sink/WellSink.java index 11b3357..5eaec39 100644 --- a/src/main/java/org/well/mysql/sink/WellSink.java +++ b/src/main/java/org/well/mysql/sink/WellSink.java @@ -136,7 +136,7 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"13131313135\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":98,\"datas\":[{\"level\":6.73,\"uptime\":\"20191217161000\"},{\"level\":5.72,\"uptime\":\"20191217162000\"},{\"level\":7.71,\"uptime\":\"20200211103000\"}],\"logTime\":\"20200211103000\"},\"ts\":1556186030842}"; // temp="{\"mType\":\"SetResponse\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidConfigSuccess\"},\"ts\":1556182310514}"; // temp="{\"mType\":\"Data\",\"devType\":\"Liquid\",\"devCode\":\"12121212125\",\"mBody\":{\"bType\":\"LiquidData\",\"cell\":97,\"datas\":[{\"level\":4,\"uptime\":\"20201219150000\"},{\"level\":4,\"uptime\":\"20191219151000\"},{\"level\":6.5,\"uptime\":\"20191219152000\"}],\"logTime\":\"20191219152000\"},\"ts\":1556186030842}"; - temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; +// temp="{\"mType\":\"Data\",\"devType\":\"NoiseDig\",\"devCode\":\"14141414146\",\"mBody\":{\"bType\":\"NoiseDigData\",\"cell\":88,\"datas\":[{\"noiseVal\":60,\"noiseFreq\":50,\"uptime\":\"20200109123131\"}],\"logTime\":\"20200119123131\"},\"ts\":1556184691451}"; // temp="{\"mType\":\"Event\",\"devType\":\"Well\",\"devCode\":\"412019060037\",\"mBody\":{\"eventType\":[\"WellOpenAlarm\"],\"logTime\":\"20191017154056\",\"bType\":\"WellEvent\"},\"ts\":1571298056241}"; // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312018020163\",\"mBody\":{\"cell\":95,\"datas\":[{\"gas\":0.064453125,\"uptime\":\"20200925173900\"},{\"gas\":0.080566406,\"uptime\":\"20200925175400\"},{\"gas\":25,\"uptime\":\"20200925165400\"},{\"gas\":0.09990235,\"uptime\":\"20200925085400\"},{\"gas\":0.070898436,\"uptime\":\"20200407085400\"},{\"gas\":60,\"uptime\":\"20200509085400\"}],\"logTime\":\"20200407085400\",\"bType\":\"MethaneData\"},\"ts\":1571292084960}"; @@ -147,12 +147,14 @@ // temp="{\"mType\":\"Data\",\"devType\":\"Methane\",\"devCode\":\"312020030044\",\"mBody\":{\"cell\":49,\"pci\":272,\"rsrp\":-88,\"snr\":25,\"datas\":[{\"gas\":1.8,\"uptime\":\"20210610160600\"},{\"gas\":1.8,\"uptime\":\"20210610170600\"},{\"gas\":1.8,\"uptime\":\"20210610180600\"}],\"logTime\":\"20210610180304\",\"bType\":\"MethaneData\"},\"ts\":1623319384413}"; // temp="{\"mType\":\"Data\",\"devType\":\"LG\",\"devCode\":\"322020080276\",\"mBody\":{\"cell\":96,\"datas\":[{\"gas\":0.0,\"uptime\":\"20210610181200\"}],\"logTime\":\"20210610180245\",\"bType\":\"LGData\"},\"ts\":1623319365811}"; - AbstractResponse resp = ResponseResolver.makeResponse(temp); - resp.setAc(ac); - resp.process(temp); +// AbstractResponse resp = ResponseResolver.makeResponse(temp); +// resp.setAc(ac); +// resp.process(temp); // DeviceManager deviceManager = ac.getBean(DeviceManager.class); // deviceManager.updateDeviceStatus(); + System.out.println("已经起来了,可以处理数据了。。。。。"); + } } diff --git a/src/main/java/org/well/well/kafka/KafkaConsumer.java b/src/main/java/org/well/well/kafka/KafkaConsumer.java index 3f8cbcf..c2ad4bf 100644 --- a/src/main/java/org/well/well/kafka/KafkaConsumer.java +++ b/src/main/java/org/well/well/kafka/KafkaConsumer.java @@ -8,5 +8,6 @@ @Override public void onMessage(ConsumerRecord record) { String value = record.value(); + System.out.println(value); } } diff --git a/src/main/resources/wellSensor/application.properties b/src/main/resources/wellSensor/application.properties index 5446317..0135bc0 100644 --- a/src/main/resources/wellSensor/application.properties +++ b/src/main/resources/wellSensor/application.properties @@ -169,7 +169,7 @@ # ============================================================================ bootstrap.servers = 111.198.10.15:12502 kafka.topic = test -bootstrap.groupid =0 +bootstrap.groupid = 0 # ============================================================================ # 告警、工单推送地址 diff --git a/target/classes/wellSensor/application.properties b/target/classes/wellSensor/application.properties index dee4d13..5446317 100644 --- a/target/classes/wellSensor/application.properties +++ b/target/classes/wellSensor/application.properties @@ -163,6 +163,14 @@ activemq_password = + +# ============================================================================ +# kafka配置 +# ============================================================================ +bootstrap.servers = 111.198.10.15:12502 +kafka.topic = test +bootstrap.groupid =0 + # ============================================================================ # 告警、工单推送地址 # ============================================================================