shardingsphere ui 状态为离线,但应用程序运行成功
作者: GoyacJ创建于 2023年4月7日更新于 2026年7月3日
标签uivolunteer wanted
org.apache.shardingsphere.elasticjob
elasticjob-lite-spring-boot-starter
3.0.3
curator-recipes
org.apache.curator
curator-framework
org.apache.curator
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>5.1.0</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-recipes</artifactId>
<version>5.1.0</version>
</dependency>
@Component
@Slf4j
@RequiredArgsConstructor
public class SignDataFlowJob implements DataflowJob<UploadInfo> {
private final UploadInfoService uploadInfoService;
private final BaseServiceFeign baseServiceFeign;
private final TransferDataFactory transferDataFactory;
@Override
public List<UploadInfo> fetchData(ShardingContext shardingContext) {
// default to only one shard
int shardingTotalCount = shardingContext.getShardingTotalCount();
if (shardingTotalCount > 1) {
return null;
}
log.info("Current fetch task shard: {}", shardingTotalCount);
return uploadInfoService.schedulerUpload(count);
}
@Override
public void processData(ShardingContext shardingContext, List<UploadInfo> uploadInfoList) {
log.info("Current process data task shard: {}", shardingContext.getShardingTotalCount());
// ...
}
}内容来源: apache/shardingsphere-elasticjob