Silverlight 4 + WCF RIA - 数据服务设计最佳实践

Question

嘿大家。我意识到这是一个相当长的问题，但我真的很感谢任何有 RIA 服务经验的人提供的帮助。谢谢！

我正在开发一个 Silverlight 4 应用程序，用于查看服务器中的数据。我对 RIA 服务相对缺乏经验，因此一直在完成将我需要的数据传递给客户端的任务，但我添加到难题中的每一个新部分似乎都越来越有问题。我觉得我在这里遗漏了一些基本概念，而且似乎我只是以耗时的方式“破解”一些部分，当我尝试添加它们时，每个概念都会破坏之前的概念。我很想获得具有 RIA 服务经验的开发人员的反馈，以找出完成我想做的事情的预期方法。让我列出我正在尝试做的事情：

首先，数据。该数据的来源有多种，主要由共享库创建，该共享库从我们的数据库读取数据，并将其公开为 POCO（普通旧 CLR 对象）。我正在创建自己的 POCO 来表示我需要在服务器和客户端之间传递的不同类型的数据。

DataA - 此应用程序用于近乎实时地查看某种类型的数据，我们可以调用 DataA。每 3 分钟，客户端应该从服务器上拉取自上次请求数据以来所有新 DataA 的数据。

DataB - 用户可以在应用程序中查看 DataA 对象，并可以从列表中选择其中一个，该列表会显示有关该 DataA 的其他详细信息。我将这些额外的详细信息作为 DataB 从服务器上下载下来。

DataC - DataB 包含的内容之一是几个重要值随时间的历史记录。我将此历史记录的每个数据点称为 DataC 对象，每个 DataB 对象包含许多 DataC。

数据模型 - 在服务器端，我有一个 DomainService：

[EnableClientAccess]
public class MyDomainService : DomainService
{
    public IEnumerable<DataA> GetDataA(DateTime? startDate)
    {
        /*Pieces together the DataAs that have been created 
        since startDate, and returns them*/
    }

    public DataB GetDataB(int dataAID)
    {
        /*Looks up the extended info for that dataAID, 
        constructs a new DataB with that DataA's data, 
        plus the extended info (with multiple DataCs in a 
        List<DataC> property on the DataB), and returns it*/
    }

    //Not exactly sure why these are here, but I think it 
    //wouldn't compile without them for some reason? The data 
    //is entirely read-only, so I don't need to update.
    public void UpdateDataA(DataA dataA)
    {
        throw new NotSupportedException();
    }
    public void UpdateDataB(DataB dataB)
    {
        throw new NotSupportedException();
    }
}

DataA/B/C 的类如下所示：

[KnownType(typeof(DataB))]
public partial class DataA
{
    [Key]
    [DataMember]
    public int DataAID { get; set; }
    [DataMember]
    public decimal MyDecimalA { get; set; }
    [DataMember]
    public string MyStringA { get; set; }
    [DataMember]
    public DataTime MyDateTimeA { get; set; }
}

public partial class DataB : DataA
{
    [Key]
    [DataMember]
    public int DataAID { get; set; }
    [DataMember]
    public decimal MyDecimalB { get; set; }
    [DataMember]
    public string MyStringB { get; set; }
    [Include] //I don't know which of these, if any, I need?
    [Composition]
    [Association("DataAToC","DataAID","DataAID")]
    public List<DataC> DataCs { get; set; }
}

public partial class DataC
{
    [Key]
    [DataMember]
    public int DataAID { get; set; }
    [Key]
    [DataMember]
    public DateTime Timestamp { get; set; }
    [DataMember]
    public decimal MyHistoricDecimal { get; set; }
}

我想我在这里遇到的一个大问题是......我应该使用实体而不是 POCO？我的类是否正确构建以能够正确传递数据？我应该在 DomainService 上使用 Invoke 方法而不是 Query (Get) 方法吗？

