好的，所以我刚刚开始了一个新的 Android 项目，并想尝试实现 Bob 叔叔的 Clean Architecture。我在使用 RxJava 以及来自 GitHub 示例和样板以及 Fernando Cerjas 的博客（如本文）的东西有一个很好的开始，但对于如何实现一些用例仍有一些疑问。
TL;博士
一个实体是否应该具有另一个实体的字段（在我的示例中，User有一个List<Messages>字段）？
或者 Presenter 应该结合 UseCases 来构建一个映射到多个实体上的 ViewModel（那么你如何编写映射器？）？
或者，Presenter 是否应该有一个与每个 UseCase/Entity 关联的 ViewModel，并创建某种“等待所有数据到 onNext”来为每个 ViewModel 调用 view.show()？
基本上，UseCases 应该只返回实体吗？实体可以由其他实体组成（如在类的字段中）吗？实体只是愚蠢的数据模型 POJO 吗？你如何表示“加入 SQL”查询？
例如，让我们以一个简单的用户/消息应用程序为例。我想实现两个视图：UserList和UserDetails：
UserList显示列表UsersUserDetails显示用户的信息及其最新消息。
UserList非常简单，我可以看到如何编写相关的 UseCase 和层（代码如下）。
我的问题是UserDetails屏幕。
GetUserInfoUseCase如果我希望同时在视图中传递所有数据（例如构建由 User 类和字段 List 组成的 ViewModel），我应该如何编写我的代码？的返回值应该是GetUserInfoUseCase多少？我应该在我的演示者中编写 aObservable<User> GetUserInfoUseCase和 aObservable<List<Message>> GetUserLatestMessages并以某种方式合并它们吗？如果是，我该如何管理这个，因为我的 Presenter 中没有 Observables（我只传递一个 Observer 作为我的 UseCases 参数）？
用户实体
public abstract class User {
public abstract long id();
public abstract String name();
...
}
消息实体
public abstract class Message {
public abstract long id();
public abstract long senderId();
public abstract String text();
public abstract long timstamp();
...
}
获取用户用例
public class GetUsersUseCase extends UseCaseObservableWithParameter<Boolean, List<User>, UsersRepository> {
@Inject
public GetUsersUseCase(UsersRepository UsersRepository,
@Named("Thread") Scheduler threadScheduler,
@Named("PostExecution") Scheduler postExecutionScheduler) {
super(usersRepository, threadScheduler, postExecutionScheduler);
}
@Override
protected Observable<List<User>> buildObservable(Boolean forceRefresh) {
if(forceRefresh)
repository.invalidateCache();
return repository.getUsers();
}
}
用户演示者
public class UsersPresenter extends BasePresenter<UsersContract.View> implements UsersContract.Presenter {
@Inject
GetUsersUseCase mGetUsersUseCase;
@Inject
UserViewModelMapper mUserMapper;
@Inject
public UsersPresenter() {
}
@Override
public void attachView(UsersContract.View mvpView) {
super.attachView(mvpView);
}
@Override
public void detachView() {
super.detachView();
mGetUsersUseCase.unsubscribe();
}
@Override
public void fetchUsers(boolean forceRefresh) {
getMvpView().showProgress();
mGetUsersUseCase.execute(forceRefresh, new DisposableObserver<List<User>>() {
@Override
public void onNext(List<User> users) {
getMvpView().hideProgress();
getMvpView().showUsers(mUsersMapper.mapUsersToViewModels(users));
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable e) {
getMvpView().hideProgress();
getMvpView().showErrorMessage(e.getMessage());
}
});
}
}
UseCaseObservableWithParameter
public abstract class UseCaseObservableWithParameter<REQUEST_DATA, RESPONSE_DATA, REPOSITORY> extends UseCase<Observable, REQUEST_DATA, RESPONSE_DATA, REPOSITORY> {
public UseCaseObservableWithParameter(REPOSITORY repository, Scheduler threadScheduler, Scheduler postExecutionScheduler) {
super(repository, threadScheduler, postExecutionScheduler);
}
protected abstract Observable<RESPONSE_DATA> buildObservable(REQUEST_DATA requestData);
public void execute(REQUEST_DATA requestData, DisposableObserver<RESPONSE_DATA> useCaseSubscriber) {
this.disposable.add(
this.buildObservable(requestData)
.subscribeOn(threadScheduler)
.observeOn(postExecutionScheduler)
.subscribeWith(useCaseSubscriber)
);
}
}
用例
public abstract class UseCase<OBSERVABLE, REQUEST_DATA, RESPONSE_DATA, REPOSITORY> {
protected final REPOSITORY repository;
protected final Scheduler threadScheduler;
protected final Scheduler postExecutionScheduler;
protected CompositeDisposable disposable = new CompositeDisposable();
public UseCase(REPOSITORY repository,
@Named("Thread") Scheduler threadScheduler,
@Named("PostExecution") Scheduler postExecutionScheduler) {
Timber.d("UseCase CTOR");
this.repository = repository;
this.threadScheduler = threadScheduler;
this.postExecutionScheduler = postExecutionScheduler;
}
protected abstract OBSERVABLE buildObservable(REQUEST_DATA requestData);
public boolean isUnsubscribed() {
return disposable.size() == 0;
}
public void unsubscribe() {
if (!isUnsubscribed()) {
disposable.clear();
}
}
}