From 969bef7391113c44eff4ca43a36a2eded2479532 Mon Sep 17 00:00:00 2001 From: Yang Haoyu <2241399212@qq.com> Date: Tue, 5 Dec 2023 10:30:46 +0800 Subject: [PATCH] =?UTF-8?q?=E7=94=B5=E5=AD=90=E5=9B=B4=E6=A0=8F=E9=A2=84?= =?UTF-8?q?=E8=AD=A6=E4=BA=8B=E4=BB=B6+KAfka=E6=B6=88=E6=81=AF=E6=8E=A5?= =?UTF-8?q?=E6=94=B6+Hbase=E6=95=B0=E6=8D=AE=E5=AD=98=E5=82=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- fate-modules-common/pom.xml | 2 +- fate-modules-remote/pom.xml | 2 +- fate-modules-service/pom.xml | 2 +- .../src/main/java/com/shiyi/analysis/config/KafkaConsumer.java | 1 - .../java/com/shiyi/analysis/hbase/instance/HBaseInstance.java | 3 +-- .../main/java/com/shiyi/analysis/kafka/config/MQTTConfig.java | 3 ++- .../shiyi/analysis/kafka/service/impl/KafkaServiceimpl.java | 2 -- .../java/com/shiyi/analysis/service/impl/HbaseServiceimpl.java | 1 - 8 files changed, 6 insertions(+), 10 deletions(-) diff --git a/fate-modules-common/pom.xml b/fate-modules-common/pom.xml index 42c71f8..82a0565 100644 --- a/fate-modules-common/pom.xml +++ b/fate-modules-common/pom.xml @@ -13,7 +13,7 @@ fate-modules-common - 解析系统——公共模块 + 数据解析——公共模块 diff --git a/fate-modules-remote/pom.xml b/fate-modules-remote/pom.xml index fe149c7..341db3f 100644 --- a/fate-modules-remote/pom.xml +++ b/fate-modules-remote/pom.xml @@ -13,7 +13,7 @@ fate-modules-remote - 解析系统——远程调用模块 + 数据解析——远程调用模块 diff --git a/fate-modules-service/pom.xml b/fate-modules-service/pom.xml index 73cfdf6..bb3a700 100644 --- a/fate-modules-service/pom.xml +++ b/fate-modules-service/pom.xml @@ -13,7 +13,7 @@ fate-modules-service - 解析系统——服务模块 + 数据解析——服务模块 diff --git a/fate-modules-service/src/main/java/com/shiyi/analysis/config/KafkaConsumer.java b/fate-modules-service/src/main/java/com/shiyi/analysis/config/KafkaConsumer.java index 6e40991..3b54b8a 100644 --- a/fate-modules-service/src/main/java/com/shiyi/analysis/config/KafkaConsumer.java +++ b/fate-modules-service/src/main/java/com/shiyi/analysis/config/KafkaConsumer.java @@ -17,7 +17,6 @@ import org.springframework.data.redis.core.RedisTemplate; import org.springframework.kafka.annotation.KafkaListener; import org.springframework.stereotype.Component; -import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.Optional; diff --git a/fate-modules-service/src/main/java/com/shiyi/analysis/hbase/instance/HBaseInstance.java b/fate-modules-service/src/main/java/com/shiyi/analysis/hbase/instance/HBaseInstance.java index 8f63a6f..d474db2 100644 --- a/fate-modules-service/src/main/java/com/shiyi/analysis/hbase/instance/HBaseInstance.java +++ b/fate-modules-service/src/main/java/com/shiyi/analysis/hbase/instance/HBaseInstance.java @@ -7,7 +7,6 @@ import lombok.extern.log4j.Log4j2; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.client.Admin; -//import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.springframework.context.annotation.Bean; @@ -158,7 +157,7 @@ public class HBaseInstance { preparedStatement.executeUpdate (); } }catch (SQLException e){ - System.out.println(e.getMessage()); + log.info(e.getMessage()); } } diff --git a/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/config/MQTTConfig.java b/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/config/MQTTConfig.java index e2dca6e..a770444 100644 --- a/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/config/MQTTConfig.java +++ b/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/config/MQTTConfig.java @@ -1,5 +1,6 @@ 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.MqttConnectOptions; import org.eclipse.paho.client.mqttv3.MqttException; @@ -18,7 +19,7 @@ public class MQTTConfig { /** *MQTT代理服务器地址和端口 */ - private static final String BROKER_URL = "tcp://182.254.222.21:1883"; + private static final String BROKER_URL = "tcp://fluxmq.muyu.icu:1883"; /** diff --git a/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/service/impl/KafkaServiceimpl.java b/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/service/impl/KafkaServiceimpl.java index 7f928ad..e05560e 100644 --- a/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/service/impl/KafkaServiceimpl.java +++ b/fate-modules-service/src/main/java/com/shiyi/analysis/kafka/service/impl/KafkaServiceimpl.java @@ -48,7 +48,6 @@ public class KafkaServiceimpl implements KafkaService { @Override public void connectionLost(Throwable throwable) { } - /** * 接收到消息 * @param s @@ -62,7 +61,6 @@ public class KafkaServiceimpl implements KafkaService { */ } - @Override public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) { diff --git a/fate-modules-service/src/main/java/com/shiyi/analysis/service/impl/HbaseServiceimpl.java b/fate-modules-service/src/main/java/com/shiyi/analysis/service/impl/HbaseServiceimpl.java index a7144d1..88d7c8d 100644 --- a/fate-modules-service/src/main/java/com/shiyi/analysis/service/impl/HbaseServiceimpl.java +++ b/fate-modules-service/src/main/java/com/shiyi/analysis/service/impl/HbaseServiceimpl.java @@ -16,7 +16,6 @@ import org.apache.hadoop.hbase.util.Bytes; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import javax.swing.*; import java.io.IOException; import java.lang.reflect.Field; import java.lang.reflect.InvocationTargetException;