Cumulocity多线程调用Platform API报Not within any context异常求助

问题原因 #

你注入的Platform bean是tenant作用域的，它的生效依赖当前线程的租户上下文。subscriptionsService.runForEachTenant()会在主线程中设置租户上下文，但通过ExecutorService提交的异步任务在新线程执行时，不会继承主线程的租户上下文，导致无法获取tenant-scoped的Platform实例，从而抛出Scope 'tenant' is not active异常。

解决方案 #

1. 使用租户ID获取专属Platform实例 #

不要直接依赖全局注入的platform，而是通过subscriptionsService.getPlatformForTenant(tenantId)获取当前租户绑定的Platform实例，该实例不依赖线程上下文，直接关联指定租户。

2. 复用线程池 #

避免在分页循环中重复创建ExecutorService，全局初始化一个可复用的线程池，减少线程创建销毁的性能损耗。

3. 优化列表分割逻辑 #

原分割方法在列表长度无法被线程数整除时会丢失部分数据，调整为向上取整的分割方式，确保所有元素都被覆盖。

修改后的代码示例 #

@Autowired
private MicroserviceSubscriptionsService subscriptionsService;

// 全局复用线程池，根据业务场景调整核心线程数
private final ExecutorService es = Executors.newFixedThreadPool(20);

public void generateDeviceReports() {
    subscriptionsService.runForEachTenant(() -> {
        // 分页获取当前租户的设备列表
        ManagedObjectCollectionRepresentation managedObjCol = managedObjectCollection.get(500, new QueryParam(PagingParam.WITH_TOTAL_PAGES, "true"));
        String currentTenantId = subscriptionsService.getTenant();
        
        for (int page = 1; page <= managedObjCol.getPageStatistics().getTotalPages(); page++) {
            List<ManagedObjectRepresentation> managedObjList = managedObjectCollection.getPage(managedObjCol, page).getManagedObjects();
            
            // 将当前页设备列表分割为20个子列表
            List<List<ManagedObjectRepresentation>> subLists = splitList(managedObjList, 20);
            
            // 提交异步任务处理每个子列表
            for (List<ManagedObjectRepresentation> sublist : subLists) {
                es.submit(() -> {
                    try {
                        // 获取当前租户专属的Platform实例
                        Platform tenantPlatform = subscriptionsService.getPlatformForTenant(currentTenantId);
                        
                        for (ManagedObjectRepresentation mObjRep : sublist) {
                            OperationFilter operPendingFilter = new OperationFilter()
                                    .byStatus(OperationStatus.PENDING)
                                    .byDevice(mObjRep.getId().getValue());
                            
                            Iterable<OperationRepresentation> devCtr = tenantPlatform.getDeviceControlApi()
                                    .getOperationsByFilter(operPendingFilter)
                                    .get(2000)
                                    .allPages();
                            
                            List<OperationRepresentation> pendingOperRep = StreamSupport.stream(devCtr.spliterator(), false)
                                    .collect(Collectors.toList());
                            
                            // 此处添加报表生成逻辑
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                });
            }
        }
    });
}

// 优化的列表分割方法，确保所有元素被覆盖
private <T> List<List<T>> splitList(List<T> list, int numParts) {
    List<List<T>> result = new ArrayList<>();
    int totalSize = list.size();
    int partSize = (totalSize + numParts - 1) / numParts; // 向上取整计算每个子列表大小
    
    for (int i = 0; i < numParts; i++) {
        int startIndex = i * partSize;
        int endIndex = Math.min(startIndex + partSize, totalSize);
        if (startIndex < endIndex) {
            result.add(list.subList(startIndex, endIndex));
        }
    }
    return result;
}

// 应用关闭时优雅关闭线程池
@PreDestroy
public void shutdownExecutor() {
    es.shutdown();
    try {
        if (!es.awaitTermination(60, TimeUnit.SECONDS)) {
            es.shutdownNow();
        }
    } catch (InterruptedException e) {
        es.shutdownNow();
    }
}

额外注意事项 #

• 线程池参数需根据服务器资源和业务量调整，避免固定线程池导致资源耗尽；
• 若需要更精细的线程控制，建议使用ThreadPoolExecutor自定义核心线程数、最大线程数、队列容量等参数。

内容的提问来源于stack exchange，提问作者Datta Sai