From 16e9a7f0d81d34846e71a347d82a773e462402c5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com> Date: Mon, 29 May 2023 07:53:50 +0800 Subject: [PATCH] 'commit' --- pom.xml | 34 ++---------------- .../UnitTest/OpenGaussReplicationToKafka.java | 5 ++- src/main/java/UnitTest/RocketMqConsumer.java | 24 ++++++------- src/main/java/UnitTest/RocketMqProducer.java | 29 +++++++-------- .../92B9D720-B77E-4985-906B-59EB015EA337.xls | Bin 4593 -> 0 bytes 5 files changed, 26 insertions(+), 66 deletions(-) delete mode 100644 target/classes/ExcelExportTemplate/excelTemp/92B9D720-B77E-4985-906B-59EB015EA337.xls 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 a9d35412dec90d92eca7a2c275216e3ef768af8c..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 4593 zcmaJ^2{@E(+m?|bV;w|zWfx_M>>*nt+bGGBWiZxZ##pk1#(2jrd$R8gB|BlPSt7Dz zUrJP#kR?)%o%i`%*Lgy902It*R8&-Cl%aLTWG4bl zyf;@zx_QFgJgtm;QE(3nF&|e%&8G9HiA8mC`nnkC=1{Q3y68VJUeDhwnrTrp z3&fQ-Wd^yk?FLQKpO1jCbECuN{S8`9L3Myseu=&Ail@lPI4Q`;p#O+H4H0`QG#ud} zE=Kx(8sFyJApyc!buP`xtyxDI);+qsz%8+@C|87+6@Y~_ zj5kbR$dhs4&Z%WNV4~SaOQCAM-F#VB|I%#(%5*u4q*k*H0^0lAtQXQ-1l}za7&Hr=`Odx9a$q{W<*9Qdf(&kN;Q~D zRHiQ@Z;U_81yCz6ALLq6Emv_*1dx-kDT?wVED$T#CjT8a48$kwkhV}X66GNdL!n5d z)Qf35LnNifM({BM8d>MZ5GP%5K3K?qke+IJj51XZV!Zq*Ex|9H{o|%l-FM9iS*qOCY1*Nwwl~C_&*paL^f4hg3wuO7Tp*Q<8zs z+q?N{eyZJ#tB=jIM7N4Qegu;+9Ar(+IZb?F%8A!MW5`Uz&<7#z;Rr*+?QVIZo!lHe zNH7K%4c#1pG6dY~3R+sU7&eOR$)9gyZ&6jrzQx-Q(soWzP-b-$B`=T|jys2AV(=L( zG-6ca{pe8neA&uJaTD`$ZdbC=;q~0Chs^t7px2dc%d&G3Wh`BTV;YRy1e^Jk8+e!4d3+^nwl>9<{2fA=1Lab zv5U5!Te)51IQ)9$4AQ6s?LH~oSBWp%dXDhUyb~GGrJb7t$-U6&qF4?OT^B>thS_$k z`T7L$Zx!-yfmO-Lp8+zaJrjK%mG5)Grf0u2>uD)-B8xn}$$S73xRmqP~qr!tYdJv;1de&-h zVYO;-dpP?OWEBSBbbj*s-3&vEq-e&#rEHeDLyQ*L7@5G6Q??Cf9jSM@D$^@6c@^<=L=}7xqoYs)gX#=fyn2R!iS=Hu$8s7_U|h9xAM7 z4C5SG2)D*KVv!Vfj1#oh-L~l&530|`2GjRP?sam~;34$kwEa9EvV8#qU5imiGT_O{ z5&p0XPv}EFEYq8Q2a+gd7S_qnNbE7qr+-H&+W(`Jr!NBj7nk~P_s5J#Ff{XR(j{*o zreZZ&Zd3**MaUuJ>KnonOjfgcydT+FVZiUN`kZ<(-HNHRMil7@o3FW*Ce^=@vikJH zUa3}SSyM=^A!kZLKuSp^4Wkb z+94)jZ6jFM+QH zi>n<0Lag2@Z-C=fO@QMov{xfk7!GV6^vJ!fS>^WFCJNNna+hLH7KxmWldgfC6((1j`9eM|!fUpwrW95`>=t0Q65*tqLQb%To4}1cL zd(CnZ@|*Fv zUHE{giyS{6B}H`gpO-!8?uMyX9+`U;!SbUH|-A*SV5Tr zFS8J~+4S#SIl}k9M#U1{rFaGq^ zbAba1zTLch3D`2Hw)3ZB_-N@Y_Y7qBtTnD`sz~MlY$n{sUd#DDRpE~|)zyrZgOu#I znNd?ah|@acH!MGYWw}}flKFx90+_lzJvWIScpxzHITu?Q$(2G72b2J`o2~B;-R#T9 zziUviKX{n@BM|hhXWmt7n8v&D0hYj7r4Tu^5HkMkTj5bb%i(AcN*<#2=9VwlY>iGJ zMG;$L{q9E^5;i!1V%!^I3g2dwLK@A@N6&#IB?i3uLY;Gj2n6@>sRr z3P$-Q&oHfa>a!)Ha`LrHNnSj;t@V?`{l4rPzd7}E%W9T@0ro5mrcSCk;1YU6^R`!E zU%0qm&ITTx^T_mh=C`0gl|c6IbtA8{y8JD!j&l@5jWZ{Heess9ia;IgS7E4Wwzp%P z)Gs7z!Gd?9EA@gRMU%v)b9w3Q*mkkJ{WpRXEbadkSqrl)Fa{s%&%A;!0!Q3wj{Dy< zEBmiaR%BHN)&k!qgIo4v1OvVoplc*b6P=WQiBC#|EmZ*8=cAPADt z&cpRGnlu^XYshCkpF!U&bKS(K*4bk^WDBidNn-a6-;yXU z(L7uD&V27T6ZW9`%ksv8Wl3$Y+$pDw0>O+JQNmt{cj4#zS~&!7x&oxf%$N+;>~q=t zO0t`BaoRnr!g)ELis-bg!f||#Cqnq)Q-t}X4093glKaDuCjLKS!^FbbnKlI^uk+4# z@?Nhfc4f)vH_8g*kvwk$0fnh4 z-Q|GVvDHIowuHeNBPZ!Xvs> zno;OYEUcA*UBWJyMoDU>BifTzmT5#o7g@}y&LWRfJ}Zx#b7LzU8M-nHi2_R!W>Fxy z%OE-4guzbYmSYAQB~pZ#CPJ@Kay?d#SGcUJ!8N-b?b$EO1khxlI(X%*3|Gj{-#?^`e8{a&e^u|~G&7M|O?q*gy**m@uz1pZ# zKRi|3`^Th{(ejpOY-y6yg}0@2Rg=v!e*RBtu<0_1MaO^n!?}gdKk)!EvJh6%3^_&4 zO!m{ApY)C-cmAL8KfL;{3!F4qB#Zeo?h`xj3B&no;z=Vz@?SqAh1iyUbz{F~pOo+< zv-2~Yh?V|3`~R)aujwb{8cFB>jHg5s{l8TIuPdA!%p_TNB8a1!w8Fnd-mj@AM-yps z{|poAzfw;QqF<9w_HNSj`WbO&{!0FbS@!EXCrLr-^grV%@feBwCvD=t`aV?WG$rXt OYT`$QcueVk?f+k6et~fS