2

我正在尝试在已经使用 MSMQ 传递消息的现有系统环境中插入#Rebus。

当然，目的是让 Rebus 接管一切；-)，但目前我无法更改任何已经使用 MSMQ 传输的现有代码。

所以，我想我可以在系统的新部分中使用 Rebus 并将消息发送到现有的应用程序队列，但出现了问题。

我像这样配置我的 Rebus：

_bus = Configure.With(new WindsorContainerAdapter(container))
    .Logging(l => l.ColoredConsole(LogLevel.Debug))
    .Transport(t => t.UseMsmqInOneWayClientMode())
    .MessageOwnership(d => d.FromRebusConfigurationSection())
    .Serialization(s => s.UseBinarySerializer())
    .CreateBus().Start();

它按计划发送消息，但是当我现有的应用程序尝试从队列中读取时，会引发异常：

“无法反序列化作为参数传递的消息。无法识别序列化格式。”

有问题的方法调用是这样的：

// using System.Messaging.MessageQueue
receiveQueue.Receive(_queueTimeout, transaction);

通过代码挖掘我可以看到 Rebus 的 DefaultFilter 或多或少像我们的

https://github.com/rebus-org/Rebus/blob/1ab9b0a02883157de457e0b6106d289ace3a077e/src/Rebus.Snoop/Listeners/MsmqInteraction.cs#L567

return new MessagePropertyFilter
{
  Label = true,
  ArrivedTime = true,
  Extension = true,
  Body = true,
  Id = true,
  };

我们的 MessagePropertyFilter 配置如下：

var propertyFilter = new MessagePropertyFilter
{
    Id = true,
    Body = true,
    Label = true
};

这种微妙的变化真的是异常的原因吗？我们还使用 BinaryFormatter 来序列化消息。

任何帮助将不胜感激 ：-）

4

1 回答 1

2

Rebus 有自己的消息格式化程序，RebusTransportMessageFormatter它是 MSMQ 客户端将 MSMQ 的实际读/写委托给它的东西Message。

查看格式化程序中的Read和Write方法 - 它们包含 Rebus 在使用 MSMQ 传输消息时使用的逻辑，无论选择何种序列化程序。

如果要将 Rebus 直接用于现有的 MSMQ 解决方案，则现有解决方案必须能够像 Rebus 一样将消息序列化/反序列化到正文中。

另请注意 Rebus 如何使用该Extension属性来存储标头 - 这可能意味着您将无法从现有的 MSMQ 解决方案向 Rebus 发送消息，因为 Rebus 将假定存在Extension可以解释为 UTF7 的字节流-编码的，序列化的标头值字典。

希望这可以帮助 ：）

于 2014-02-05T22:53:43.493 回答