android - 如何将消息从后台服务发布到 UI fragment ？

Question

我对 Greenrobot 的 EventBus 有疑问。

我试图从我的同步适配器的后台服务发布一个事件，并在 fragment 中捕获它以更新 UI。

问题是，当我尝试从同步适配器发布事件时，我在调试日志中得到以下信息:

No subscribers registered for event class olexiimuraviov.ua.simplerssreader.event.UpdateUIEventNo subscribers registered for event class org.greenrobot.eventbus.NoSubscriberEvent

I register fragment in onResume and unregister it in onPause

@Override
public void onResume() {
    super.onResume();
    EventBus.getDefault().register(this);
    if (mDebug) Log.d(LOG_TAG, EventBus.getDefault().isRegistered(this) + "");
}

@Override
public void onPause() {
    super.onPause();
    EventBus.getDefault().unregister(this);
}

onResume 中的日志语句显示 fragment 已成功注册。

这是 onEvent 方法:

@Subscribe
public void onEvent(UpdateUIEvent event) {
    if (mSwipeRefreshLayout.isRefreshing())
        mSwipeRefreshLayout.setRefreshing(false);
}

我试图用背景线程模式调用 onEvent 方法，但它没有帮助。

在此之后，我尝试使用处理程序来发布事件，但事件总线仍然找不到任何已注册的事件订阅者。

 new Handler(Looper.getMainLooper()).post(new Runnable() {
     @Override
     public void run() {
         EventBus.getDefault().post(new UpdateUIEvent());
     }
 });

这是我的同步适配器的 onPerform 方法:

    @Override
public void onPerformSync(Account account, Bundle extras, String authority, ContentProviderClient provider, SyncResult syncResult) {
    // Fetch data from server
    } finally {
       // close everything
       new Handler(Looper.getMainLooper()).post(new Runnable() {
           @Override
           public void run() {
               Log.d(LOG_TAG, "Update event");
               EventBus.getDefault().post(new UpdateUIEvent());
           }
       });
    }
}

如何使用 Greenrobot 的 EventBus 将事件从同步适配器发送到 fragment ？

Answer 1

tl;dr

您永远不必担心从哪个线程 发布事件，但您必须担心从哪个进程 发布事件。您的同步适配器在与您的 fragment 不同的进程中运行 - EventBus 仅在创建它的进程中运行。

长版

除了您订阅事件的地方之外，您永远不需要启动不同的线程，甚至不必担心您在哪个线程上。

检查 http://greenrobot.org/eventbus/documentation/delivery-threads-threadmode/有关更多详细信息，但语法非常 self 解释:

@Subscribe(threadMode = ThreadMode.BACKGROUND)
public void thisMethodWillBeRunInABackgroundThread(DoLoginEvent event)
{
    //Run some code that makes an HTTP request
}

并在 UI 上运行一些东西:

@Subscribe(threadMode = ThreadMode.MAIN)
public void thisMethodWillBeRunOnTheUIThread(LoginSuccessfulEvent event)
{
    //Run some code that touches the UI
}

当您调用 post() 来同时触发 DoLoginEvent 和 LoginSuccessfulEvent 时，您在哪个线程中绝对无关紧要。

现在您遇到的真正问题是:似乎没有在订阅对象上捕获事件。

我怀疑这是因为您的同步适配器在不同的进程 中运行。 EventBus 仅在它创建的进程中运行。

同步适配器(如 BroadcastReceiver 或服务)在单独的进程中运行，以允许您与服务器同步数据， 无需与您的应用程序本身进行任何交互。这个想法是，即使应用程序关闭，您也可以与服务器同步，将任何内容保存到数据库中，然后当应用程序启动时，它会检查该数据库(快速)，而不必与服务器同步(慢速)。但是，如果在同步适配器运行时您的应用程序处于 Activity 状态，那么您既要保存到数据库，又要告诉应用程序有一些新信息，对吗？

因此，为了允许您的同步适配器与您的应用程序通信，我建议您在您的 fragment/Activity 中设置一个 BroadcastReceiver，然后从您的同步适配器广播一个 Intent 。

这个机制和EventBus的概念很相似，你甚至可以发送sticky intents !您的 fragment 会监听这些 Intent ，但仅限于它处于 Activity 状态时。如果您的同步适配器在您的应用程序关闭时发送广播，则什么也不会发生。但是当 fragment 启动并注册这些 Intent 时，它将获得最后一个粘性。

public class LogFragment extends Fragment {

    private LogReceiver mReceiver;

    public class LogReceiver extends BroadcastReceiver {
        @Override
        public void onReceive(Context context, Intent intent) {
            //you can call the EventBus from in here
        }
    }


    @Override
    public void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        mReceiver = new LogReceiver();
    }

    @Override
    public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {
        getActivity().registerReceiver(mReceiver, new IntentFilter("com.whatever.whatever"));
        return view;
    }

    @Override
    public void onDestroyView() {
        getActivity().unregisterReceiver(mReceiver);
        super.onDestroy();
    }
}

然后从您的同步适配器

Intent sendIntent = new Intent("com.whatever.whatever");
sendIntent.putExtra("SYNC_ADAPTER_EXTRA", "Your sync adapter says hi");
context.sendBroadcast(sendIntent);