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/resources/application-prod.yml | 2 +-
src/main/java/org/springblade/binlog/constant/BinLogConstants.java | 3 ++-
src/main/java/org/springblade/binlog/listener/MysqlBinLogListener.java | 4 +++-
3 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/src/main/java/org/springblade/binlog/constant/BinLogConstants.java b/src/main/java/org/springblade/binlog/constant/BinLogConstants.java
index 797afc5..446c3fd 100644
--- a/src/main/java/org/springblade/binlog/constant/BinLogConstants.java
+++ b/src/main/java/org/springblade/binlog/constant/BinLogConstants.java
@@ -42,7 +42,8 @@
public static final int consumerThreads = 5;
- public static final long queueSleep = 1000;
+// public static final long queueSleep = 1000;
+ public static final long queueSleep = 200;
}
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) {
diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml
index e591993..5fe5c19 100644
--- a/src/main/resources/application-prod.yml
+++ b/src/main/resources/application-prod.yml
@@ -47,7 +47,7 @@
username: root
password: 1qaz@WSX3edc
db: jczz # 监听数据库
- table: jczz_house,jczz_household,jczz_house_rental,jczz_user_house_label,jczz_label,jczz_place,jczz_place_check,jczz_place_door,jczz_place_ext,jczz_place_poi_label,jczz_place_practitioner,jczz_police_affairs_grid,jczz_task_label_reporting_event,jczz_patrol_group,jczz_patrol_group_item,jczz_patrol_record,blade_attach_data,jczz_category,jczz_grid,jczz_backblast_pub_record,jczz_backblast_warn_han_rec,jczz_dispute_record,jczz_police_alarm_records,jczz_task_residence_permit_apply
+ table: jczz_house,jczz_household,jczz_house_rental,jczz_user_house_label,jczz_label,jczz_place,jczz_place_check,jczz_place_door,jczz_place_ext,jczz_place_poi_label,jczz_place_practitioner,jczz_task_label_reporting_event,jczz_patrol_group,jczz_patrol_group_item,jczz_patrol_record,blade_attach_data,jczz_category,jczz_grid,jczz_backblast_pub_record,jczz_backblast_warn_han_rec,jczz_dispute_record,jczz_police_alarm_records,jczz_task_residence_permit_apply
# table: blade_attach_data
enabled: true
# 目标数据库
--
Gitblit v1.9.3