使用Repository模式的多个数据源的体系结构

Question

我有一个使用MVP架构的项目.该项目使用Repository模式.

我有两个数据源,第一个来自远程JSON Api PollutionApiService,第二个是我从assets文件夹中的XML文件获得的简单数据:air_quality_levels.xml.网络数据包含实时污染等级,XML文件包含这些污染等级的限制标准.

现在我只为JSON Api实现了一个Repository,它看起来像这样:

接口

public interface Repository {
    Observable<Aqicn> getPollutionLevelsFromNetwork(String city, String authToken);
   Observable<Aqicn> getPollutionLevels(String city, String authToken);
}

类

public class PollutionLevelsRepository implements Repository {
    private PollutionApiService pollutionApiService;
    private static Observable<Aqicn> pollutionData = null;


    public PollutionLevelsRepository(PollutionApiService pollutionApiService) {
        this.pollutionApiService = pollutionApiService;
    }

    @Override
    public Observable<Aqicn> getPollutionLevelsFromNetwork(String city, String authToken) {
        pollutionData = pollutionApiService.getPollutionObservable(city, authToken);
        return pollutionData;
    }

    @Override
    public Observable<Aqicn> getPollutionLevels(String city, String authToken) {
        return getPollutionLevelsFromNetwork(city, authToken);
    }
}

我是否应该使用相同的存储库(添加更多方法)来获取我将从assets文件夹中的XML文件获取的数据？

如果我必须使用两个存储库,我应该如何命名第二个存储库接口？我从来没有几个存储库,所以我总是使用通用名称"Repository"作为接口.我不能给它与该类相同的名称,并且不能添加"I"前缀,因为我读它是不好的做法...或者我应该保留这个"存储库"名称并将新的存储库放在另一个包中？

这是我的实际项目结构,请注意我按功能打包但我将两个存储库放在公共包中,因为它获取了我的两个功能(donut和pollutionlevels)将使用的数据:

如果您对建筑有一般性的简短相关建议,欢迎他们.

Answer 1

存储库的想法是充当数据实际来源和消耗它的业务逻辑代码之间的抽象.您的业​​务逻辑既不知道也不关心数据是通过网络,xml还是来自其他任何地方.这允许将来具有灵活性,以便您可以自由地更改获取数据(缓存,脱机存储等)的实现,同时仍保持存储库的原始合同.

我倾向于为每种"类型"的数据创建一个单独的存储库.在您的情况下,网络请求和xml都是污染级数据,因此我将它们放在同一个存储库中.但是,如果你需要有用户数据,那么我会建立一个单独的类来处理这个问题(可能是AccountRepositoy).

考虑到上述情况,我将创建一个类PollutionLevelsRepository,如下所示:

public class PollutionLevelsRepository {

    private PollutionHttp pollutionHttp;
    private PollutionXml pollutionXml;

    public PollutionLevelsRepository(PollutionHttp pollutionHttp, PollutionXml pollutionXml) {
        this.pollutionHttp = pollutionHttp;
        this.pollutionXml = pollutionXml;
    }

    public Observable<Aqicn> getRealTimePollutionLevels(String city) {

        // currently this method runs the http request
        // note that I have removed the auth token - this is a network
        // implementation detail and probably shouldn't be part of the public api
        return pollutionHttp.getPollutionLevels(city);
    }

    public Observable<Aqicn> getPollutionLimitStandard(String city) {

        // this method would return data from the xml
        return pollutionXml.getPollutionLimit(city);
    }
}

请注意,方法名称不指示数据的来源.您可以随时更改此信息.我也认为没有理由实现接口.其他人可能不同意这一点,但由于你只有一个实现,我会打电话给YAGNI并说它只是引入了不必要的复杂性.

这两个类PollutionHttp及PollutionXml负责实际做的HTTP请求和XML解析数据模型类(称他们为你想要的!)