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