binlog 同步队列去除初始化大小，休眠时间缩短，警格表去除数据同步

zhongrj

2024-04-02 bd7035535abfda6be9ce792fb725d0d754ed42e3

 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) {