MassTransit -更新消息到客户端

我没有太多使用MSMQ的经验，有人建议我看看MassTransit来帮助实现解决方案，但我很难弄清楚使用MassTransit + MSMQ是否是适合这项工作的工具。

我们有一个由多个用户使用的WPF应用程序(3.5)。持久化是从应用程序(通过NHibernate)到数据库完成的。到目前为止，用户会定期刷新他们的视图，以确保他们有最新的更新。但是，我们现在希望在使用pub/sub消息传递持久化实体时向每个应用程序实例发送通知。客户端应用程序都在同一域中运行，并且应该能够满足所需的大多数依赖关系(例如，在客户端机器上安装MSMQ)。

总结:Client1发布更新消息--> ?????---->所有其他活动的客户端都收到它。

由于我是MSMQ的新手，我甚至不确定架构应该是什么样子。

• 是否每个客户端机器都需要有一个本地MSMQ队列来接收消息?
我们是否只需要在服务器上创建一个队列，然后所有客户端都在那里侦听消息?如果是这样，仅仅一个队列就足够了吗?还是我们需要创建一个服务来正确地分发消息?
• 这是适合工作的工具吗?

我创建了一个小小的POC，希望它能起作用，但我最终得到了我认为是"竞争性消费者"的东西。我希望发生的情况是，一个应用程序实例发送一条消息，所有应用程序实例都接收它。

任何建议，方向或建议将不胜感激!

下面是POC视图模型代码(注意-在我看来localhost将被替换为每个应用程序实例将发送消息的服务器):

更新:添加网络密钥(小猫)

更新:我已经上传了示例代码 https://docs.google.com/viewer?a=v&pid=explorer&chrome=true&srcid=0ByDMJXKmYB7zMjBmYzYwNDEtYzMwOC00Y2RhLTk1MDYtZjc0NTI2M2E3Y2Qy&hl=en_US

public class MainViewModel : IDisposable, INotifyPropertyChanged 
{
    private Guid id;
    public MainViewModel()
    {
        id = Guid.NewGuid();
        Publish = new RelayCommand(x => OnExecutePublishCommand(), x => !string.IsNullOrEmpty(Message));
        Messages = new ObservableCollection<MessagePayload>();
        Bus.Initialize(sbc =>
        {
            sbc.UseMsmq();
            sbc.SetNetwork("Kittens");
            sbc.VerifyMsmqConfiguration();
            sbc.UseMulticastSubscriptionClient();
            sbc.ReceiveFrom(string.Format("msmq://localhost/{0}", ConfigurationManager.AppSettings["queue"]));
            sbc.Subscribe(subs => subs.Handler<MessagePayload>(OnReceiveMessage));
        });
    }
    public ICommand Publish { get; private set; }
    private string message;
    public string Message
    {
        get { return message; }
        set
        {
            message = value;
            SendPropertyChanged("Message");
        }
    }
    public ObservableCollection<MessagePayload> Messages { get; private set; }
    private void OnReceiveMessage(MessagePayload msg)
    {
        Application.Current.Dispatcher.Invoke(DispatcherPriority.Background, 
            new Action(() => Messages.Add(msg)));
    }
    private void OnExecutePublishCommand()
    {
        Bus.Instance.Publish(new MessagePayload{ Sender= id, Message = Message});
        Message = null;
    }
    public event PropertyChangedEventHandler PropertyChanged;
    private void SendPropertyChanged(string propertyName)
    {
        if (PropertyChanged != null)
        {
            PropertyChanged(this, new PropertyChangedEventArgs(propertyName));
        }
    }
    public void Dispose()
    {
        Bus.Instance.Dispose();
    }
}

更新:以防有人感兴趣，我们最终将我们的"事件总线"分成两个。对于服务器，我们使用MassTransit。然而，由于公共交通需要"完整的档案"。. NET 4.0)，我们希望坚持使用"客户端配置文件"来处理我们的WPF实例，我们使用SignalR作为客户端事件总线。服务器事件总线上的"观察者"将消息转发到客户端事件总线。