C＋＋/CLI程序进程之间的通讯

扫一扫
分享文章到微信
扫一扫
关注官方公众号
至顶头条

现在，把大型软件项目分解为一些相交互的小程序似乎变得越来越普遍，程序各部分之间的通讯可使用某种类型的通讯协议。

作者：谢启东编译来源：天极开发 2007年11月16日

关键字：

客户端套接字

　　现在，让我们来看一下客户端程序（参见例2）。在连接到服务端之后，客户端将发送一对随机的整数，并且在发送下一对之前等待返回的结果。此处我们所看到的是服务端与客户端的同步通讯，客户端在接收到前一对值的结果之前，是不会发送另一对新值的。

　　例2：

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

int main(array<String^>^ argv)
{
　if (argv->Length != 2)
　{
　　Console::WriteLine("Usage: Client port message-count");
　　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);
　}

　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);
　}

　int messageCount = 0;

　try
　{
　　messageCount = Int32::Parse(argv[1]);
　}
　catch (FormatException^ e)
　{
　　Console::WriteLine("Message count {0} is ill-formed", argv[1]);
　　Environment::Exit(4);
　}

　IPAddress^ ipAddress = nullptr;
　try
　{
　　/*1*/ ipAddress = Dns::GetHostEntry(Dns::GetHostName())->AddressList[0];
　　/*2*/ IPEndPoint^ ipEndpoint = gcnew IPEndPoint(ipAddress, port);

　　/*3*/ Socket^ clientSocket = gcnew Socket(AddressFamily::InterNetwork,
　　SocketType::Stream, ProtocolType::Tcp);

　　/*4*/ clientSocket->Connect(ipEndpoint);

　　NetworkStream^ netStream = gcnew NetworkStream(clientSocket);
　　BinaryReader^ br = gcnew BinaryReader(netStream);
　　BinaryWriter^ bw = gcnew BinaryWriter(netStream);

　　int value1, value2;
　　int result;

　　Random^ random = gcnew Random;
　　(int i = 1; i <= messageCount; ++i)
　　{
　　　/*5*/ value1 = static_cast<int>(random->NextDouble() * 100);
　　　/*6*/ value2 = static_cast<int>(random->NextDouble() * 100);
　
　　　/*7*/ bw->Write(value1);
　　　/*8*/ bw->Write(value2);
　　　Console::Write("Sent values {0,3} and {1,3}",value1, value2);
　
　　　/*9*/ result = br->ReadInt32();
　　　Console::WriteLine(", received result {0,3}", result);
　　　/*10*/ Thread::Sleep(3000);
　　}

　　/*11*/ clientSocket->Shutdown(SocketShutdown::Both);
　　Console::WriteLine("Notified server we're shutting down");
　　/*12*/ clientSocket->Close();
　　/*13*/ netStream->Close();
　　Console::WriteLine("Shutting down client");
　}
　/*14*/ catch (SocketException^ e)
　{
　　Console::WriteLine("Request to connect to {0} on port {1} failed"+ "\nbecause of {2}", ipAddress, port, e);
　　Environment::Exit(5);
　}
}

　　如同服务端一样，客户端取得一个IP地址，把它与端口号绑定以生成一个IPEndPoint，并连接到服务端，而服务端在此之前一直处于阻塞监听模式。

　　在每一个发送与接收操作之间，我们有意延迟三秒，以便观察程序的输出。

　　以下是一个服务端程序使用端口2500时的输出：

Server listener blocking status is True
New connection accepted
Received values 42 and 69, sent result 111
Received values 66 and 71, sent result 137
Received values 7 and 93, sent result 100
Received values 43 and 65, sent result 108
Received values 45 and 3, sent result 48
Shutting down server

　　而以下是对应的客户端程序，在发送5对值之后的输出：

Sent values 42 and 69, received result 111
Sent values 66 and 71, received result 137
Sent values 7 and 93, received result 100
Sent values 43 and 65, received result 108
Sent values 45 and 3, received result 48
Notified server we're shutting down
Shutting down client

VIP专区

VIP用户

普通用户

闂傚倷绶￠崣搴ㄥ窗閺囩偐鏋庨柕蹇嬪灪婵ジ鏌曡箛瀣偓鏍綖閿燂拷

濠电姷顣介埀顒€鍟块埀顒€缍婇幃妯诲緞閹邦剛鐣洪梺闈浥堥弲婊勬叏濠婂牊鍋ㄦい鏍ㄧ〒閹藉啴鏌熼悜鈺傛珚鐎规洘宀稿畷鍫曞煛閸屾粍娈搁梻浣筋嚃閸ㄤ即宕㈤弽顐ュС闁挎稑瀚崰鍡樸亜閵堝懎濮┑鈽嗗亝濠㈡ê螞濡ゅ懏鍋傛繛鍡樻尭鐎氬鏌嶈閸撶喎顕ｉ渚婄矗濞撴埃鍋撻柣娑欐崌閺屾稑鈹戦崨顕呮▊缂備焦顨呴惌鍌炵嵁鎼淬劌鐒垫い鎺戝鐎氬銇勯弽銊ф噥缂佽妫濋弻鐔碱敇瑜嶉悘鑼磼鏉堛劎绠為柡灞芥喘閺佹劙宕熼鐘虫緰闂佽崵濮抽梽宥夊垂閽樺）锝夊礋椤栨稑娈滈梺纭呮硾椤洟鍩€椤掆偓閿曪妇妲愰弮鍫濈闁绘劕寮Δ鍛厸闁割偒鍋勯悘锕傛煕鐎ｎ偆澧紒鍌涘笧閹瑰嫰鎼圭憴鍕靛晥闂備礁鎼€氱兘宕归柆宥呯；鐎广儱顦伴崕宥夋煕閺囥劌澧ù鐘趁湁闁挎繂妫楅埢鏇㈡煃瑜滈崜姘跺蓟閵娧勵偨闁绘劕顕埢鏇㈡倵閿濆倹娅囨い蹇涗憾閺屾洟宕遍鐔奉伓

重磅专题

往期文章

C＋＋/CLI程序进程之间的通讯

业界热点: