fate
/
fate-modules-analysis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

电子围栏预警事件+KAfka消息接收+Hbase数据存储

master
Yang Haoyu 2023-12-05 10:30:46 +08:00
parent ec1616e6d9
commit 969bef7391
8 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
fate-modules-common/pom.xml
View File

@ -13,7 +13,7 @@
<artifactId>fate-modules-common</artifactId> <artifactId>fate-modules-common</artifactId>
<description> <description>
解析系统——公共模块 数据解析——公共模块
</description> </description>
<properties> <properties>

2
fate-modules-remote/pom.xml
View File

@ -13,7 +13,7 @@
<artifactId>fate-modules-remote</artifactId> <artifactId>fate-modules-remote</artifactId>
<description> <description>
解析系统——远程调用模块 数据解析——远程调用模块
</description> </description>
<properties> <properties>

2
fate-modules-service/pom.xml
View File

@ -13,7 +13,7 @@
<artifactId>fate-modules-service</artifactId> <artifactId>fate-modules-service</artifactId>
<description> <description>
解析系统——服务模块 数据解析——服务模块
</description> </description>
<properties> <properties>

1
fate-modules-service/src/main/java/com/shiyi/analysis/config/KafkaConsumer.java
View File

@ -17,7 +17,6 @@ import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.kafka.annotation.KafkaListener; import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.io.IOException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Date; import java.util.Date;
import java.util.Optional; import java.util.Optional;

3
fate-modules-service/src/main/java/com/shiyi/analysis/hbase/instance/HBaseInstance.java
View File

@ -7,7 +7,6 @@ import lombok.extern.log4j.Log4j2;
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Admin;
//import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
@ -158,7 +157,7 @@ public class HBaseInstance {
preparedStatement.executeUpdate (); preparedStatement.executeUpdate ();
} }
}catch (SQLException e){ }catch (SQLException e){
System.out.println(e.getMessage()); log.info(e.getMessage());
} }
} }

3
fate-modules-service/src/main/java/com/shiyi/analysis/kafka/config/MQTTConfig.java
View File

@ -1,5 +1,6 @@
package com.shiyi.analysis.kafka.config; package com.shiyi.analysis.kafka.config;
import io.netty.handler.codec.mqtt.MqttProperties;
import org.eclipse.paho.client.mqttv3.MqttClient; import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions; import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException; import org.eclipse.paho.client.mqttv3.MqttException;
@ -18,7 +19,7 @@ public class MQTTConfig {
/** /**
*MQTT代理服务器地址和端口 *MQTT代理服务器地址和端口
*/ */
private static final String BROKER_URL = "tcp://182.254.222.21:1883"; private static final String BROKER_URL = "tcp://fluxmq.muyu.icu:1883";
/** /**

2
fate-modules-service/src/main/java/com/shiyi/analysis/kafka/service/impl/KafkaServiceimpl.java
View File

@ -48,7 +48,6 @@ public class KafkaServiceimpl implements KafkaService {
@Override @Override
public void connectionLost(Throwable throwable) { public void connectionLost(Throwable throwable) {
} }
/** /**
* 接收到消息 * 接收到消息
* @param s * @param s
@ -62,7 +61,6 @@ public class KafkaServiceimpl implements KafkaService {
*/ */
} }
@Override @Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

1
fate-modules-service/src/main/java/com/shiyi/analysis/service/impl/HbaseServiceimpl.java
View File

@ -16,7 +16,6 @@ import org.apache.hadoop.hbase.util.Bytes;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.swing.*;
import java.io.IOException; import java.io.IOException;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException; import java.lang.reflect.InvocationTargetException;