2

我对公开异步远程接口的最佳方式有疑问。

条件如下：

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

作为改善我在这方面缺乏技能的一种手段（并全面提高我的 Java），我已经开始了一个项目来为xmms2创建一个基于 Eclipse 的前端（如下所述）。

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

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

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

我已经实现了一个协议抽象，我称之为“客户端”（出于遗留原因），它允许我使用我很满意的方法调用来访问大多数公开的功能，即使它远非完美。

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

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

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

今天我有了Tracks接口，我可以使用它来根据Track类的 id获取实例。搜索是通过Collections接口（不幸的命名空间冲突）执行的，我认为我宁愿将其移至 Tracks。

任何数据都可以随时被第三方修改，这应该在模型和分发的变更通知中得到适当的反映

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

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

5 回答 5

2

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

对于查询，我建议使用方法链接来构建查询对象，方法链接返回的每个对象都应该是Iterable. 类似于 Django 的模型。说你有QuerySet哪些工具Iterable<Song>。然后您可以调用allSongs()which 将返回一个遍历所有歌曲的结果。或者allSongs().artist("Beatles")，您将对所有 Betles 歌曲进行迭代。甚至allSongs().artist("Beatles").years(1965,1967)等等。

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

于 2008-08-31T20:52:01.193 回答
0

@Staale ：非常感谢！

将 Future 用于异步操作很有趣。唯一的缺点是它不提供回调。但话又说回来，我尝试了这种方法，看看它把我带到了哪里:)

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

可以修改远程对象，但由于我确实使用线程，因此我尽量保持对象不可变。我目前的假设是我将在表单上发送有关轨道更新的通知事件

somehandlername(int changes, Track old_track, Track new_track)

或类似的，但我最终可能会得到同一曲目的多个版本。

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

也许像

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

返回一个 Future 可能会工作......

于 2008-08-31T21:23:35.440 回答
0

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

于 2008-08-31T22:13:33.727 回答
0

@斯塔尔

这当然是可能的，但正如您所指出的，这会使其阻塞（由于睡眠磁盘而在家中停留大约 10 秒），这意味着我不能使用它来直接更新 UI。

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

我再考虑一下。我可能只是能够解决一些问题。它确实使代码看起来不错。

于 2008-08-31T22:57:06.073 回答
0

到目前为止我的结论；

由于对象是不可变的，因此我对是否对 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() 上。缺少一些细节，例如我应该如何处理通配符和更高级的析取查询。我可能只需要一些完成回调功能，可能类似于Asynchronous Completion Token，但我们会看到的。也许这会发生在一个额外的层。

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);
}
于 2008-09-01T13:23:18.830 回答