对WCF消息详细介绍说明("WCF消息机制全面解析与详细说明")

原创

ithorizon 6个月前 (10-21) 阅读数 31 #后端开发

WCF消息机制全面解析与详细说明

一、WCF消息概述

Windows Communication Foundation（WCF）是微软推出的一个用于构建服务导向应用程序的框架。WCF中的消息是通信的基本单位，它封装了在服务之间传输的数据。本文将详细介绍WCF消息的机制、组成以及相关技术。

二、WCF消息的组成

WCF消息关键由以下几个部分组成：

消息头（Message Headers）

消息体（Message Body）

消息属性（Message Properties）

消息附件（Message Attachments）

三、消息头（Message Headers）

消息头包含了一系列键值对，用于传递涉及消息的元数据。WCF赞成两种类型的消息头：标准消息头和自定义消息头。

标准消息头包括：

To：指定消息的目标地址。

From：指定消息的发送者地址。

Action：指定消息的操作。

RelatesTo：指定消息与另一个消息的关系。

自定义消息头可以通过添加自定义属性来实现。

四、消息体（Message Body）

消息体是消息中携带的数据部分，通常包含业务逻辑所需的数据。消息体可以采用不同的编码格式，如XML、JSON等。以下是一个明了的XML消息体示例：


<?xml version="1.0" encoding="utf-8"?>
<soap:Envelope xmlns:soap="http://schemas.xmlsoap.org/soap/envelope/">
    <soap:Body>
        <MyService>
            <MyProperty>value</MyProperty>
        </MyService>
    </soap:Body>
</soap:Envelope>

五、消息属性（Message Properties）

消息属性是附加在消息上的键值对，用于存储与消息相关的额外信息。消息属性在WCF中通过MessageProperties类进行管理。以下是一个示例：


MessageProperties props = new MessageProperties();
props.Add("MyProperty", "MyValue");

六、消息附件（Message Attachments）

消息附件是附加在消息上的二进制数据，通常用于传输大型文件或非结构化数据。WCF赞成两种类型的附件：SOAP附件和MTOM附件。

SOAP附件通过MessagePartHeader类进行管理，而MTOM附件则通过MessagePart类进行管理。以下是一个SOAP附件的示例：


MessagePartHeader header = MessagePartHeader.CreateHeader("MyAttachment", "http://tempuri.org/MyAttachment");
MessagePart part = new MessagePart();
part.Data = File.ReadAllBytes("path/to/attachment");
MessageBuffer buffer = part.CreateBuffer();
Message message = Message.CreateMessage(buffer, null, header);

七、消息编码和解码

WCF赞成多种消息编码和解码格式，如文本编码、二进制编码和MTOM编码。以下是一个明了的消息编码和解码示例：


// 创建消息编码器
XmlDictionaryWriter writer = XmlDictionaryWriter.CreateTextWriter(stream);
MessageEncoder encoder = new TextMessageEncoder();
// 编码消息
encoder.WriteMessage(writer, message);
// 解码消息
MessageBuffer buffer = MessageBuffer.CreateBuffer(stream, stream.Length);
Message decodedMessage = encoder.ReadMessage(buffer.CreateStream(), buffer.Size);

八、消息可靠

WCF提供了多种机制来确保消息的可靠性，包括传输可靠、消息加密和签名等。以下是一个明了的消息可靠示例：


// 创建可靠策略
SecurityBindingElement security = new SecurityBindingElement();
security.MessageSecurityVersion = MessageSecurityVersion.WSSecurity11WSTrustFebruary2005WSSecureConversationFebruary2005WSSecurityPolicy11BasicSecurityProfile10;
// 创建绑定
CustomBinding binding = new CustomBinding();
binding.Elements.Add(security);
binding.Elements.Add(new TextMessageEncodingBindingElement());
// 创建服务
ServiceHost host = new ServiceHost(typeof(MyService));
host.AddServiceEndpoint(typeof(IMyService), binding, new Uri("http://localhost:8000/MyService"));
host.Open();