Elastic-Job任务类
生活随笔
收集整理的這篇文章主要介紹了
Elastic-Job任务类
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
/*** 數(shù)據(jù)查詢?nèi)蝿?wù)**/
@Component
public class MyJob implements SimpleJob {@Autowiredprivate UserMapper userMapper;//執(zhí)行定時任務(wù)@Overridepublic void execute(ShardingContext shardingContext) {//得到分片總數(shù)int count = shardingContext.getShardingTotalCount();//得到分片項int item = shardingContext.getShardingItem();//查詢數(shù)據(jù)List<User> userList = userMapper.queryUserById(count,item);//輸出結(jié)果userList.forEach(user -> {System.out.println("作業(yè)分片:"+item+"--->"+user);});}
}
總結(jié)
以上是生活随笔為你收集整理的Elastic-Job任务类的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Elastic-Job重要概念
- 下一篇: zookeeper注册中心