java網絡編程之socket網絡編程示例(服務器端/客戶端)

2019-11-26 15:44:17

字體：大中小

來源：轉載

供稿：網友

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編程中，首先客戶端需要向服務器端發送，然后被動的等待服務器端的響應。下面的示例中：我們向服務器端發送信息，等待服務器端發送的消息，并打印顯示出來?！?/P>

復制代碼代碼如下:

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