Java為TCP協定提供了兩個類,分別在客戶端程式設計和伺服器端程式設計中使用它們。在應用程式開始通訊之前,需要先建立一個連接,由客戶端程式發起;而伺服器端的程式需要一直監聽著主機的特定連接埠號,等待客戶端的連接。在客戶端我們只需要使用Socket實例,而服務端要同時處理ServerSocket實例和Socket實例;二者並且都使用OutputStream和InpuStream來傳送和接收資料。
學習一種知識最好的方式就是使用它,透過前面的筆記,我們已經知道如何獲取主機的地址信息,現在我們通過一個簡單的程序來初步學習傳輸層使用了TCP協議的Socket編程。
TCP伺服器端
在Socket程式設計中,伺服器端遠比客戶端複雜得多。伺服器端的工作就是建立一個通訊終端,被動的等待客戶端的連線。下面這個伺服器端程式的範例的作用是:監聽從控制台輸入取得的連接埠號,並且將客戶端傳送過來的訊息,再發送回去。
複製代碼代碼如下:
importjava.net.*;
importjava.text.MessageFormat;
importjava.io.*;
publicclassTCPEchoServer{
privatestaticfinalintBUFSIZE=32;
publicstaticvoidmain(String[]args)throwsIOException{
//TODOAuto-generatedmethodstub
//從控制台取得需要監聽的連接埠號
if(args.length!=1)
thrownewIllegalArgumentException("Parameter(s):<Port>");
//取得連接埠號
intservPort=Integer.parseInt(args[0]);
//實例化一個ServerSocket物件實例
ServerSocketservSocket=newServerSocket(servPort);
System.out.println(MessageFormat.format("開始啟動監聽,連接埠號碼:{0}",args[0]));
//初始接收資料的總位元組數
intrecvMsgSize;
//接收資料的緩衝區
byte[]receiveBuf=newbyte[BUFSIZE];
//循環迭代,監聽連接埠號碼,處理新的連線請求
while(true){
//阻塞等待,每接收到一個請求就會建立一個新的連線實例
SocketclntSocket=servSocket.accept();
//取得連線的客戶端的SocketAddress
SocketAddressclientAddress=clntSocket.getRemoteSocketAddress();
//列印輸出連接客戶端位址訊息
System.out.println("Handlingclientat"+clientAddress);
//從客戶端接收資料的對象
InputStreamin=clntSocket.getInputStream();
//向客戶端傳送資料的對象
OutputStreamout=clntSocket.getOutputStream();
//讀取客戶端傳送的資料後,再傳送到客戶端
while((recvMsgSize=in.read(receiveBuf))!=-1){
out.write(receiveBuf,0,recvMsgSize);
}
//客戶端關閉連線時,關閉連接
System.out.println("客戶端關閉連線");
clntSocket.close();
}
}
}
TCP客戶端
在Socket程式設計中,首先客戶端需要向伺服器端發送,然後被動的等待伺服器端的回應。在下面的範例中:我們向伺服器端發送訊息,等待伺服器端發送的訊息,並列印顯示出來。
複製代碼代碼如下:
importjava.io.*;
importjava.net.Socket;
importjava.net.SocketException;
publicclassTCPEchoClient{
publicstaticvoidmain(String[]args)throwsIOException{
//TODOAuto-generatedmethodstub
//判斷從控制台接受的參數是否正確
if((args.length<2)||(args.length>3))
thrownewIllegalArgumentException(
"Parameter(s):<Server><Word>[<Port>]]");
//取得伺服器位址
Stringserver=args[0];
//取得需要傳送的訊息
byte[]data=args[1].getBytes();
//如果有三個從參數那麼就取得傳送訊息的連接埠號,預設連接埠號碼為8099
intservPort=(args.length==3)?Integer.parseInt(args[2]):8099;
//根據伺服器位址和連接埠號碼實例化一個Socket實例
Socketsocket=newSocket(server,servPort);
System.out.println("Connectedtoserver...sendingechostring");
//傳回此套接字的輸入流,即從伺服器接受的資料對象
InputStreamin=socket.getInputStream();
//傳回此套接字的輸出流,即向伺服器傳送的資料對象
OutputStreamout=socket.getOutputStream();
//向伺服器發送從控制台接收的數據
out.write(data);
//接收資料的計數器,將寫入資料的初始偏移量
inttotalBytesRcvd=0;
//初始化接收資料的總位元組數
intbytesRcvd;
while(totalBytesRcvd<data.length){
//伺服器關閉連接,則傳回-1,read方法傳回接收資料的總位元組數
if((bytesRcvd=in.read(data,totalBytesRcvd,data.length
-totalBytesRcvd))==-1)
thrownewSocketException("與伺服器的連線已關閉");
totalBytesRcvd+=bytesRcvd;
}
//列印伺服器發送來的數據
System.out.println("Received:"+newString(data));
//關閉連線
socket.close();
}
}
首先運行伺服器端,監聽8099埠:
接著運行客戶端程序,並且向伺服器端發送訊息:
再次查看我們的伺服器端控制台,我們可以看到前面客戶端連接的位址資訊: