我没有太多使用 MSMQ 的经验，有人建议我查看 MassTransit 以帮助实施解决方案，但我很难确定使用 MassTransit + MSMQ 是否适合这项工作。
我们有一个供多个用户使用的 WPF 应用程序 (3.5)。持久性是从应用程序（通过 NHibernate）到数据库的。到目前为止，用户会定期刷新那里的视图，以确保他们有最新的更新。但是，我们现在希望在使用 pub/sub 消息传递持久化实体时向每个应用程序实例发送通知。客户端应用程序都在同一个域中运行，并且应该能够满足所需的大多数依赖项（例如在客户端计算机上安装 MSMQ）。
总结一下：Client1 发布更新消息 ---> ????? ----> 所有其他活动客户端都会收到它。
由于我是 MSMQ 的新手，我什至不确定架构应该是什么样子。
- 是否每台客户端机器都需要有一个本地 MSMQ 队列来接收消息？
- 我们是否只需要在服务器上创建一个队列并且所有客户端都在那里侦听消息？如果是这样，只需要一个队列就足够了，还是我们需要创建一个服务来正确分发消息？
- 这甚至是适合这项工作的工具吗？
我创建了一个小 POC，希望它能起作用，但我最终得到了我认为被称为“竞争消费者”的东西。我想要发生的是一个应用程序实例发送一条消息，所有应用程序实例都接收它。
任何建议、方向或建议将不胜感激！
这是 POC 视图模型代码（注意 - 在我看来 localhost 将被替换为每个应用程序实例将向其发送消息的服务器）：
更新：添加了网络密钥（小猫）
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。但是，由于 Mass Transit 需要“完整配置文件”（.NET 4.0），并且我们希望为我们的 WPF 实例坚持使用“客户端配置文件”，因此我们将 SignalR 用于客户端事件总线。服务器事件总线上的“观察者”将消息转发到客户端事件总线。