diff --git a/pom.xml b/pom.xml index 7413ee3..7f5230b 100644 --- a/pom.xml +++ b/pom.xml @@ -215,23 +215,7 @@ httpmime 4.5.13 - - com.aliyun - aliyun-java-sdk-ram - 3.3.0 - - - - com.aliyun - aliyun-java-sdk-core - 4.6.2 - - - - com.aliyun - aliyun-java-sdk-dysmsapi - 2.2.1 - + org.apache.logging.log4j log4j-core @@ -265,27 +249,13 @@ slf4j-simple 1.7.36 - - - - org.apache.rocketmq - rocketmq-client - 4.9.4 - + org.opengauss opengauss-jdbc 5.0.0 - - - - - - - - org.apache.kafka diff --git a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java index 6ef0fbe..6fb44d7 100644 --- a/src/main/java/UnitTest/OpenGaussReplicationToKafka.java +++ b/src/main/java/UnitTest/OpenGaussReplicationToKafka.java @@ -1,7 +1,5 @@ package UnitTest; -import com.dsideal.FengHuang.Util.CommonUtil; -import com.jfinal.kit.StrKit; import com.jfinal.plugin.activerecord.ActiveRecordPlugin; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Record; @@ -17,7 +15,8 @@ import org.postgresql.replication.PGReplicationStream; import java.nio.ByteBuffer; import java.sql.DriverManager; -import java.util.*; +import java.util.List; +import java.util.Properties; import java.util.concurrent.TimeUnit; public class OpenGaussReplicationToKafka { diff --git a/src/main/java/UnitTest/RocketMqConsumer.java b/src/main/java/UnitTest/RocketMqConsumer.java index 70537d6..d673393 100644 --- a/src/main/java/UnitTest/RocketMqConsumer.java +++ b/src/main/java/UnitTest/RocketMqConsumer.java @@ -1,24 +1,20 @@ package UnitTest; -import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; -import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; -import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; -import org.apache.rocketmq.common.consumer.ConsumeFromWhere; /** * @Date 2021-04-20 15:47 */ public class RocketMqConsumer { public static void main(String[] args) throws Exception { - DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("default_consumer_group"); - consumer.setNamesrvAddr("10.10.14.231:9876"); - consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); - consumer.subscribe("TopicXuanKe", "*");//订阅topic和tag设置 - consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> { - String body = new String(msgs.get(0).getBody()); - System.out.printf("消息内容:%s%n", body); - return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; - }); - consumer.start(); +// DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("default_consumer_group"); +// consumer.setNamesrvAddr("10.10.14.231:9876"); +// consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); +// consumer.subscribe("TopicXuanKe", "*");//订阅topic和tag设置 +// consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> { +// String body = new String(msgs.get(0).getBody()); +// System.out.printf("消息内容:%s%n", body); +// return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; +// }); +// consumer.start(); } } \ No newline at end of file diff --git a/src/main/java/UnitTest/RocketMqProducer.java b/src/main/java/UnitTest/RocketMqProducer.java index 9f1865a..0eab108 100644 --- a/src/main/java/UnitTest/RocketMqProducer.java +++ b/src/main/java/UnitTest/RocketMqProducer.java @@ -1,9 +1,4 @@ package UnitTest; -import org.apache.rocketmq.client.producer.DefaultMQProducer; -import org.apache.rocketmq.client.producer.SendResult; -import org.apache.rocketmq.common.message.Message; - -import java.util.UUID; /** * @Date 2021-04-20 15:40 @@ -11,17 +6,17 @@ import java.util.UUID; public class RocketMqProducer { public static void main(String[] args) throws Exception { - //声明发送者 - DefaultMQProducer producer = new DefaultMQProducer("default_producter_group"); - producer.setNamesrvAddr("10.10.14.231:9876"); - producer.start(); - //发送 - String body = "你好 RocketMQ"; - Message message = new Message("TopicXuanKe", null, body.getBytes()); - message.setKeys(UUID.randomUUID().toString()); - SendResult sendResult = producer.send(message); - System.out.printf("发送结果:%s%n", sendResult); - //关闭生产者 - producer.shutdown(); +// //声明发送者 +// DefaultMQProducer producer = new DefaultMQProducer("default_producter_group"); +// producer.setNamesrvAddr("10.10.14.231:9876"); +// producer.start(); +// //发送 +// String body = "你好 RocketMQ"; +// Message message = new Message("TopicXuanKe", null, body.getBytes()); +// message.setKeys(UUID.randomUUID().toString()); +// SendResult sendResult = producer.send(message); +// System.out.printf("发送结果:%s%n", sendResult); +// //关闭生产者 +// producer.shutdown(); } } \ No newline at end of file diff --git a/target/classes/ExcelExportTemplate/excelTemp/92B9D720-B77E-4985-906B-59EB015EA337.xls b/target/classes/ExcelExportTemplate/excelTemp/92B9D720-B77E-4985-906B-59EB015EA337.xls deleted file mode 100644 index a9d3541..0000000 Binary files a/target/classes/ExcelExportTemplate/excelTemp/92B9D720-B77E-4985-906B-59EB015EA337.xls and /dev/null differ