在客户端方面，我遇到了很多问题。令人惊讶的是，我最大的事情之一就是线程。我没想到 MyDomainContext 会有这么多线程问题。我了解到的是，您似乎只能在 UI 线程上创建 MyDomainContextObjects，您可以进行的所有查询都只能异步完成，并且如果您尝试通过阻塞调用线程来假冒同步执行，直到LoadOperation 完成后，您必须在后台线程上执行此操作，因为它使用 UI 线程来进行查询。这就是我到目前为止所得到的。

应用程序应显示 DataA 对象流，将其中的每 3 分钟块分散到接下来的 3 分钟内（因此它们最终会在发生后 3 分钟显示，看起来像一个连续的流，但只需在 3 分钟内突发下载）。为此，主窗体进行初始化，创建一个私有 MyDomainContext，并启动一个后台工作程序，该工作程序在 while(true) 中连续循环。在每个循环中，它都会检查是否还有剩余的 DataAs 需要显示。如果是这样，它会显示该 Data，并执行 Thread.Sleep()，直到计划显示下一个 DataA。如果它没有数据，它会使用以下方法查询更多数据：

public DataA[] GetDataAs(DateTime? startDate)
{
    _loadOperationGetDataACompletion = new AutoResetEvent(false);
    LoadOperation<DataA> loadOperationGetDataA = null;

    loadOperationGetDataA = 
        _context.Load(_context.GetDataAQuery(startDate),
        System.ServiceModel.DomainServices.Client.LoadBehavior.RefreshCurrent, false);
    loadOperationGetDataA.Completed += new
        EventHandler(loadOperationGetDataA_Completed);

    _loadOperationGetDataACompletion.WaitOne();
    List<DataA> dataAs = new List<DataA>();
    foreach (var dataA in loadOperationGetDataA.Entities)
        dataAs.Add(dataA);

    return dataAs.ToArray();
}

private static AutoResetEvent _loadOperationGetDataACompletion;
private static void loadOperationGetDataA_Completed(object sender, EventArgs e)
{
    _loadOperationGetDataACompletion.Set();
}

试图强制它同步似乎有点笨拙，但由于这已经在后台线程上，我认为这可以吗？到目前为止，一切都确实有效，尽管看起来像是黑客攻击。需要注意的是，如果我尝试在 UI 线程上运行该代码，它会锁定，因为它会永远等待 WaitOne()，锁定线程，因此它无法向服务器发出 Load 请求。

因此，一旦显示数据，用户可以在数据经过时单击其中一个，以使用有关该对象的完整 DataB 数据填充详细信息窗格。为此，我让详细信息窗格用户控件订阅我设置的选择事件，当选择更改时（在 UI 线程上）会触发该事件。我在那里使用类似的技术来获取 DataB 对象：

void SelectionService_SelectedDataAChanged(object sender, EventArgs e)
{
    DataA dataA = /*Get the selected DataA*/;

    MyDomainContext context = new MyDomainContext();
    var loadOperationGetDataB = 
        context.Load(context.GetDataBQuery(dataA.DataAID),
        System.ServiceModel.DomainServices.Client.LoadBehavior.RefreshCurrent, false);
    loadOperationGetDataB.Completed += new
        EventHandler(loadOperationGetDataB_Completed);          
}

private void loadOperationGetDataB_Completed(object sender, EventArgs e)
{
    this.DataContext = 
        ((LoadOperation<DataB>)sender).Entities.SingleOrDefault();  
}

同样，这似乎有点 hacky，但它有效......除了它加载的 DataB 之外，DataCs 列表是空的。我在那里尝试了各种方法，但我不明白我做错了什么，让 DataC 与 DataB 一起下来。我正准备对 DataC 进行第三次查询，但这对我来说更加骇人听闻。

真的感觉就像我正在与这里的谷物作斗争，就像我以一种完全无意识的方式这样做一样。如果有人可以提供任何帮助，并指出我在这里做错了什么，我将非常感激！

谢谢！

Answer 1

我不得不说它看起来确实有点过于复杂。

如果您使用实体框架（如果需要，版本 4 可以生成 POCO）和 Ria /LINQ 您可以使用延迟加载、“扩展”语句和每个类型继承的表来隐式完成所有这些操作。