实时数据绑定
全部 –
我目前有一个端到端工作的POC WPF项目。 该应用程序模拟通过库（Publisher）发布的实时市场数据，我的WPF客户端是Subscriber（具有处理程序方法）。 它使用自定义事件来发布数据。
我的问题是：
1）我想实现Producer Consumer – 所以我的处理程序不会直接将数据提取到Observable Collection中。
2）我确切地知道如何实现Producer / Consumer C＃片段（ http://msdn.microsoft.com/en-us/library/hh228601.aspx ），但希望更多地了解它如何适合我当前的架构。 这是一张图
3）任何人都可以帮我解决代码方法，链接等问题。
MainWindowViewModel.cs
public class MainWindow_VM : ViewModelBase { #region Properties public myCommand SbmtCmd { get; set; } public ObservableCollection stocks { get; set; } #endregion #region Fields private readonly Dispatcher currentDispatcher; #endregion public MainWindow_VM() { SbmtCmd = new myCommand(mySbmtCmdExecute, myCanSbmtCmdExecute); currentDispatcher = Dispatcher.CurrentDispatcher; stocks = new ObservableCollection(); } private void mySbmtCmdExecute(object parameter) { MarketDataProvider p = new MarketDataProvider(); p.OnMarketData += new EventHandler(handlermethod); p.GenerateMarketData(); } private bool myCanSbmtCmdExecute(object parameter) { return true; } // Subscriber method which will be called when the publisher raises an event private void handlermethod(object sender, MarketDataEventArgs e) { foreach (Stock s in e.updatedstk) { StockModel sm = new StockModel(); sm.symbol = s.symbol; sm.bidprice = s.bidprice; sm.askprice = s.askprice; sm.lastprice = s.lastprice; currentDispatcher.Invoke(DispatcherPriority.Normal, (Action)delegate() { if (sm != null) { if (stocks.Any(x => x.symbol == sm.symbol)) { var found = stocks.FirstOrDefault(x => x.symbol == sm.symbol); int i = stocks.IndexOf(found); stocks[i] = sm; } else { stocks.Add(sm); } } }); } } } 我已经完成了一些市场供稿的项目，你的图表在概念上看起来很好。 为避免可伸缩性问题，或主动针对可伸缩性问题进行设计，您可以考虑使生产者/消费者框具有多个实例，以适应Feed中的多个订阅源和/或多个工具。 例如，如果给定的市场变得非常不稳定，那么您不希望所有其他工具都缺乏数据。
此外，有些人喜欢根据任意标准切换给定乐器的馈送，例如从伦敦获得YEN直到黄金修复，然后切换到纽约，然后再切换到东京。
我可以提到的另一件事是，生产者/消费者盒子里的箭头只能通过POCO DTO。 它增加了应用程序的价值，也使隔离测试变得更加容易。
测试关闭实时源（甚至是模拟源）很少，因为它们无法捕获应用程序可部署之前需要测试的所有条件。
最后我要提到生产者/消费者模式是从.NET 4.0开始实现的，带有System.Collections.Concurrent名称空间… http://msdn.microsoft.com/en-us/library/dd287147.aspx我有一直在生产中使用这些类，他们真正切断了测试本土设计模式的需要。
我创建了一个名为ReactiveTables的UI工具包，它允许您创建可以连接，过滤，使用计算列扩展然后绑定到WPF控件的实时表。 这些表公开了一个IObservable接口，并且是为性能而设计的。
您可以将表直接挂接到生产者/消费者实现，然后将它们绑定到您的视图。 这些表将通知单个单元格的更改，并且有一个帮助程序类用于将其转换为INotifyPropertyChanged事件。
在接收方，有一些类可以限制对UI表的更新，并将数据线程编组到UI线程。