公开远程接口或对象模型

Question

我有一个关于公开异步远程接口的最佳方法的问题。

条件如下：

• 协议是异步的
• 第三方可以随时修改数据
• 命令往返可能很重要
• 模型应该非常适合 UI 交互
• 协议支持对某些对象的查询，模型也必须支持

作为提高我在该领域缺乏的技能（并总体上温习 Java）的一种方法，我启动了一个项目< /a> 为 xmms2 创建基于 Eclipse 的前端（如下所述）。

所以，问题是； 我应该如何将远程接口公开为一个简洁的数据模型（在本例中，跟踪管理和事件处理）？

我欢迎任何内容，从一般性讨论到模式名称删除或具体示例和补丁:)

---

我在这里的主要目标是总体上了解此类问题。 如果我的项目可以从中受益，那很好，但我严格提出它是为了有一些东西可以引发讨论。

我已经实现了一个协议抽象，我称之为 'client' （用于遗留原因），这使我可以使用方法调用访问大多数公开的功能，我对此感到满意，即使它远非完美。

xmms2 守护进程提供的功能包括曲目搜索、元数据检索和操作、更改播放状态、加载播放列表等等。

我正在更新到 xmms2 的最新稳定版本，我想我也可以修复当前实现的一些明显的弱点。

我的计划是在协议接口之上构建一个更好的抽象，允许与守护进程进行更自然的交互。 当前的 'model' 实现很难使用，而且坦率地说相当丑陋（更不用说 UI 代码了，这真是太可怕了）。

今天我有 曲目< /a> 接口，我可以使用它来获取 根据班级 ID 跟踪 班级。 搜索是通过 集合执行的 接口（不幸的命名空间冲突），我认为我宁愿转移到 Tracks。

第三方可以随时修改任何数据，这应该正确反映在模型和分发的更改通知中

这些接口在连接时通过返回如下所示的对象层次结构来公开

• ：
  • 回放 getPlayback()
    • 播放、暂停、跳转、当前曲目等
    • 公开播放状态更改
  • 曲目 getTracks()
    • 跟踪 getTrack(id) 等
    • 公开曲目更新
  • 集合 getCollection()
    • 加载和操作播放列表或命名集合
    • 查询媒体库
    • 公开集合更新

Answer 1

到目前为止我的结论；

由于对象是不可变的，我对是否对 Track 对象使用 getter 还是仅仅公开成员感到犹豫。

class Track {
    public final String album;
    public final String artist;
    public final String title;
    public final String genre;
    public final String comment;

    public final String cover_id;

    public final long duration;
    public final long bitrate;
    public final long samplerate;
    public final long id;
    public final Date date;

    /* Some more stuff here */
}

任何想知道库中的曲目何时发生问题的人都可以实现这个...

interface TrackUpdateListener {
    void trackUpdate(Track oldTrack, Track newTrack);
}

这就是查询的构建方式。 连锁呼叫让您心满意足。 不过，对于 get() 还没有定论。 缺少一些细节，例如我应该如何处理通配符和带有析取的更高级查询。 我可能只需要一些完成回调功能，可能类似于 异步完成令牌< /a>，但我们会看到这一点。 也许这会在附加层中发生。

interface TrackQuery extends Iterable<Track> {
    TrackQuery years(int from, int to);
    TrackQuery artist(String name);
    TrackQuery album(String name);
    TrackQuery id(long id);
    TrackQuery ids(long id[]);

    Future<Track[]> get();
}

一些示例：

tracks.allTracks();
tracks.allTracks().artist("Front 242").album("Tyranny (For You)");

轨道接口主要只是连接和各个轨道之间的粘合剂。 它将是实现或管理元数据缓存的一个（如果有的话）（就像今天一样，但我想我会在重构期间将其删除，看看我是否真的需要它）。 此外，这还提供了 medialib 轨道更新，因为通过轨道实现它的工作量太大。

interface Tracks {
    TrackQuery allTracks();

    void addUpdateListener(TrackUpdateListener listener);
    void removeUpdateListener(TrackUpdateListener listener);
}

Answer 2

@Staale：非常感谢！

使用 Future 进行异步操作很有趣。 唯一的缺点是它不提供回调。 但话又说回来，我尝试了这种方法，看看它给我带来了什么:)

我目前正在使用工作线程和阻塞队列来分派传入的命令回复来解决类似的问题，但这种方法翻译得不太好。

远程对象可以修改，但由于我确实使用线程，所以我尝试保持对象不可变。 我当前的假设是，我将在表单

somehandlername(int changes, Track old_track, Track new_track)

或类似形式上发送有关曲目更新的通知事件，但最终我可能会得到同一曲目的多个版本。

我一定会研究 Django 的方法链。 我一直在研究一些类似的结构，但一直无法想出一个好的变体。 返回可迭代的东西很有趣，但是查询可能需要一些时间才能完成，而且我不想在查询完全构建之前实际执行查询。

也许像

Tracks.allSongs().artist("Beatles").years(1965,1967).execute()

返回 Future 之类的东西可能会起作用......

Answer 3

Iterable 仅具有 Iterator get() 或类似方法。 因此，在实际开始迭代之前，无需构建任何查询或执行任何代码。 它确实使示例中的执行变得多余。 但是，线程将被锁定，直到第一个结果可用，因此您可以考虑使用执行器在单独的线程中运行查询代码。

Answer 4

@Staale

这当然有可能，但正如你所注意到的，这会使其阻塞（在家里由于磁盘休眠而阻塞大约 10 秒），这意味着我无法使用它直接更新 UI。

我可以使用迭代器在单独的线程中创建结果的副本，然后将其发送到 UI，但是虽然迭代器解决方案本身相当优雅，但它不太适合。 最后，实现 IStructuredContentProvider 需要返回所有对象的数组，以便在 TableViewer，所以如果我能逃脱得到类似的东西回调...:)

我会再考虑一下。 我也许能解决一些问题。 它确实使代码看起来很漂亮。

Answer 5

对于异步位，我建议检查 java.util.concurrent，尤其是 Future 接口。 future 接口用于表示尚未准备好但正在单独线程中创建的对象。 您说第三方可以随时修改对象，但我仍然建议您在此处使用不可变的返回对象，而是拥有一个单独的线程/事件日志，您可以订阅以在对象过期时得到通知。 我很少使用 UI 进行编程，但我相信使用 Futures 进行异步调用会让您拥有一个响应式 GUI，而不是等待服务器回复的 GUI。

对于查询，我建议使用方法链接来构建查询对象，并且方法链接返回的每个对象都应该是Iterable。 与 Django 的模型类似。 假设您有实现 Iterable 的 QuerySet。 然后，您可以调用 allSongs() ，这将返回迭代所有歌曲的结果。 或者 allSongs().artist("Beatles")，您将获得所有 Betles 歌曲的可迭代对象。 甚至是 allSongs().artist("Beatles").years(1965,1967) 等等。

希望这作为一个起点有所帮助。