全部 -
我目前有一个端到端运行的 POC WPF 项目。该应用程序模拟通过库(发布者)发布的实时市场数据,我的 WPF 客户端是订阅者(具有处理程序方法)。它使用自定义事件来发布数据。
我的问题是:
1) 我想实现 Producer Consumer - 所以我的处理程序不会直接将数据拉入 Observable Collection 中。
2) 我确切地知道如何实现生产者/消费者 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<StockModel> 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<StockModel>();
}
private void mySbmtCmdExecute(object parameter)
{
MarketDataProvider p = new MarketDataProvider();
p.OnMarketData += new EventHandler<MarketDataEventArgs>(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);
}
}
});
}
}
}
最佳答案
我已经完成了一些带有市场提要的项目,并且您的图表在概念上看起来不错。为了避免可扩展性问题,或者主动设计以解决可扩展性问题,您可以考虑让您的生产者/消费者盒具有多个实例,以容纳多个源和/或源中的多个仪器。例如,如果某个特定市场变得剧烈波动,您不希望所有其他工具都缺乏数据。
此外,有些人喜欢根据任意标准切换给定工具的源,例如从伦敦获取日元,直到黄金定盘价,然后切换到纽约,然后再次切换到东京。
我可以提到的另一件事是,从生产者/消费者框出来的箭头只能通过 POCO DTO。它增加了应用程序的值(value),并使隔离测试变得更加容易。
测试实时源(甚至模拟源)的情况很少,因为它们无法捕获应用部署之前需要测试的所有条件。
最后我要提到的是,生产者/消费者模式是从 .NET 4.0 开始使用 System.Collections.Concurrent 命名空间实现的... http://msdn.microsoft.com/en-us/library/dd287147.aspx我一直在生产中使用这些类,它们确实消除了测试本土设计模式的需要。
关于c# - 实时数据绑定(bind),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17451531/