多节点Spring Boot进程同时读写单表的解决方案咨询

如果需要让多节点上的所有进程同时执行任务，而非像ShedLock那样限制单节点执行，以下是几种可行的方案：

1. 消息队列广播模式 #

利用消息队列的广播特性，将任务触发信号同步发送给所有节点的进程：

• 使用RabbitMQ的fanout交换机：无需路由键，所有绑定到该交换机的队列都会收到消息，每个节点的进程监听专属队列，收到消息后立即执行任务。
• 使用Kafka主题：所有节点的进程订阅同一个主题，当生产者发送任务触发消息时，所有订阅者都会收到并执行任务。
  示例伪代码（RabbitMQ）：

// 声明fanout交换机
channel.exchangeDeclare("task_broadcast", "fanout");
// 每个节点创建独立队列并绑定到交换机
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName, "task_broadcast", "");
// 消费消息执行任务
channel.basicConsume(queueName, true, (consumerTag, delivery) -> {
    String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
    executeTask(); // 执行本地任务
}, consumerTag -> {});

2. 中心触发+节点本地执行 #

通过一个中心服务统一触发所有节点的任务：

• 基于服务发现（如Consul、Nacos）：中心服务获取所有在线节点的地址，同时调用每个节点的任务触发接口，触发本地任务执行。
• 利用Spring Cloud Bus：通过自定义事件，将任务触发信号广播到所有Spring Cloud节点，节点监听事件后执行任务。

3. 分布式Pub/Sub通知 #

借助分布式工具的发布订阅能力实现全局通知：

• Redis Pub/Sub：在触发节点发布任务消息，所有节点的进程订阅对应频道，收到消息后立即执行任务。
• ZooKeeper Watcher：在ZK上创建一个临时节点作为触发信号，所有节点监听该节点的创建事件，一旦检测到节点创建，立即执行任务，任务完成后删除节点以便下次触发。

这些方案的核心是同步触发信号到所有节点，确保所有进程同时启动任务执行，无需分布式锁限制单节点访问。

内容的提问来源于stack exchange，提问作者sonnv0812