如何在服务中读取数据并监听 Room 数据库的变化？

Question

我将用户信息存储在本地会议室数据库中。在活动和片段中，我使用 AndroidViewModel 和 LiveData 来监听对数据库所做的更改并更新 UI。

现在我想分析所有过去的用户数据，为未来的决策提供建议。我的建议会随着用户对数据库所做的每一次更改而改变，因此我需要经常更新我的建议，同时一遍又一遍地进行相同的计算。

我正在考虑在应用启动时启动一项服务，该服务通过 ViewModel 和 LiveData 侦听数据库更改并更新我的建议（这些建议也存储在同一个数据库中）。但不知何故，服务不能

1. 通过viewModel = ViewModelProviders.of(this).get(DataViewModel.class); 获取 ViewModel
2. 观察 LiveData 对象，因为它不是 LifecycleOwner。

基本上我只需要从数据库中读取所有条目，分析数据并在每次数据库内容更改时更新 5-10 个值。

如果不在服务中，我应该如何以及在哪里进行计算？也许我陷入了错误的想法，而服务不是正确的方法，因此非常感谢任何关于如何做到这一点的想法！

Answer 1

观察 LiveData 对象，因为它不是 LifecycleOwner

在LiveData 上使用observeForever()，在适当的时候通过removeObserver() 手动取消注册（服务的onDestroy()，如果不是更早的话）。

请记住，此处适用标准服务限制（例如，服务在 Android 8.0+ 上运行约 1 分钟，除非它们是前台服务），因此您可能需要考虑其他方法。

Answer 2

我最终使用了一项服务并解决了我的问题，如下所示：

在我的Application object 的onCreate 方法中，我将MyService 绑定到它：

serviceConnection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName name, IBinder iBinder) {
            service = ((MyService.MyLocalBinder) iBinder ).getService();
        }
        @Override
        public void onServiceDisconnected(ComponentName name) {
        }
    };
Intent intent = new Intent(this, MyService.class);
getApplicationContext().bindService(intent, serviceConnection, BIND_AUTO_CREATE);

只要应用程序没有被破坏，将服务绑定到应用程序上下文就应该使服务保持活动状态。在MyService 中，我通过AndroidViewModelFactory 获得了一个ViewModel 实例，如下所示

MyViewModel myViewModel = ViewModelProvider.AndroidViewModelFactory.getInstance(getApplication()).create(MyViewModel.class);

我可以像这样通过observeForever 观察从 ViewModel 获取的 LiveData

Observer<List<Entry>> obsEntries = new Observer<List<Entry>>() {
        @Override
        public void onChanged(@Nullable List<Entry> entries) {
            //perform calculations with entries in here
        }
    };
    viewModel.getEntries().observeForever(obsEntries);

重要提示：从 Service 的 onDestroy 中的 LiveData 引用中删除观察者（这就是我保留对 Observer 对象的本地引用的原因）：

@Override
public void onDestroy() {
    super.onDestroy();
    viewModel.getEntries().removeObserver(obsEntries);
}

谢谢大家！

Answer 3

Entity 中没有任何改变。

在 DAO 中，例如

@Dao
public interface TimeDao {
    //    ...
    //    ...

    // for a started Service using startService() in background
    @Query("select * from times where name = :bName")
    List<TimeEntity> getServiceTimes(String bName);

}

这不是 LiveData

在数据库中，例如，

@Database(entities = {DataEntity.class, TimeEntity.class}, version = 1)
public abstract class BrRoomDatabase extends RoomDatabase {

    public abstract TimeDao iTimeDao();

    public static BrRoomDatabase getDatabase(final Context context) {

        if (INSTANCE == null) {        
            //          ...
        }
        return INSTANCE;
    }
}

一个接口类

public interface SyncServiceSupport {
    List<TimeEntity> getTimesEntities(String brName);
}

它的实现类。

public class SyncServiceSupportImpl implements SyncServiceSupport {

    private TimeDao timeDao;

    public SyncServiceSupportImpl(Context context) {

        timeDao = BrRoomDatabase.getDatabase(context).iTimeDao(); 
        // getDatabase() from where we get DB instance.
        // .. and .. 
        // public abstract TimeDao iTimeDao();  <= defined abstract type in RoomDatabase abstract class
    }

    @Override
    public List<TimeEntity> getTimesEntities(String name) {
        return timeDao.getServiceTimes(name);
    }

}

最后……在服务中……

public class SyncService extends Service {

    //..

    // now, iEntities will have a List of TimeEntity objects from DB .. 
    // .. retrieved using @Query 

    private static List<TimeEntity> iEntities = new ArrayList<>();  
    private static SyncServiceSupportImpl iSyncService;

    private static void getFromDB(String brName) {

        new AsyncTask<String, Void, Void>() {
            @Override
            protected Void doInBackground(String... params) {
                iEntities = iSyncService.getTimesEntities(params[0]);
                return null;
            }

            @Override
            protected void onPostExecute(Void agentsCount) {

            }
        }.execute(brName);
    }

    @Override
    public void onCreate() {
        super.onCreate();

        //init service
        iSyncService = new SyncServiceSupportImpl(SyncService.this);

    }

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {

        // this can be elsewhere also !..

        getFromDB(myName);
    }

}