Java為T(mén)CP協(xié)議提供了兩個(gè)類(lèi)，分別在客戶端編程和服務(wù)器端編程中使用它們。在應(yīng)用程序開(kāi)始通信之前，需要先創(chuàng)建一個(gè)連接，由客戶端程序發(fā)起；而服務(wù)器端的程序需要一直監(jiān)聽(tīng)著主機(jī)的特定端口號(hào)，等待客戶端的連接。在客戶端中我們只需要使用Socket實(shí)例，而服務(wù)端要同時(shí)處理ServerSocket實(shí)例和Socket實(shí)例;二者并且都使用OutputStream和InpuStream來(lái)發(fā)送和接收數(shù)據(jù)。
學(xué)習(xí)一種知識(shí)最好的方式就是使用它，通過(guò)前面的筆記，我們已經(jīng)知道如何獲取主機(jī)的地址信息，現(xiàn)在我們通過(guò)一個(gè)簡(jiǎn)單的程序來(lái)初步學(xué)習(xí)傳輸層使用了TCP協(xié)議的Socket編程。
TCP服務(wù)器端
在Socket編程中，服務(wù)器端遠(yuǎn)比客戶端要復(fù)雜得多。服務(wù)器端的工作就是建立一個(gè)通信終端，被動(dòng)的等待客戶端的連接。下面這個(gè)服務(wù)器端程序的示例的作用是：監(jiān)聽(tīng)從控制臺(tái)輸入獲取的端口號(hào)，并且將客戶端發(fā)送過(guò)來(lái)的消息，再發(fā)送回去。
importjava.net.*;
importjava.text.MessageFormat;
importjava.io.*;
publicclassTCPEchoServer{
privatestaticfinalintBUFSIZE=32;
publicstaticvoidmain(String[]args)throwsIOException{
//TODOAuto-generatedmethodstub
//從控制臺(tái)獲取需要監(jiān)聽(tīng)的端口號(hào)
if(args.length!=1)
thrownewIllegalArgumentException("Parameter(s):<Port>");
//獲取端口號(hào)
intservPort=Integer.parseInt(args[0]);
//實(shí)例化一個(gè)ServerSocket對(duì)象實(shí)例
ServerSocketservSocket=newServerSocket(servPort);
System.out.println(MessageFormat.format("開(kāi)始啟動(dòng)監(jiān)聽(tīng)，端口號(hào):{0}",args[0]));
//初始接收數(shù)據(jù)的總字節(jié)數(shù)
intrecvMsgSize;
//接收數(shù)據(jù)的緩沖區(qū)
byte[]receiveBuf=newbyte[BUFSIZE];
//循環(huán)迭代，監(jiān)聽(tīng)端口號(hào),處理新的連接請(qǐng)求
while(true){
//阻塞等待，每接收到一個(gè)請(qǐng)求就創(chuàng)建一個(gè)新的連接實(shí)例
SocketclntSocket=servSocket.accept();
//獲取連接的客戶端的SocketAddress
SocketAddressclientAddress=clntSocket.getRemoteSocketAddress();
//打印輸出連接客戶端地址信息
System.out.println("Handlingclientat"+clientAddress);
//從客戶端接收數(shù)據(jù)的對(duì)象
InputStreamin=clntSocket.getInputStream();
//向客戶端發(fā)送數(shù)據(jù)的對(duì)象
OutputStreamout=clntSocket.getOutputStream();
//讀取客戶端發(fā)送的數(shù)據(jù)后，再發(fā)送到客戶端
while((recvMsgSize=in.read(receiveBuf))!=-1){
out.write(receiveBuf,0,recvMsgSize);
}
//客戶端關(guān)閉連接時(shí)，關(guān)閉連接
System.out.println("客戶端關(guān)閉連接");
clntSocket.close();
}
}
}
TCP客戶端
在Socket編程中，首先客戶端需要向服務(wù)器端發(fā)送，然后被動(dòng)的等待服務(wù)器端的響應(yīng)。下面的示例中：我們向服務(wù)器端發(fā)送信息，等待服務(wù)器端發(fā)送的消息，并打印顯示出來(lái)。
importjava.io.*;
importjava.net.Socket;
importjava.net.SocketException;
publicclassTCPEchoClient{
publicstaticvoidmain(String[]args)throwsIOException{
//TODOAuto-generatedmethodstub
//判斷從控制臺(tái)接受的參數(shù)是否正確
if((args.length<2)||(args.length>3))
thrownewIllegalArgumentException(
"Parameter(s):<Server><Word>[<Port>]]");
//獲取服務(wù)器地址
Stringserver=args[0];
//獲取需要發(fā)送的信息
byte[]data=args[1].getBytes();
//如果有三個(gè)從參數(shù)那么就獲取發(fā)送信息的端口號(hào)，默認(rèn)端口號(hào)為8099
intservPort=(args.length==3)?Integer.parseInt(args[2]):8099;
//根據(jù)服務(wù)器地址和端口號(hào)實(shí)例化一個(gè)Socket實(shí)例
Socketsocket=newSocket(server,servPort);
System.out.println("Connectedtoserver...sendingechostring");
//返回此套接字的輸入流，即從服務(wù)器接受的數(shù)據(jù)對(duì)象
InputStreamin=socket.getInputStream();
//返回此套接字的輸出流，即向服務(wù)器發(fā)送的數(shù)據(jù)對(duì)象
OutputStreamout=socket.getOutputStream();
//向服務(wù)器發(fā)送從控制臺(tái)接收的數(shù)據(jù)
out.write(data);
//接收數(shù)據(jù)的計(jì)數(shù)器，將寫(xiě)入數(shù)據(jù)的初始偏移量
inttotalBytesRcvd=0;
//初始化接收數(shù)據(jù)的總字節(jié)數(shù)
intbytesRcvd;
while(totalBytesRcvd<data.length){
//服務(wù)器關(guān)閉連接，則返回-1,read方法返回接收數(shù)據(jù)的總字節(jié)數(shù)
if((bytesRcvd=in.read(data,totalBytesRcvd,data.length
-totalBytesRcvd))==-1)
thrownewSocketException("與服務(wù)器的連接已關(guān)閉");
totalBytesRcvd+=bytesRcvd;
}
//打印服務(wù)器發(fā)送來(lái)的數(shù)據(jù)
System.out.println("Received:"+newString(data));
//關(guān)閉連接
socket.close();
}
}
首先運(yùn)行服務(wù)器端,監(jiān)聽(tīng)8099端口:
接著運(yùn)行客戶端程序，并且向服務(wù)器端發(fā)送消息:
再次查看我們的服務(wù)器端控制臺(tái)，我們可以看到前面客戶端連接的地址信息:
