Microsoft.ServiceBus.Messaging.MessageReceiver messageReceiver = messagingFactory.CreateMessageReceiver( Microsoft.ServiceBus.Messaging.SubscriptionClient.FormatSubscriptionPath(
"TopicName",
"SubscriptionName"),
Microsoft.ServiceBus.Messaging.ReceiveMode.PeekLock);
List<BrokeredMessage> brokeredMessages = new List<BrokeredMessage>();
var messages = messageReceiver.ReceiveBatch(10);
brokeredMessages.AddRange(messages);
foreach (var message in messages)
var stream = message.GetBody<System.IO.Stream>();
var reader = new StreamReader(stream);
var body = reader.ReadToEnd();
这给出了错误的输出 -
@string3http://schemas.microsoft.com/2003/10/Serialization/�h
{"MyID":"121"}
当我在下面使用时,它的工作完美 -
string body = message.GetBody<string>();
输出 - {"MyID":"121"}
为什么会这样?
我猜这就是你发送邮件的方式:
MyClass myObj = new MyClass { MyID = "121" };
string json = ... // serialize myObj to JSON
var message = new BrokeredMessage(json);
但是,这不会按原样发送您的内容。您实际上正在使用此构造函数重载:
public BrokeredMessage(object serializableObject)
它确实:
通过使用带有二进制XmlDictionaryWriter的DataContractSerializer,从给定对象初始化BrokeredMessage类的新实例。
因此,您的字符串被序列化为XML,然后使用二进制格式进行格式化。这就是您在消息内容中看到的内容(名称空间和一些不可读的字符)。
message.GetBody<string>
工作正常,因为它反过来:它从二进制XML反序列化消息。
message.GetBody<Stream>
是一个原始操作,因此你得到原始字节。
要按原样序列化内容,您应该使用基于Stream
的构造函数重载:
var message = new BrokeredMessage(new MemoryStream(Encoding.UTF8.GetBytes(json)), true);