我正在编写我的第一个Android应用程序,试图弄清楚服务和活动之间的通信。我有一个服务,将在后台运行,并做一些gps和基于时间的日志记录。我将有一个活动,将用于启动和停止服务。

因此,首先,我需要能够确定当活动启动时服务是否正在运行。这里还有一些其他的问题,所以我想我可以解决(但请随意提供建议)。

My real problem: if the Activity is running and the Service is started, I need a way for the Service to send messages to the Activity. Simple Strings and integers at this point - status messages mostly. The messages will not happen regularly, so I don't think polling the service is a good way to go if there is another way. I only want this communication when the Activity has been started by the user - I don't want to start the Activity from the Service. In other words, if you start the Activity and the Service is running, you will see some status messages in the Activity UI when something interesting happens. If you don't start the Activity, you will not see these messages (they're not that interesting).

似乎我应该能够确定服务是否正在运行,如果是的话,将活动添加为侦听器。然后在Activity暂停或停止时删除Activity作为监听器。这真的可能吗?我能想出的唯一方法是让活动实现Parcelable并构建一个AIDL文件,这样我就可以通过服务的远程接口传递它。这似乎是多余的,但我不知道活动应该如何实现writeToParcel() / readFromParcel()。

有没有更简单或更好的方法?谢谢你的帮助。

编辑:

对于稍后对此感兴趣的人来说,在示例目录:/apis/app/RemoteService.java中有来自谷歌的通过AIDL处理此问题的示例代码


当前回答

正如Madhur提到的,您可以使用总线进行通信。

在使用总线的情况下,您有一些选择:

Otto事件总线库(已弃用,支持RxJava)

http://square.github.io/otto/

绿色机器人的EventBus

http://greenrobot.org/eventbus/

NYBus (RxBus,使用RxJava实现。非常类似于EventBus)

https://github.com/MindorksOpenSource/NYBus

其他回答

正如Madhur提到的,您可以使用总线进行通信。

在使用总线的情况下,您有一些选择:

Otto事件总线库(已弃用,支持RxJava)

http://square.github.io/otto/

绿色机器人的EventBus

http://greenrobot.org/eventbus/

NYBus (RxBus,使用RxJava实现。非常类似于EventBus)

https://github.com/MindorksOpenSource/NYBus

使用LocalBroadcastManager注册一个接收器来监听本地服务在你的应用内发送的广播,参考如下:

http://developer.android.com/reference/android/support/v4/content/LocalBroadcastManager.html

提问者可能早就跳过了这个,但以防其他人搜索这个…

还有另一种处理方法,我认为可能是最简单的。

为您的活动添加一个BroadcastReceiver。注册它来接收一些自定义意图在onResume和取消注册它在onPause。然后当你想要发送状态更新或其他信息时,从你的服务中发送意图。

确保如果其他应用程序监听了你的意图(有人会做任何恶意的事情吗?),你不会不高兴,但除此之外,你应该没问题。

代码示例:

在我的工作中,我有这个:

// Do stuff that alters the content of my local SQLite Database
sendBroadcast(new Intent(RefreshTask.REFRESH_DATA_INTENT));

(RefreshTask。REFRESH_DATA_INTENT只是一个常量字符串。)

在我的监听活动中,我定义了BroadcastReceiver:

private class DataUpdateReceiver extends BroadcastReceiver {
    @Override
    public void onReceive(Context context, Intent intent) {
        if (intent.getAction().equals(RefreshTask.REFRESH_DATA_INTENT)) {
          // Do stuff - maybe update my view based on the changed DB contents
        }
    }
}

我在类的顶部声明了我的接收者:

private DataUpdateReceiver dataUpdateReceiver;

我覆盖onResume添加这个:

if (dataUpdateReceiver == null) dataUpdateReceiver = new DataUpdateReceiver();
IntentFilter intentFilter = new IntentFilter(RefreshTask.REFRESH_DATA_INTENT);
registerReceiver(dataUpdateReceiver, intentFilter);

我重写onPause添加:

if (dataUpdateReceiver != null) unregisterReceiver(dataUpdateReceiver);

现在我的活动正在监听我的服务说“嘿,去更新你自己。”我可以在Intent中传递数据,而不是更新数据库表,然后返回到我的活动中寻找更改,但由于我希望更改始终存在,因此通过DB传递数据是有意义的。

与服务通信有三种明显的方式:

使用意图 使用AIDL 使用服务对象本身(作为单例)

在你的情况下,我选择第三种。对它自己的服务做一个静态引用,并在onCreate()中填充它:

void onCreate(Intent i) {
  sInstance = this;
}

创建一个静态函数MyService getInstance(),该函数返回静态sInstance。

Then in Activity.onCreate() you start the service, asynchronously wait until the service is actually started (you could have your service notify your app it's ready by sending an intent to the activity.) and get its instance. When you have the instance, register your service listener object to you service and you are set. NOTE: when editing Views inside the Activity you should modify them in the UI thread, the service will probably run its own Thread, so you need to call Activity.runOnUiThread().

您需要做的最后一件事是删除activity . onpause()中对侦听器对象的引用,否则您的活动上下文实例将泄漏,这不好。

注意:此方法仅在应用程序/活动/任务是唯一访问服务的进程时有用。如果不是这种情况,你必须使用选项1。或2。

你也可以像EventBus一样使用LiveData。

class MyService : LifecycleService() {
    companion object {
        val BUS = MutableLiveData<Any>()
    }

    override fun onStartCommand(intent: Intent, flags: Int, startId: Int): Int {
        super.onStartCommand(intent, flags, startId)

        val testItem : Object

        // expose your data
        if (BUS.hasActiveObservers()) {
            BUS.postValue(testItem)
        }

        return START_NOT_STICKY
    }
}

然后从您的活动中添加一个观察者。

MyService.BUS.observe(this, Observer {
    it?.let {
        // Do what you need to do here
    }
})

你可以从这个博客上读到更多。