在标号1中,通过IPEndPoint类中的MinPort和MaxPort这两个公共静态字段,就可得到特定系统上可用的端口范围。
而在标号2中,可得到我们自己的主机名,并解析到一个IpHostEntry,可从中取得本机的IP地址。接下来在标号3中,用IP地址和端口号创建了一个IPEndPoint对象,其可为某个连接提供某种服务。
在标号4中,创建了一个Internet传输服务托管版本的套接字,一旦它被创建,就应通过Bind函数(标号5)绑定到一个特定的端点。接下来,套接字声明其已经开始服务,并监听连接请求(标号6)。传递给Listen的参数表明了请求队列中连接挂起的长度,因为我们只有一个客户端,所以在此1就足够了。
套接字默认以阻塞模式创建,如标号7中所示,这意味着,它会一直等待连接请求。
当从客户端接收到连接请求时,阻塞的套接字就会被唤醒,通过调用Accept(如标号8),接受请求并创建另一个套接字,并通过此套接字来与客户端通讯。我们看到,此时的服务端有两个套接字:一个用于监听客户连接请求,而另一个用于与连接的客户端通讯。当然,一个服务端在同一时间,可与多个客户端进行连接,且每个客户端都有一个套接字。
在这个简单的例子中,我们只关心请求连接的第一个客户端,一旦连接上了,便可关闭此监听连接请求的套接字(参见标号9)。
在标号10-12中,我们用最近连接的套接字,建立了一个NetworkStream,连同两个读写函数一起,便可以从套接字接收请求,并返回结果。
服务端在此无限循环,读入一对整数,计算它们的和,并把结果返回给客户端。当服务端探测到输入流中的文件结束标志时(由客户端关闭了套接字),会抛出EndOfStreamException异常,并关闭I/O流和套接字,服务结束。
标号18中的Socket::ShutDown调用将同时关闭套接字上的接收和发送功能,因为我们的服务端只需告之一个客户端它的关闭,所以此函数调用有点多余,但是,在服务端要过早地结束的某些情况下,这种做法还是有用的。
为何要捕捉IOException异常的原因在标号17中,在此是为了处理客户端在关闭套接字之前的过早结束。
客户端套接字
现在,让我们来看一下客户端程序。在连接到服务端之后,客户端将发送一对随机的整数,并且在发送下一对之前等待返回的结果。此处我们所看到的是服务端与客户端的同步通讯,客户端在接收到前一对值的结果之前,是不会发送另一对新值的。
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);
}
}