IMessage 接口 (System.Runtime.Remoting.Messaging)

admin
战术研究院
2026-07-30 16:10:40

IMessage 接口

定义

命名空间:

System.Runtime.Remoting.Messaging

程序集:mscorlib.dll

重要

一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。

包含协作消息接收器之间发送的通信数据。

public interface class IMessage

public interface IMessage

[System.Runtime.InteropServices.ComVisible(true)]

public interface IMessage

type IMessage = interface

[]

type IMessage = interface

Public Interface IMessage

派生

System.Runtime.Remoting.Activation.IConstructionCallMessage

System.Runtime.Remoting.Activation.IConstructionReturnMessage

System.Runtime.Remoting.Messaging.ConstructionCall

System.Runtime.Remoting.Messaging.ConstructionResponse

System.Runtime.Remoting.Messaging.IMethodCallMessage

System.Runtime.Remoting.Messaging.IMethodMessage

System.Runtime.Remoting.Messaging.IMethodReturnMessage

System.Runtime.Remoting.Messaging.MethodCall

System.Runtime.Remoting.Messaging.MethodCallMessageWrapper

System.Runtime.Remoting.Messaging.MethodResponse

System.Runtime.Remoting.Messaging.MethodReturnMessageWrapper

System.Runtime.Remoting.Messaging.ReturnMessage

更多…

属性

ComVisibleAttribute

示例

// Create a custom 'RealProxy'.

public ref class MyProxy: public RealProxy

