From bd7035535abfda6be9ce792fb725d0d754ed42e3 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 02 Apr 2024 11:02:30 +0800
Subject: [PATCH] binlog 同步队列去除初始化大小，休眠时间缩短，警格表去除数据同步
---
src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java b/src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java
index 3f11eab..db53ef0 100644
--- a/src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java
+++ b/src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java
@@ -56,7 +56,7 @@
);
client.setEventDeserializer(eventDeserializer);
this.parseClient = client;
- this.queue = new ArrayBlockingQueue<>(1024);
+ this.queue = new LinkedBlockingQueue<>();
this.conf = conf;
this.listeners = ArrayListMultimap.create();
this.dbTableCols = new ConcurrentHashMap<>();
@@ -145,8 +145,10 @@
consumer.submit(() -> {
while (true) {
if (queue.size() > 0) {
+ log.info("队列个数1：" + queue.size());
try {
BinLogItem item = queue.take();
+ log.info("队列个数2：" + queue.size());
String dbtable = item.getDbTable();
listeners.get(dbtable).forEach(binLogListener -> binLogListener.onEvent(item));
} catch (InterruptedException e) {
--
Gitblit v1.9.3