如何停用未使用的OSGI服务？组件如何检测闲置并停止活动？

针对你遇到的Eclipse DS违反OSGi规范、单例组件无引用时不自动停用的问题，这里提供几个可行的解决方案：

方案一：手动跟踪服务引用计数（推荐，无需全局修改） #

通过在组件中维护引用计数器，结合服务的绑定/解绑回调来控制轮询的启动与停止，完全避开DS的默认行为问题：

代码示例 #

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import org.osgi.service.component.annotations.Activate;
import org.osgi.service.component.annotations.Deactivate;
import org.osgi.service.component.annotations.Reference;
import org.osgi.service.component.annotations.ReferenceCardinality;
import org.osgi.service.component.annotations.ReferencePolicy;

public class PollingComponent {
    private final AtomicInteger clientReferenceCount = new AtomicInteger(0);
    private ScheduledExecutorService pollingExecutor;
    private ScheduledFuture<?> pollingTask;

    @Activate
    void activate() {
        // 初始化线程池，暂不启动轮询
        pollingExecutor = Executors.newSingleThreadScheduledExecutor();
    }

    @Deactivate
    void deactivate() {
        // 组件销毁时清理资源
        if (pollingTask != null) {
            pollingTask.cancel(true);
        }
        pollingExecutor.shutdownNow();
    }

    // 绑定客户端引用时触发
    @Reference(
        cardinality = ReferenceCardinality.MULTIPLE,
        policy = ReferencePolicy.DYNAMIC,
        bind = "bindClient",
        unbind = "unbindClient"
    )
    void bindClient(YourClientInterface client) {
        int currentCount = clientReferenceCount.incrementAndGet();
        // 第一个客户端绑定，启动轮询
        if (currentCount == 1) {
            pollingTask = pollingExecutor.scheduleAtFixedRate(
                this::executePolling,
                0, 5, TimeUnit.SECONDS // 按实际需求调整轮询间隔
            );
        }
    }

    // 解绑客户端引用时触发
    void unbindClient(YourClientInterface client) {
        int currentCount = clientReferenceCount.decrementAndGet();
        // 最后一个客户端解绑，停止轮询
        if (currentCount == 0 && pollingTask != null) {
            pollingTask.cancel(true);
            pollingTask = null;
        }
    }

    // 实际的REST轮询逻辑
    private void executePolling() {
        // 调用远程REST端点的代码
    }
}

组件声明（保持单例） #

<component name="PollingComponent" scope="singleton">
    <service>
        <provide interface="com.yourpackage.PollingService"/>
    </service>
    <reference 
        name="ClientInterface" 
        interface="com.yourpackage.YourClientInterface"
        cardinality="0..n" 
        policy="dynamic" 
        bind="bindClient" 
        unbind="unbindClient"
    />
</component>

这个方案的优势是不依赖全局配置，仅针对当前组件生效，线程安全且逻辑清晰。

方案二：修改DS框架属性（恢复OSGi规范行为） #

如果允许调整Eclipse的启动参数，可以通过关闭ds.delayed.keepInstances来让DS遵循OSGi规范，在单例组件无引用时自动调用@Deactivate方法：

操作步骤 #

在Eclipse的启动配置（或产品启动脚本）中添加VM参数：

-Dds.delayed.keepInstances=false

组件代码简化 #

此时组件可以直接利用生命周期回调控制轮询：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import org.osgi.service.component.annotations.Activate;
import org.osgi.service.component.annotations.Deactivate;

public class PollingComponent {
    private ScheduledExecutorService pollingExecutor;
    private ScheduledFuture<?> pollingTask;

    @Activate
    void activate() {
        // 组件激活时启动轮询
        pollingExecutor = Executors.newSingleThreadScheduledExecutor();
        pollingTask = pollingExecutor.scheduleAtFixedRate(
            this::executePolling,
            0, 5, TimeUnit.SECONDS
        );
    }

    @Deactivate
    void deactivate() {
        // 组件停用时停止轮询并清理资源
        if (pollingTask != null) {
            pollingTask.cancel(true);
        }
        pollingExecutor.shutdownNow();
    }

    private void executePolling() {
        // REST轮询逻辑
    }
}

注意事项 #

• 该设置是全局生效的，可能影响其他依赖DS延迟停用特性的组件，需要充分测试。
• 如果是在Eclipse IDE中运行插件，需在「运行配置」→「Arguments」→「VM arguments」中添加上述参数。

不推荐的方案说明 #

你之前使用的scope="bundle"会为每个引用的Bundle创建独立组件实例，导致多轮询线程，完全不符合单例轮询的需求，应避免使用。

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