CLI程序进程之间的通讯

C++/CLI程序进程之间的通讯2007-05-15 天极谢启东编…现在，把大型软件项目分解为一些相交互的小程序似乎变得越来越普遍，程序各部分之间的通讯可使用某种类型的通讯协议，这些程序可能运行在不同的机器上、不同的操作系统中、以不同的语言编写，但也有可能只在同一台机器上，实际上，这些程序可看成是同一程序中的不同线程。而本文主要讨论C++/CLI程序间的通讯，当然，在此是讨论进程间通讯，而不是网络通讯。

简介

试想一个包含数据库查询功能的应用，通常有一个被称为服务端的程序，等待另一个被称为客户端程序发送请求，当接收到请求时，服务端执行相应功能，并把结果（或者错误信息）返回给客户端。在许多情况中，有着多个客户端，所有的请求都会在同一时间发送到同一服务端，这就要求服务端程序要更加高级、完善。

在某些针对此任务的环境中，服务端程序可能只是众多程序中的一个程序，其他可能也是服务端或者客户端程序，实际上，如果我们的数据库服务端需要访问不存在于本机的文件，那么它就可能成为其他某个文件服务器的一个客户端。一个程序中可能会有一个服务线程及一个或多个客户线程，因此，我们需小心使用客户端及服务端这个术语，虽然它们表达了近似的抽象含义，但在具体实现上却大不相同。从一般的观点来看，客户端即为服务端所提供服务的"消费者"，而服务端也能成为其他某些服务的客户端。

服务端套接字

让我们从一个具体有代表性的服务端程序开始（请看例1）,此程序等待客户端发送一对整数，把它们相加之后返回结果给客户端。

例1：

using namespace System;
using namespace System::IO;
using namespace System::Net;
using namespace System::Net::Sockets;

int main（array<String^>^ argv）
{
if （argv->Length ！= 1）
{
Console::WriteLine（"Usage: Server port"）;
Environment::Exit（1）;
}

int port = 0;

try
{
port = Int32::Parse（argv[0]）;
}
catch （FormatException^ e）
{
Console::WriteLine（"Port number {0} is ill-formed", argv[0]）;
Environment::Exit（2）;
}

/*1*/ if （port < IPEndPoint::MinPort || port > IPEndPoint::MaxPort）
{
Console::WriteLine（"Port number must be in the range {0}-{1}",
IPEndPoint::MinPort, IPEndPoint::MaxPort）;
Environment::Exit（3）;
}

/*2*/ IPAddress^ ipAddress = 
Dns::GetHostEntry（Dns::GetHostName（））->AddressList[0];
/*3*/ IPEndPoint^ ipEndpoint = gcnew IPEndPoint（ipAddress, port）;

/*4*/ Socket^ listenerSocket = gcnew Socket（AddressFamily::InterNetwork,
SocketType::Stream, ProtocolType::Tcp）;

/*5*/ listenerSocket->Bind（ipEndpoint）;

/*6*/ listenerSocket->Listen（1）;
/*7*/ Console::WriteLine（"Server listener blocking status is {0}",
listenerSocket->Blocking）;

/*8*/ Socket^ serverSocket = listenerSocket->Accept（）;
Console::WriteLine（"New connection accepted"）;
/*9*/ listenerSocket->Close（）;

/*10*/ NetworkStream^ netStream = gcnew NetworkStream（serverSocket）;
/*11*/ BinaryReader^ br = gcnew BinaryReader（netStream）;
/*12*/ BinaryWriter^ bw = gcnew BinaryWriter（netStream）;

try
{
int value1, value2;
int result;

while （true）
{
/*13*/ value1 = br->ReadInt32（）;
/*14*/ value2 = br->ReadInt32（）;
Console::Write（"Received values {0,3} and {1,3}", 
value1, value2）;

result = value1 + value2;
/*15*/ bw->Write（result）;
Console::WriteLine（", sent result {0,3}", result）;
}
}
/*16*/ catch （EndOfStreamException^ e）
{
}
/*17*/ catch （IOException^ e）
{
Console::WriteLine（"IOException {0}", e）;
}

/*18*/ serverSocket->Shutdown（SocketShutdown::Both）;
/*19*/ serverSocket->Close（）;
/*20*/ netStream->Close（）;
Console::WriteLine（"Shutting down server"）;
}