分布式集成

本文详细讲解如何集成 FlowLong 分布式相关内容。

数据层

默认采用 MybatisPlus 雪花ID 生成器，确保在分布式数据环境下 主键ID 的唯一性。

应用层

集成 FlowLong 框架层面保持操作的原子性。

分布式缓存

更多查看 模型缓存 说明

• 实现 FlowCache 缓存接口，确保在分布式数据环境下缓存数据一致性。缓存内容主要包括模型数据等，确保运行更加高效。

// 默认采用 `ConcurrentHashMap` 实现本地缓存
public interface FlowCache {
    ...
}

分布式任务锁

需要注意的是，在分布式环境下调用 FlowLong 相关方法，业务层面也需要加锁，防止任务并发执行。

• 实现 JobLock 任务执行锁接口，为任务执行提供分布式锁，确保任务执行一致性。

// 默认采用 `ReentrantLock` 实现本地锁
public interface JobLock {
    ...
}

分布式定时任务

更多查看 定时调度 说明

• 继成 FlowLongScheduler 抽象类，实现分布式任务调度功能，该功能主要实现了延时通知触发器等功能。

// 默认采用 `Spring Boot` `SchedulingConfigurer` 实现单机定时调度
public abstract class FlowLongScheduler {
    ...
}