{

private:

String^ myURIString;

MarshalByRefObject^ myMarshalByRefObject;

public:

MyProxy( Type^ myType )

: RealProxy( myType )

{

// RealProxy uses the Type to generate a transparent proxy.

myMarshalByRefObject = dynamic_cast(Activator::CreateInstance(myType));

// Get 'ObjRef', for transmission serialization between application domains.

ObjRef^ myObjRef = RemotingServices::Marshal( myMarshalByRefObject );

// Get the 'URI' property of 'ObjRef' and store it.

myURIString = myObjRef->URI;

Console::WriteLine( "URI :{0}", myObjRef->URI );

}

virtual IMessage^ Invoke ( IMessage^ myIMessage ) override

{

Console::WriteLine( "MyProxy.Invoke Start" );

Console::WriteLine( "" );

if ( dynamic_cast(myIMessage) )

Console::WriteLine( "IMethodCallMessage" );

if ( dynamic_cast(myIMessage) )

Console::WriteLine( "IMethodReturnMessage" );

Type^ msgType = myIMessage->GetType();

Console::WriteLine( "Message Type: {0}", msgType );

Console::WriteLine( "Message Properties" );

IDictionary^ myIDictionary = myIMessage->Properties;

// Set the '__Uri' property of 'IMessage' to 'URI' property of 'ObjRef'.

myIDictionary->default[ "__Uri" ] = myURIString;

IDictionaryEnumerator^ myIDictionaryEnumerator = dynamic_cast(myIDictionary->GetEnumerator());

while ( myIDictionaryEnumerator->MoveNext() )

{

Object^ myKey = myIDictionaryEnumerator->Key;

String^ myKeyName = myKey->ToString();

Object^ myValue = myIDictionaryEnumerator->Value;

Console::WriteLine( "\t{0} : {1}", myKeyName, myIDictionaryEnumerator->Value );

if ( myKeyName->Equals( "__Args" ) )

{

array^myObjectArray = (array^)myValue;

for ( int aIndex = 0; aIndex < myObjectArray->Length; aIndex++ )

Console::WriteLine( "\t\targ: {0} myValue: {1}", aIndex, myObjectArray[ aIndex ] );

}

if ( (myKeyName->Equals( "__MethodSignature" )) && (nullptr != myValue) )

{

array^myObjectArray = (array^)myValue;

for ( int aIndex = 0; aIndex < myObjectArray->Length; aIndex++ )

Console::WriteLine( "\t\targ: {0} myValue: {1}", aIndex, myObjectArray[ aIndex ] );

}

IMessage^ myReturnMessage;

myIDictionary->default[ "__Uri" ] = myURIString;

Console::WriteLine( "__Uri {0}", myIDictionary->default[ "__Uri" ] );

Console::WriteLine( "ChannelServices.SyncDispatchMessage" );

myReturnMessage = ChannelServices::SyncDispatchMessage( myIMessage );

// Push return value and OUT parameters back onto stack.

IMethodReturnMessage^ myMethodReturnMessage = dynamic_cast(myReturnMessage);

Console::WriteLine( "IMethodReturnMessage.ReturnValue: {0}", myMethodReturnMessage->ReturnValue );

Console::WriteLine( "MyProxy.Invoke - Finish" );

return myReturnMessage;

}

};

// Create a custom 'RealProxy'.

public class MyProxy : RealProxy

{

String myURIString;

MarshalByRefObject myMarshalByRefObject;

public MyProxy(Type myType) : base(myType)

{

// RealProxy uses the Type to generate a transparent proxy.

myMarshalByRefObject = (MarshalByRefObject)Activator.CreateInstance((myType));

// Get 'ObjRef', for transmission serialization between application domains.

ObjRef myObjRef = RemotingServices.Marshal(myMarshalByRefObject);

// Get the 'URI' property of 'ObjRef' and store it.

myURIString = myObjRef.URI;

Console.WriteLine("URI :{0}", myObjRef.URI);

}

public override IMessage Invoke(IMessage myIMessage)

{

Console.WriteLine("MyProxy.Invoke Start");

Console.WriteLine("");

if (myIMessage is IMethodCallMessage)

Console.WriteLine("IMethodCallMessage");

if (myIMessage is IMethodReturnMessage)

Console.WriteLine("IMethodReturnMessage");

Type msgType = myIMessage.GetType();

Console.WriteLine("Message Type: {0}", msgType.ToString());

Console.WriteLine("Message Properties");

IDictionary myIDictionary = myIMessage.Properties;

// Set the '__Uri' property of 'IMessage' to 'URI' property of 'ObjRef'.

myIDictionary["__Uri"] = myURIString;

IDictionaryEnumerator myIDictionaryEnumerator =

(IDictionaryEnumerator) myIDictionary.GetEnumerator();

while (myIDictionaryEnumerator.MoveNext())

{

Object myKey = myIDictionaryEnumerator.Key;

String myKeyName = myKey.ToString();

Object myValue = myIDictionaryEnumerator.Value;

Console.WriteLine("\t{0} : {1}", myKeyName,

myIDictionaryEnumerator.Value);

if (myKeyName == "__Args")

{

Object[] myObjectArray = (Object[])myValue;

for (int aIndex = 0; aIndex < myObjectArray.Length; aIndex++)

Console.WriteLine("\t\targ: {0} myValue: {1}", aIndex,

myObjectArray[aIndex]);

}

if ((myKeyName == "__MethodSignature") && (null != myValue))

{

Object[] myObjectArray = (Object[])myValue;

for (int aIndex = 0; aIndex < myObjectArray.Length; aIndex++)

Console.WriteLine("\t\targ: {0} myValue: {1}", aIndex,

myObjectArray[aIndex]);

}

IMessage myReturnMessage;

myIDictionary["__Uri"] = myURIString;

Console.WriteLine("__Uri {0}", myIDictionary["__Uri"]);

Console.WriteLine("ChannelServices.SyncDispatchMessage");

myReturnMessage = ChannelServices.SyncDispatchMessage(myIMessage);

// Push return value and OUT parameters back onto stack.

IMethodReturnMessage myMethodReturnMessage = (IMethodReturnMessage)

myReturnMessage;

Console.WriteLine("IMethodReturnMessage.ReturnValue: {0}",

myMethodReturnMessage.ReturnValue);

Console.WriteLine("MyProxy.Invoke - Finish");

return myReturnMessage;

}

' Create a custom 'RealProxy'.

Public Class MyProxy

Inherits RealProxy

Private myURIString As String

Private myMarshalByRefObject As MarshalByRefObject

Public Sub New(ByVal myType As Type)

MyBase.New(myType)

' RealProxy uses the Type to generate a transparent proxy.

myMarshalByRefObject = CType(Activator.CreateInstance(myType), MarshalByRefObject)

' Get 'ObjRef', for transmission serialization between application domains.

Dim myObjRef As ObjRef = RemotingServices.Marshal(myMarshalByRefObject)

' Get the 'URI' property of 'ObjRef' and store it.

myURIString = myObjRef.URI

Console.WriteLine("URI :{0}", myObjRef.URI)

End Sub

Public Overrides Function Invoke(ByVal myIMessage As IMessage) As IMessage

Console.WriteLine("MyProxy.Invoke Start")

Console.WriteLine("")

If TypeOf myIMessage Is IMethodCallMessage Then

Console.WriteLine("IMethodCallMessage")

End If

If TypeOf myIMessage Is IMethodReturnMessage Then

Console.WriteLine("IMethodReturnMessage")

End If

Dim msgType As Type

msgType = CObj(myIMessage).GetType

Console.WriteLine("Message Type: {0}", msgType.ToString())

Console.WriteLine("Message Properties")

Dim myIDictionary As IDictionary = myIMessage.Properties

' Set the '__Uri' property of 'IMessage' to 'URI' property of 'ObjRef'.

myIDictionary("__Uri") = myURIString

Dim myIDictionaryEnumerator As IDictionaryEnumerator = CType(myIDictionary.GetEnumerator(), _

IDictionaryEnumerator)

While myIDictionaryEnumerator.MoveNext()

Dim myKey As Object = myIDictionaryEnumerator.Key

Dim myKeyName As String = myKey.ToString()

Dim myValue As Object = myIDictionaryEnumerator.Value

Console.WriteLine(ControlChars.Tab + "{0} : {1}", myKeyName, myIDictionaryEnumerator.Value)

If myKeyName = "__Args" Then

Dim myObjectArray As Object() = CType(myValue, Object())

Dim aIndex As Integer

For aIndex = 0 To myObjectArray.Length - 1

Console.WriteLine(ControlChars.Tab + ControlChars.Tab + "arg: {0} myValue: {1}", _

aIndex, myObjectArray(aIndex))

Next aIndex

End If

If myKeyName = "__MethodSignature" And Not Nothing Is myValue Then

Dim myObjectArray As Object() = CType(myValue, Object())

Dim aIndex As Integer

For aIndex = 0 To myObjectArray.Length - 1

Console.WriteLine(ControlChars.Tab + ControlChars.Tab + "arg: {0} myValue: {1}", _

aIndex, myObjectArray(aIndex))

Next aIndex

End If

End While

Dim myReturnMessage As IMessage

myIDictionary("__Uri") = myURIString

Console.WriteLine("__Uri {0}", myIDictionary("__Uri"))

Console.WriteLine("ChannelServices.SyncDispatchMessage")

myReturnMessage = ChannelServices.SyncDispatchMessage(CObj(myIMessage))

' Push return value and OUT parameters back onto stack.

Dim myMethodReturnMessage As IMethodReturnMessage = CType(myReturnMessage, IMethodReturnMessage)

Console.WriteLine("IMethodReturnMessage.ReturnValue: {0}", myMethodReturnMessage.ReturnValue)

Console.WriteLine("MyProxy.Invoke - Finish")

Return myReturnMessage

End Function 'Invoke

End Class

注解

可以使用 IMessage 的消息接收器可以放置在客户端接收器链或服务器接收器链中。消息对象通过链从消息接收器传递到消息接收器，并携带一组命名属性，例如操作标识符、envoy 信息和参数。

实现 IMessage 接口的对象满足被视为消息对象的最小限定。消息接收器接收的确切对象不必传递到下一个接收器，但这种情况通常如此。

尽管属性包中的对象不必可序列化，但消息接收器实现者需要考虑这一点，因为流出应用程序域的属性必须可序列化。

属性

名称

说明

Properties

获取一个表示消息属性集合的集合 IDictionary 。

适用于