IpcChannel Třída
Definice
Důležité
Některé informace platí pro předběžně vydaný produkt, který se může zásadně změnit, než ho výrobce nebo autor vydá. Microsoft neposkytuje žádné záruky, výslovné ani předpokládané, týkající se zde uváděných informací.
Poskytuje kanál implementace, který používá protokol IPC k přenosu zpráv.
public ref class IpcChannel : System::Runtime::Remoting::Channels::IChannelReceiver, System::Runtime::Remoting::Channels::IChannelSender, System::Runtime::Remoting::Channels::ISecurableChannel
public class IpcChannel : System.Runtime.Remoting.Channels.IChannelReceiver, System.Runtime.Remoting.Channels.IChannelSender, System.Runtime.Remoting.Channels.ISecurableChannel
type IpcChannel = class
interface IChannelReceiver
interface IChannelSender
interface IChannel
interface ISecurableChannel
type IpcChannel = class
interface IChannelReceiver
interface IChannel
interface IChannelSender
interface ISecurableChannel
Public Class IpcChannel
Implements IChannelReceiver, IChannelSender, ISecurableChannel
- Dědičnost
-
IpcChannel
- Implementuje
Příklady
Následující příklad kódu ukazuje, jak použít IpcChannel k nastavení serveru vzdálené komunikace a jeho klienta. Příklad obsahuje tři části:
Server
Klient
Vzdálený objekt používaný serverem a klientem.
Následující příklad kódu ukazuje server.
#using <System.dll>
#using <System.Runtime.Remoting.dll>
#using "common.dll"
using namespace System;
using namespace System::Runtime::Remoting::Channels::Ipc;
void main()
{
// Create the server channel.
IpcChannel^ serverChannel = gcnew IpcChannel( L"localhost:9090" );
// Register the server channel.
System::Runtime::Remoting::Channels::ChannelServices::RegisterChannel( serverChannel );
// Show the name of the channel.
Console::WriteLine( L"The name of the channel is {0}.", serverChannel->ChannelName );
// Show the priority of the channel.
Console::WriteLine( L"The priority of the channel is {0}.", serverChannel->ChannelPriority );
// Show the URIs associated with the channel.
System::Runtime::Remoting::Channels::ChannelDataStore^ channelData = (System::Runtime::Remoting::Channels::ChannelDataStore^)serverChannel->ChannelData;
for each (String^ uri in channelData->ChannelUris)
{
Console::WriteLine("The channel URI is {0}.", uri);
}
// Expose an object for remote calls.
System::Runtime::Remoting::RemotingConfiguration::RegisterWellKnownServiceType(
RemoteObject::typeid,L"RemoteObject.rem",
System::Runtime::Remoting::WellKnownObjectMode::Singleton);
// Parse the channel's URI.
array<String^>^ urls = serverChannel->GetUrlsForUri( L"RemoteObject.rem" );
if ( urls->Length > 0 )
{
String^ objectUrl = urls[ 0 ];
String^ objectUri;
String^ channelUri = serverChannel->Parse( objectUrl, objectUri );
Console::WriteLine( L"The object URI is {0}.", objectUri );
Console::WriteLine( L"The channel URI is {0}.", channelUri );
Console::WriteLine( L"The object URL is {0}.", objectUrl );
}
// Wait for the user prompt.
Console::WriteLine( L"Press ENTER to exit the server." );
Console::ReadLine();
Console::WriteLine( L"The server is exiting." );
}
using System;
using System.Runtime.Remoting.Channels.Ipc;
public class Server
{
public static void Main(string[] args)
{
// Create the server channel.
IpcChannel serverChannel =
new IpcChannel("localhost:9090");
// Register the server channel.
System.Runtime.Remoting.Channels.ChannelServices.RegisterChannel(
serverChannel);
// Show the name of the channel.
Console.WriteLine("The name of the channel is {0}.",
serverChannel.ChannelName);
// Show the priority of the channel.
Console.WriteLine("The priority of the channel is {0}.",
serverChannel.ChannelPriority);
// Show the URIs associated with the channel.
System.Runtime.Remoting.Channels.ChannelDataStore channelData =
(System.Runtime.Remoting.Channels.ChannelDataStore)
serverChannel.ChannelData;
foreach (string uri in channelData.ChannelUris)
{
Console.WriteLine("The channel URI is {0}.", uri);
}
// Expose an object for remote calls.
System.Runtime.Remoting.RemotingConfiguration.
RegisterWellKnownServiceType(
typeof(RemoteObject), "RemoteObject.rem",
System.Runtime.Remoting.WellKnownObjectMode.Singleton);
// Parse the channel's URI.
string[] urls = serverChannel.GetUrlsForUri("RemoteObject.rem");
if (urls.Length > 0)
{
string objectUrl = urls[0];
string objectUri;
string channelUri = serverChannel.Parse(objectUrl, out objectUri);
Console.WriteLine("The object URI is {0}.", objectUri);
Console.WriteLine("The channel URI is {0}.", channelUri);
Console.WriteLine("The object URL is {0}.", objectUrl);
}
// Wait for the user prompt.
Console.WriteLine("Press ENTER to exit the server.");
Console.ReadLine();
Console.WriteLine("The server is exiting.");
}
}
Následující příklad kódu ukazuje klienta pro tento server.
#using <System.dll>
#using <System.Runtime.Remoting.dll>
#using "common.dll"
using namespace System;
using namespace System::Runtime::Remoting::Channels::Ipc;
void main()
{
// Create the channel.
IpcChannel^ channel = gcnew IpcChannel;
// Register the channel.
System::Runtime::Remoting::Channels::ChannelServices::RegisterChannel(channel);
// Register as client for remote object.
System::Runtime::Remoting::WellKnownClientTypeEntry^ remoteType = gcnew
System::Runtime::Remoting::WellKnownClientTypeEntry(
RemoteObject::typeid,L"ipc://localhost:9090/RemoteObject.rem" );
System::Runtime::Remoting::RemotingConfiguration::RegisterWellKnownClientType(remoteType);
// Create a message sink.
String^ objectUri;
System::Runtime::Remoting::Messaging::IMessageSink^ messageSink = channel->CreateMessageSink(
L"ipc://localhost:9090/RemoteObject.rem", nullptr, objectUri );
Console::WriteLine( L"The URI of the message sink is {0}.", objectUri );
if ( messageSink != nullptr )
{
Console::WriteLine( L"The type of the message sink is {0}.", messageSink->GetType() );
}
// Create an instance of the remote object.
RemoteObject^ service = gcnew RemoteObject;
// Invoke a method on the remote object.
Console::WriteLine( L"The client is invoking the remote object." );
Console::WriteLine( L"The remote object has been called {0} times.", service->GetCount() );
}
using System;
using System.Runtime.Remoting.Channels.Ipc;
public class Client
{
public static void Main(string[] args)
{
// Create the channel.
IpcChannel channel = new IpcChannel();
// Register the channel.
System.Runtime.Remoting.Channels.ChannelServices.
RegisterChannel(channel);
// Register as client for remote object.
System.Runtime.Remoting.WellKnownClientTypeEntry remoteType =
new System.Runtime.Remoting.WellKnownClientTypeEntry(
typeof(RemoteObject),
"ipc://localhost:9090/RemoteObject.rem");
System.Runtime.Remoting.RemotingConfiguration.
RegisterWellKnownClientType(remoteType);
// Create a message sink.
string objectUri;
System.Runtime.Remoting.Messaging.IMessageSink messageSink =
channel.CreateMessageSink(
"ipc://localhost:9090/RemoteObject.rem", null,
out objectUri);
Console.WriteLine("The URI of the message sink is {0}.",
objectUri);
if (messageSink != null)
{
Console.WriteLine("The type of the message sink is {0}.",
messageSink.GetType().ToString());
}
// Create an instance of the remote object.
RemoteObject service = new RemoteObject();
// Invoke a method on the remote object.
Console.WriteLine("The client is invoking the remote object.");
Console.WriteLine("The remote object has been called {0} times.",
service.GetCount());
}
}
Následující příklad kódu ukazuje vzdálený objekt používaný serverem a klientem.
using namespace System;
// Remote object.
public ref class RemoteObject: public MarshalByRefObject
{
private:
static int callCount = 0;
public:
int GetCount()
{
Console::WriteLine( L"GetCount has been called." );
callCount++;
return (callCount);
}
};
using System;
// Remote object.
public class RemoteObject : MarshalByRefObject
{
private int callCount = 0;
public int GetCount()
{
Console.WriteLine("GetCount has been called.");
callCount++;
return(callCount);
}
}
Poznámky
Důležité
Volání metod z této třídy s nedůvěryhodnými daty představuje bezpečnostní riziko. Metody z této třídy volejte pouze s důvěryhodnými daty. Další informace najdete v tématu Ověření všech vstupů.
Kanály se používají infrastrukturou vzdálené komunikace the.NET Framework k přenosu vzdálených volání. Když klient volá vzdálený objekt, volání je serializováno do zprávy, která je odeslána klientským kanálem a přijata kanálem serveru. Po přijetí zprávy se deserializuje a zpracuje. Všechny vrácené hodnoty jsou přenášeny kanálem serveru a přijaty klientským kanálem.
Třída IpcChannel je třída pro pohodlí, která kombinuje funkce IpcClientChannel třídy a IpcServerChannel třídy .
Upozornění
Při nastavení exclusiveAddressUse
vlastnosti false
na v argumentu properties
lze pro stejnou pojmenovanou kanál zaregistrovat několik IpcServerChannel objektů. V takovém případě mohou žádosti přejít na kterýkoli z registrovaných kanálů. Toto nastavení se považuje za bezpečné pouze v případě, že se používají také řadiče zabezpečení.
Konstruktory
IpcChannel() |
Inicializuje novou instanci IpcChannel třídy a aktivuje pouze klientský kanál, a ne kanál serveru. |
IpcChannel(IDictionary, IClientChannelSinkProvider, IServerChannelSinkProvider) |
Inicializuje novou instanci IpcChannel třídy se zadanými vlastnostmi konfigurace a jímky. |
IpcChannel(IDictionary, IClientChannelSinkProvider, IServerChannelSinkProvider, CommonSecurityDescriptor) |
Inicializuje novou instanci IpcChannel třídy se zadanými vlastnostmi konfigurace a jímky. |
IpcChannel(String) |
Inicializuje novou instanci IpcChannel třídy se serverovým kanálem, který naslouchá na zadaném portu IPC. |
Vlastnosti
ChannelData |
Získá data specifická pro kanál. |
ChannelName |
Získá název aktuálního kanálu. |
ChannelPriority |
Získá prioritu aktuálního kanálu. |
IsSecured |
Získá nebo nastaví logickou hodnotu, která označuje, zda je aktuální kanál zabezpečený. |
Metody
CreateMessageSink(String, Object, String) |
Vrátí jímku zpráv kanálu, která doručuje zprávy na zadanou adresu URL nebo datový objekt kanálu. |
Equals(Object) |
Určí, zda se zadaný objekt rovná aktuálnímu objektu. (Zděděno od Object) |
GetHashCode() |
Slouží jako výchozí hashovací funkce. (Zděděno od Object) |
GetType() |
Type Získá z aktuální instance. (Zděděno od Object) |
GetUrlsForUri(String) |
Vrátí pole všech adres URL objektu se zadaným identifikátorem URI hostovaným v aktuálním IpcChannelobjektu . |
MemberwiseClone() |
Vytvoří mělkou kopii aktuálního Objectsouboru . (Zděděno od Object) |
Parse(String, String) |
Extrahuje identifikátor URI kanálu a identifikátor URI vzdáleného známého objektu ze zadané adresy URL. |
StartListening(Object) |
Dá aktuálnímu kanálu pokyn, aby začal naslouchat žádostem. |
StopListening(Object) |
Dá aktuálnímu kanálu pokyn, aby přestal naslouchat žádostem. |
ToString() |
Vrátí řetězec, který představuje aktuální objekt. (Zděděno od Object) |