如何在后台Service中使用Room数据库？LifecycleOwner参数疑问

Service默认没有实现LifecycleOwner接口，无法直接像Fragment/Activity那样传入自身作为参数。这里提供两种可行方案：

方案一：使用observeForever（快速实现） #

直接调用LiveData的observeForever方法，该方法不需要传入LifecycleOwner，但必须在Service销毁时手动移除观察者，避免内存泄漏。

示例代码：

private Observer<List<PendingTransaction>> transactionObserver;

@Override
public int onStartCommand(Intent intent, int flags, int startId) {
    mApplication = getApplication();
    pendingTransactionRepository = new PendingTransactionRepository(mApplication);

    // 初始化观察者
    transactionObserver = new Observer<List<PendingTransaction>>() {
        @Override
        public void onChanged(List<PendingTransaction> pendingTransactions) {
            int count = pendingTransactions.size();
            Log.i("LOG", String.valueOf(count));
        }
    };
    // 使用observeForever注册观察者
    pendingTransactionRepository.pendingTransactionBySendStatus().observeForever(transactionObserver);

    setupLiveData();
    return super.onStartCommand(intent, flags, startId);
}

@Override
public void onDestroy() {
    super.onDestroy();
    // 必须移除观察者，防止内存泄漏
    if (transactionObserver != null) {
        pendingTransactionRepository.pendingTransactionBySendStatus().removeObserver(transactionObserver);
    }
}

方案二：让Service实现LifecycleOwner接口（规范生命周期管理） #

通过LifecycleRegistry让Service实现LifecycleOwner接口，这样就能直接将Service自身作为LifecycleOwner传入observe方法，LiveData会自动根据Service的生命周期管理观察者状态。

示例代码：

public class YourService extends Service implements LifecycleOwner {
    private LifecycleRegistry lifecycleRegistry;

    @Override
    public void onCreate() {
        super.onCreate();
        lifecycleRegistry = new LifecycleRegistry(this);
        lifecycleRegistry.markState(Lifecycle.State.CREATED);
    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        lifecycleRegistry.markState(Lifecycle.State.STARTED);
        mApplication = getApplication();
        pendingTransactionRepository = new PendingTransactionRepository(mApplication);

        // 直接传入this作为LifecycleOwner
        pendingTransactionRepository.pendingTransactionBySendStatus().observe(this, new Observer<List<PendingTransaction>>() {
            @Override
            public void onChanged(List<PendingTransaction> pendingTransactions) {
                int count = pendingTransactions.size();
                Log.i("LOG", String.valueOf(count));
            }
        });

        setupLiveData();
        return super.onStartCommand(intent, flags, startId);
    }

    @Override
    public void onDestroy() {
        lifecycleRegistry.markState(Lifecycle.State.DESTROYED);
        super.onDestroy();
    }

    @NonNull
    @Override
    public Lifecycle getLifecycle() {
        return lifecycleRegistry;
    }
}

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