2

在我的工作中,我使用部分使用 c++ 和 C# 开发的应用程序。C++ 代码负责管理activeMQ(发送、接收消息)。

我开发了一个应用程序,通过订阅我的 C# 应用程序来监视主题中发送的消息。

因此,当向主题发送消息时,我的应用程序设法处理消息,但消息在 ActiveMQBytesMessage 中序列化。

我怎样才能反序列化这个对象?

public void OnMessage(IMessage message)
    {
        if (message != null)
        {
            var content = (message as ActiveMQBytesMessage).Content; // This is a byte[], I tried to deserialize using BinaryFormatter but it throws an exception, I can't write it here because I'm at home.
        }
    }

我刚刚注意到 ActiveMQBytesMessage 从命名空间 Apache.NMS 继承了 IBytesMessage,但我没有看到任何可以帮助我反序列化消息的东西。

我使用最新版本的 ActiveMQ 和 NMS

[NB] 我的 C# 应用程序的目标是简单地监控 ActiveMQ 通道内发生的事情。这就是为什么我需要反序列化 ActiveMQBytesMessage 以便我可以在网格视图中显示对象的名称及其内容。

[添加更多信息]

这是我试图反序列化的内容。

var memoryStream = new MemoryStream((message as ActiveMQBytesMessage).Content);
var binaryFormatter = new BinaryFormatter();

memoryStream.Position = 0;

var deserializedMessage = binaryFormatter.Deserialize(memoryStream);

反序列化时出现此错误:

输入流不是有效的二进制格式。起始内容(以字节为单位)为:00-00-00-00-00-00-4F-8C-00-00-00-09-00-00-00-00-54 ...

4

1 回答 1

1

(我在这里做了一些假设,因为您没有指定某些细节。)您尝试使用的 BinaryFormatter 仅适用于 .NET 对象,不适用于 C++ 对象。最有可能的是,这些对象没有以平台中立的方式编码,而是采用特定于该特定编译器和平台的 C++ 格式。因此,您可以直接解析二进制代码以确定编码的对象,然后手动解码数据。如果这些都是不平凡的对象,这将是一项艰巨的任务。如果可能,请尝试让原始应用程序将对象编码为平台中立的格式,该格式可以在 C# 中轻松解析和实例化。(我更喜欢使用 TextMessage 和 XML 编码。)它不会 它不像现在显然正在进行的直接 C++ 到 C++ 编码/解码那样有效,但它将允许对消息流进行外部监控。当我这样做时,我将对象的完整类型名(包括命名空间)放在 NMSType 标头属性中。然后这告诉我消息内容的内部结构,我可以实例化正确的对象来解析消息中的数据。

如果所有这些都没有帮助,或者假设是错误的并且您使用的是托管 C++,那么这个问题/答案可能会对您有所帮助:ActiveMQ NMS C# 对象消息使用哪种序列化方法?

于 2012-05-17T06:31:52.750 回答