MSMQ自定义消息格式

本文关键字：格式 自定义消息 MSMQ | 更新日期: 2023-09-27 18:28:57

我想在MSMQ中生成消息，该消息将具有文本，例如

<order><data id="5" color="blue"/></order>

这是标准的XML。到目前为止，我已经制作了Serializable类

[Serializable]
public class order
string id
string color

我正在使用BinaryFormatter。当我查看消息时。BodyStream有一些字符不应该在那里（00,01，FF），那么我不能收到这个消息而没有错误。

这个任务看起来很简单，只需放入文本

<order><data id="5" color="blue"/></order>

进入msmq。

我的全部重要代码：

public static void Send()
    {
        using (message = new Message())
        {
            request req = new request("1", "blue");
                message.Recoverable = true;
                message.Body = req.ToString();
                message.Formatter = new BinaryMessageFormatter();
                using (msmq = new MessageQueue(@".'Private$'testrfid"))
                {
                    msmq.Formatter = new BinaryMessageFormatter();
                    msmq.Send(message, MessageQueueTransactionType.None);
                }
        }
    }
[Serializable]
public class request
{
    private readonly string _order;
    private readonly string _color;
    public request(string order, string color)
    {
        _order = order;
        _color = color;
    }
    public request()
    { }
    public string Order
    {
        get { return _order; }
    }
    public string Color
    {
        get { return _color; }
    }
    public override string ToString()
    {
        return string.Format(@"<request> <job order = ""{0}"" color = ""{1}"" /> </request>",_order,_color);
    }
}

MSMQ自定义消息格式

您的问题一点也不清楚；只要使用BinaryMessageFormatter，就可以向MSMQ发送任何类型的消息。这里有一个例子：

string error = "Some error message I want to log";
using (MessageQueue MQ = new MessageQueue(@".'Private$'Your.Queue.Name"))
{
    BinaryMessageFormatter formatter = new BinaryMessageFormatter();
    System.Messaging.Message mqMessage = new System.Messaging.Message(error, formatter);
    MQ.Send(mqMessage, MessageQueueTransactionType.Single);
    MQ.Close();
}

我没有找到Message.Body在我传递给Body的字符串之前包含这些ascii字符的原因。我只是直接填充BodyStream而不是Body，并让它自己转换：

Message.BodyStream = new MemoryStream(Encoding.ASCII.GetBytes(string i want to put as Body))

那么消息只是一个字符串，没有其他内容。

您不需要可序列化类来向消息队列发送字符串。

由于您使用的是BinaryMessageFormatter，因此必须首先使用文本编码器（例如）将字符串转换为字节数组

message.Body = new UTF8Encoding().GetBytes(req.ToString());

我只是以UTF8为例，您可以使用任何您喜欢的编码。

然后，当你从队列中读取消息时，记得使用相同的编码来取回你的字符串，例如

string myString = new UTF8Encoding().GetString(message.Body);

希望这能帮助

相关文章：