提供常用工具类,redis分布式锁，redis分布式任务发布订阅，注解实体缓存，表达式解析器，poi工具类封装，反射工具，包扫描器，多线程任务等。并且在Spring boot环境下，自动配置。
- redis 分布式锁
- redis分布式任务发布订阅
- 注解实体缓存
- mybatis环境下使用
- ...
- 表达式解析器
- 导入静态方法
- 测试表达式
- 用例
- 可重入锁 -- ReentrantRedisLock
特点：可重入 - 多路径锁 -- MultiPathRedisLock
特点：一次性可对多个path上锁，只要有一个path被其他线程持有，则获取锁失败 - 二级锁 -- SecondLevelRedisLock
特点：一级锁被占用，则任务二级锁获取失败；二级锁被占用，则一级锁获取失败，但不会阻塞其他线程获取其他二级锁。
Spring环境静下，无需其他配置，自动整合spring-boot-starter-data-redis，通过redisTemplate的api实现redis操作。
try (RedisLock redisLock = new ReentrantRedisLock("test")) {
if (redisLock.tryLock(1000, 1000, TimeUnit.MILLISECONDS)) {
System.out.println("获取锁成功");
}
} catch (Exception e) {
e.printStackTrace();
}注意： RedisLock继承了AutoCloseable，在try中创建实例会自动调用Close释放锁。
非Spring环境下，需要配置jedis工厂、将JedisManagerFactory实例配置到RedisConfiguration中即可使用。
// 配置jedis工厂
JedisClientFactory factory = new JedisClientFactory("localhost", null, null, null);
// 从工厂中获取jedisClient
JedisClient jedisClient = factory.cacheClient();
JedisManagerFactory jedisLockFactory = new JedisManagerFactory(jedisClient);
// 设置全局redis manager为jedis实现类
RedisConfiguration.setDefaultRedisManagerFactory(jedisLockFactory);
// 完成初始化，之后可在任意位置直接使用：
try (RedisLock redisLock = new ReentrantRedisLock("test")) {
if (redisLock.tryLock(1000, 1000, TimeUnit.MILLISECONDS)) {
System.out.println("获取锁成功");
}
} catch (Exception e) {
e.printStackTrace();
}Spring环境静下，无需其他配置
- 任务发布 -- ClusterTaskPublisher
发布任务api发布任务实例:/** * 发布集群任务 * * @param taskId 任务ID * @param dataNums 待处理数据个数 * @param stepSize 步长 * @param concurrentNums 单个服务器并发数量 * @param desc 是否倒序 * @param header 任务头部信息 */ publish(taskId, dataNums, stepSize, concurrentNums, desc, header);
// 注入任务发布者 @Resource(name = "clusterTaskPublisher") private ClusterTaskPublisher clusterTaskPublisher; // 调用sql查询待处理数据量 int dataNums = dataMapper.countData(); // 发布了一个数据量为dataNums的任务，指定一个分片（分页）100条数据并且倒序分配，并且指定订阅者开启6条线程执行任务 clusterTaskPublisher.publish("test", dataNums, 100, 6, true, null);
- 任务订阅 -- 继承AbstractClusterTaskSubscriber
可由多个服务器节点订阅任务信息，多个节点多线程执行任务，充分利用服务器资源。@Component @SubTask(taskId = "test") public class TestSub extends AbstractClusterTaskSubscriber { @Override public void subscribe(TaskInfo taskInfo, Limit limit) { // limit为分页的封装对象，num即为分页开始数,size即为分页大小, // 假设前面发布了一个300条数据量的任务，由于前面发布的任务是倒序， // 那么第一次执行任务的num为200,size为100，第二个为{100,100}，第三个为{0,100}。 dataMapper.queryData(limit.getNum,limit.getSize); } /** * 所有分片任务执行完将回调此方法 */ @Override public void afterAllTask() { System.out.println("finish task"); } }
- 特殊用法 -- 利用header构造任务
Map<String, Object> header = new HashMap<>(); ArrayList<String> list = new ArrayList<>(); list.add("task1"); list.add("task2"); list.add("task3"); list.add("task4"); list.add("task5"); list.add("task6"); header.put("taskEnum", list); clusterTaskPublisher.publish("test2", list.size(), 1, 1, true, header); return JsonMessage.success("123"); // 订阅方法 @Override public void subscribe(TaskInfo taskInfo, Limit limit) { Map<String, Object> header = taskInfo.getHeader(); ArrayList<String> taskEnum = (List<String>)header.get("taskEnum"); int num = limit.getNum(); String taskEnum = taskEnum.get(num); swtich(taskEnum){ // 捕获不同的任务枚举，执行不同的任务 case "task1": ... case "task2": ... case "task3": ... case "task4": ... case "task5": ... case "task6": ... } }
- 配置并初始化
与配置redis分布式锁类型，但需要调用JedisClusterHelper.initJedisCluster(factory)初始化任务发布订阅器。其他与spring环境下使用情况一致。JedisClientFactory factory = new JedisClientFactory("localhost", null, null, null); JedisClient jedisClient = factory.cacheClient(); RedisConfiguration.setDefaultRedisManagerFactory(new JedisManagerFactory(jedisClient)); ClusterTaskPublisher clusterTaskPublisher = JedisClusterHelper.initJedisCluster(factory); clusterTaskPublisher.publish("test", 100, 10, 1, true); Thread.sleep(10000);
// TODO