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