我需要通过Azure Service Bus从.NET Core应用程序发送消息到BizTalk 2013.我已经在BizTalk上配置了WCF自定义接收端口但是在收到消息时会收到以下错误:
适配器“WCF-Custom”引发了错误消息。详细信息“System.Xml.XmlException:输入源格式不正确。
我找到了使用Windows.Azure.ServiceBus包和BrokeredMessage的示例,但这已被弃用。我需要使用Microsoft.Azure.ServiceBus和Message对象。
我已经尝试了很多方法来序列化XML,但似乎没有任何工作。
总之,我正在创建这样的消息:
var message = new Message(Encoding.UTF8.GetBytes("<message>Hello world</message>"));
有没有办法正确序列化消息以便在BizTalk 2013中由WCF接收?
我想到了。
对于需要使用Microsoft.Azure.ServiceBus消息通过Azure Service Bus发送消息到BizTalk 2013 WCF-Custom接收端口的任何人。
var toAddress = "sb://yourbusname.servicebus.windows.net/yourqueuename";
var bodyXml = SerializeToString(yourSerializableObject); //
var soapXmlString = string.Format(@"<s:Envelope xmlns:s=""http://www.w3.org/2003/05/soap-envelope"" xmlns:a=""http://www.w3.org/2005/08/addressing""><s:Header><a:Action s:mustUnderstand=""1"">*</a:Action><a:To s:mustUnderstand=""1"">{0}</a:To></s:Header><s:Body>{1}</s:Body></s:Envelope>",
toAddress, bodyXml);
var content = Encoding.UTF8.GetBytes(soapXmlString);
var message = new Message { Body = content };
message.ContentType = "application/soap+msbin1";
这将以适当的SOAP格式包装Xml。注意,SOAP信封中嵌入的“to”是必要的(我发现它使用message.To不起作用)。
为了完整性,这是序列化方法(对于干净的xml):
public string SerializeToString<T>(T value)
{
var emptyNamespaces = new XmlSerializerNamespaces(new[] { XmlQualifiedName.Empty });
var serializer = new XmlSerializer(value.GetType());
var settings = new XmlWriterSettings
{
Indent = false,
OmitXmlDeclaration = true
};
using (var stream = new StringWriter())
using (var writer = XmlWriter.Create(stream, settings))
{
serializer.Serialize(writer, value, emptyNamespaces);
return stream.ToString();
}
}