C# Azure:如何从Microsoft.Azure.ServiceBus.Message读取正文?

Question

我在使用Microsoft.Azure.ServiceBus.Message类时遇到问题。我想创建一个包含有效负载对象的 Message 对象，然后从中读回此对象。在我当前的示例中，我什至没有通过真正的 Azure 总线发送消息;我只是在内存中创建它，然后尝试读取它。

我无法弄清楚我应该将消息正文读取为哪种类型。我已经尝试了byte[]，string和原始对象类型。在我的所有情况下，我都会得到一个XmlException："输入源格式不正确"。

有人可以告诉我我在编码或解码消息时做错了什么吗？

[DataContract]
public class Thingy
{
[DataMember]
public string Doodad { get; set; }
}
private static Message CreateMessage()
{
var entityMessage = new Thingy {Doodad = "foobar"};
var serializedMessageBody = JsonConvert.SerializeObject(entityMessage);
var contentType = typeof(Thingy).AssemblyQualifiedName;
var bytes = Encoding.UTF8.GetBytes(serializedMessageBody);
var message = new Message(bytes) {ContentType = contentType};
return message;
}
[Test]
public void ReadMessageBytes()
{
var message = CreateMessage();
var body = message.GetBody<byte[]>();
Console.WriteLine(body);
}
[Test]
public void ReadMessageString()
{
var message = CreateMessage();
var body = message.GetBody<string>();
Console.WriteLine(body);
}
[Test]
public void ReadMessageThingy()
{
var message = CreateMessage();
var body = message.GetBody<Thingy>();
Console.WriteLine(body);
}

Answer 1

我发现这有效：

[Test]
public void ReadMessageProperly()
{
var message = CreateMessage();
var body = message.Body;
var text = Encoding.UTF8.GetString(body);
var thingy = JsonConvert.DeserializeObject<Thingy>(text);
Assert.IsInstanceOf<Thingy>(thingy);
Assert.AreEqual("foobar", thingy.Doodad);
}

Answer 2

使用自定义DataContract类型和DataContractSerializer创建代理消息时：

Record recordDataContract = new Record { Id = "DataContract Record" };
BrokeredMessage recordDataContractMessage = new BrokeredMessage(recordDataContract, new DataContractSerializer(typeof(Record)));

您可以通过以下方式接收此消息：

Record r = receiveMessage.GetBody<Record>(new DataContractSerializer(typeof(Record)));

使用自定义**DataContract**类型和默认序列化程序(数据协定 + 二进制 XML(创建**BrokeredMessage**时：

[DataContract(Namespace = "")]
class Record {
[DataMember]
public string Id { get; set; }
}

Record recordDefault = new Record { Id = "default Record" };
BrokeredMessage recordDefaultMessage = new BrokeredMessage(recordDefault);

您可以通过以下方式接收此消息：

Record r = receiveMessage.GetBody<Record>();

有关其他参考，您可以查看此博客。它有针对不同场景的详细示例。

希望对您有所帮助。