2

我正在使用 Mosby 创建一个小应用程序。

该应用程序具有我要绑定的服务。我想这样做的正确位置是在演示者中。但我真的不知道该怎么做。

我要存档的是当服务绑定时我想在其上调用一个方法并将该值推送到视图，以便现在的状态是正确的。

当服务在事件总线上发送更新时，我也想将其推送到视图。

我在后面的部分找到了一些示例，但没有关于如何在演示者中绑定/取消绑定服务。

我对它的尝试是在活动中创建这样的东西：

@NonNull
@Override
public MyPresenter createPresenter() {
    return new MyPresenter(new MyService.ServiceHandler() {
            @Override
            public void start(ServiceConnection connection) {
                Intent intent = new Intent(MyActivity.this, MyService.class);
                startService(intent);
                bindService(intent, connection, Context.BIND_AUTO_CREATE);
            }

            @Override
            public void stop(ServiceConnection connection) {
                unbindService(connection);
            }
        });

然后在演示者中执行以下操作：

private ServiceConnection connection;
private boolean bound;
private MyService service;

public MyPresenter(MyService.ServiceHandler serviceHandler) {
    super(new MyViewState.NotInitialiezedYet());

    this.serviceHandler = serviceHandler;

    connection = new ServiceConnection() {
        @Override
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
           MyService.LocalBinder binder = (MyService.LocalBinder) service;
            service = binder.getService();
            bool isInitialized = service.isInitialized();
            // how do i push isInitialized to view? 

        }

        @Override
        public void onServiceDisconnected(ComponentName componentName) {

        }
    };
}

@Override
public void attachView(@NonNull SplashView view) {
    super.attachView(view);
    serviceHandler.start(connection);
    bound = true;
}

@Override
public void detachView(boolean retainInstance) {
    super.detachView(retainInstance);
    if(bound) {
        serviceHandler.stop(connection);
        bound = false;
    }
}

@Override
protected void bindIntents() {
    //Not sure what this would look like?
}

public void onEventInitialized(InitializedEvent event) {
    //how do I push this to the view?
 }

我在正确的道路上吗？这样做的正确方法是什么？我如何将服务中的值发送到 onServiceConnected 中的视图以及当我在 onEventInitialized 中的事件总线上获取事件时？

4

1 回答 1

6

在我们深入研究可能的实现之前，需要注意一些事项：

  1. 在 Mosby 中，Presenter 在默认情况下保留屏幕方向，并且仅附加/分离视图。如果您在您的 Activity 中创建了ServiceHandler一个Activity内存泄漏，因为ServiceHandler它是在您的 Activity 中实例化的匿名类，因此具有对外部 Activity 实例的引用。为避免这种情况，您可以使用您的Application类作为上下文来调用bindService()和unbindService()。
  2. 服务是业务逻辑，所以你最好不要把绑定服务的逻辑放到视图层（Activity）中，而是放在它自己的“业务逻辑”组件中，我们称之为组件MyServiceInteractor。
  3. 当您在业务逻辑中移动该部分时，您可能想知道何时取消绑定/停止服务。在您的代码中，您已经在 Presenter 中完成了它detachView()。虽然这样可行，但 Presenter 现在对业务逻辑内部及其工作方式有了一些明确的了解。一个更类似于 Rx 的解决方案是将服务连接的生命周期与 Rx Observable 的“生命周期”联系起来。这意味着，一旦 observable 被取消订阅/处置，服务连接就应该关闭。这也与 1.“演示者在屏幕方向更改后存活”（并在屏幕方向更改期间保持可观察订阅保持活动状态）完美匹配。
  4. 任何回调/侦听器都可以通过使用轻松“包装”到 Rx Observable 中Observable.create()。
  5. 我个人认为服务（尤其是有界服务）使用起来很麻烦，并且在代码中引入了更高的复杂性。在没有服务的情况下，您可能（或不可能）能够实现相同的目标。但这实际上取决于您的具体应用程序/用例。

话虽如此，让我们看看可能的解决方案是什么样的（伪相似代码，可能无法编译）：

public class MyServiceInteractor {

  private Context context;

  public MyServiceInteractor(Context context) {
    this.context = context.getApplicationContext();
  }

  public Observable<InitializedEvent> getObservable() {
    return Observable.create(emitter -> {
      if (!emitter.isDisposed()) {

        MyService.ServiceHandler handler = new MyService.ServiceHandler() {

          @Override public void start(ServiceConnection connection) {
            Intent intent = new Intent(context, MyService.class);
            context.startService(intent);
            context.bindService(intent, connection, Context.BIND_AUTO_CREATE);
          }

          @Override public void stop(ServiceConnection connection) {
            context.unbindService(connection);
          }
        };

        emitter.onNext(handler);
        emitter.onComplete();
      }
    }).flatMap(handler ->
        Observable.create( emitter -> {
          ServiceConnection connection = new ServiceConnection() {
            @Override public void onServiceConnected(ComponentName name, IBinder service) {
              MyService.LocalBinder binder = (MyService.LocalBinder) service;
              MyService service = binder.getService();
              boolean isInitialized = service.isInitialized();
              if (!emitter.isDisposed())
                 emitter.onNext(new InitializedEvent(isInitialized));
            }

            @Override public void onServiceDisconnected(ComponentName name) {
              // you may want to emit an event too
            }
          };

        })
        .doOnDispose({handler.stop()})
    );
  }
}

因此，基本上MyServiceInteractor.getObservable()创建了一个通往 Rx Observable 世界的桥梁，并在 observable get 未订阅时停止服务连接。请注意，此代码段可能无法编译。这只是为了说明可能的解决方案/工作流程的外观。

然后你Presenter可能看起来像这样：

public class MyPresenter extends MviBasePresenter<MyView, InitializedEvent> {
  private MyServiceInteractor interactor;

  public MyPresenter(MyServiceInteractor interactor){
     this.interactor = interactor;
  }

  @Override
  void bindIntents(){
    Observable<InitializedEvent> o = intent(MyView::startLoadingIntent) // i.e triggered once in Activity.onStart()
        .flatMap( ignored -> interactor.getObservable() );

    subscribeViewState(o, MyView::render);
  }
}

所以这里的主要问题/问题不是非常特定于 MVI 或 MVP 或 MVVM，主要是我们如何将 android Service 回调“包装”到 RxJava observable 中。一旦我们有了这个，剩下的就很容易了。

唯一与 MVI 相关的事情是连接点：视图实际上必须触发一个意图来启动服务连接。这是bindIntents()通过myView.startLoadingIntent()

我希望这会有所帮助。

于 2017-03-27T13:10:37.700 回答