在Java中使用Socket通信會遇到哪些問題

本篇文章給大家分享的是有關(guān)在Java中使用Socket通信會遇到哪些問題，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

Socket通信模型如圖所示：

不管Socket通信的功能有多復(fù)雜，任何socket通信過程的基本結(jié)構(gòu)都是一樣的。

其基本步驟為：

      ①分別在客戶端和服務(wù)器端創(chuàng)建Socket和ServerSocket實(shí)例；服務(wù)器端通過.accept()方法等待請求并阻塞。請求收到后，建立連接Socket對象。

      ②通過getInputStream和getOutputStream方法分別在客戶端和服務(wù)器端打開輸入輸出流

      ③利用IO流進(jìn)行讀寫操作

      ④關(guān)閉所有的流資源和套接字資源。

其中，編程工作主要集中在第三步，其他的部分代碼基本相同。所有步驟都可能拋出IO異常！

我在編寫一個(gè)簡單的socket程序時(shí)，使用的Socket通信出現(xiàn)了一個(gè)問題：我在客戶端寫入的數(shù)據(jù)，在服務(wù)器端無法輸出。當(dāng)我從客戶端斷開連接時(shí)，之前寫入的所有數(shù)據(jù)立刻在服務(wù)器端輸出出來了。經(jīng)過反復(fù)的驗(yàn)證和求解，以下是我的結(jié)論和解決方法。希望有同樣問題的小伙伴看完可以解決問題。

通過一端的Socket建立了PrintWriter類來寫入數(shù)據(jù)，通過另一端的Socket建立了BufferedReader類來讀取數(shù)據(jù)并輸出。

如果數(shù)據(jù)寫入后沒有被顯示，可能的原因有兩種：

一、寫入的數(shù)據(jù)存儲在緩沖區(qū)中，沒有被寫入IO流中：

如果不主動的干涉，寫入的數(shù)據(jù)會一直堆在緩沖區(qū)中，直到緩沖區(qū)滿了引發(fā)JVM自動刷新緩沖區(qū)。顯然這不符合我們的需求。對于這種情況，PrintWriter類提供了flush()方法來強(qiáng)制刷新緩沖區(qū)，將緩沖區(qū)數(shù)據(jù)寫入IO流中。另外，PrintWriter類的構(gòu)造器有一個(gè)參數(shù)”boolean autoflush“，這個(gè)參數(shù)默認(rèn)為false，如果設(shè)置為true，則會開啟自動刷新緩沖區(qū)功能。但是請注意，這里的自動刷新是有觸發(fā)條件的，那就是：PrintWriter類寫入數(shù)據(jù)的方法必須是println、printf或者format方法時(shí)，才會觸發(fā)自動刷新。如果是調(diào)用write()這類方法寫入數(shù)據(jù)，是不會觸發(fā)自動刷新的！總結(jié)起來，就是三點(diǎn)：autoflush參數(shù)設(shè)置，write和println方法的選擇，flush方法的使用。對這三個(gè)進(jìn)行組合，就能保證在Socket通信的某一端寫入數(shù)據(jù)時(shí)，數(shù)據(jù)一定能成功地寫入到IO流中！

二、讀取數(shù)據(jù)使用了readLine()方法，該方法沒有正常的結(jié)束：

請注意，BufferedReader類的readLine()方法是一個(gè)阻塞函數(shù)！也就是說，這個(gè)方法本身是讀取一行數(shù)據(jù)，但是它自己識別不了什么叫做“一行”!當(dāng)調(diào)用該方法讀取完一段數(shù)據(jù)后，它會阻塞，而不會return它的讀取數(shù)據(jù)。這就是為什么有的時(shí)候明明已經(jīng)刷新了緩沖區(qū)正確的寫入數(shù)據(jù)了，還是通過輸入流讀取數(shù)據(jù)并顯示出來的原因。

對于readLine()方法，它解除阻塞、正確結(jié)束并返回讀取的值，只有以下幾種情況：

      ①讀取的數(shù)據(jù)里含有回車符"\r"或者換行符"\n"或者回車換行符"\r\n"；

      ②讀取的數(shù)據(jù)是在另一端通過println方法寫入的，因?yàn)閜rintln方法自帶換行符；

      ③BufferedReader類的緩沖區(qū)滿了，那么JVM會自動刷新緩沖區(qū)從而釋放“積攢”的數(shù)據(jù)（但是鑒于默認(rèn)緩沖區(qū)大小為8192個(gè)字符，對于小數(shù)據(jù)量的通信，顯然觸發(fā)不了）；

      ④對于讀取的數(shù)據(jù)，寫入這些數(shù)據(jù)的流發(fā)生異?；蛘咧苯雨P(guān)閉，那么readLine()就會把它吃的數(shù)據(jù)全部吐出來。這就剛好解釋了，為什么在我的程序中，斷開客戶端Socket連接，服務(wù)器端立刻輸出所有客戶端消息的原因。

綜上，在Socket通信過程中，保證某一端輸出流的緩沖被刷新，保證另一端的readLine方法能正常停止，即可解決寫入的數(shù)據(jù)在另一端無法輸出的問題。

以下是我修改后能成功運(yùn)行的代碼，分別是服務(wù)器端Socket和客戶端Socket。

over！

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
public class ShakingServer{
 public static void main(String[] args) throws IOException {

 //創(chuàng)建服務(wù)器套接字實(shí)例，設(shè)置監(jiān)聽端口為2000
 ServerSocket server=new ServerSocket(2000);
 //開始監(jiān)聽客戶端的請求，并阻塞
 Socket socket=server.accept();
 //請求收到后，自動建立連接。通過IO流進(jìn)行數(shù)據(jù)傳輸
 System.out.println("連接建立成功");

 OutputStream os=socket.getOutputStream();
 PrintWriter pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(os)),true);
 pw.write("歡迎訪問搖頭耶穌的世界！");
 pw.flush();
  //因?yàn)槲谊P(guān)閉了輸出流，所以另一端的readLine方法才正常結(jié)束了
 socket.shutdownOutput();

 InputStream is=socket.getInputStream();
 InputStreamReader isr=new InputStreamReader(is);
 BufferedReader br=new BufferedReader(isr);
 while(true) {
  String str=br.readLine();
  if(str.equals("quit")) {
  break;
  }
  System.out.println("Client said: "+str);
 }
 socket.shutdownInput();
 //socket.shutdownOutput();
 socket.close();
 server.close();
 }
}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class ShakingClient{
 public static void main(String[] args) throws IOException{

 //創(chuàng)建客戶端的套接字，設(shè)置連接的服務(wù)器的IP地址和端口號
 Socket socket=new Socket("169.254.132.203",2000);
 //輸入流讀取服務(wù)器發(fā)送的信息
 BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));
  //開啟自動刷新緩沖區(qū)
 PrintWriter pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);  
  //從鍵盤讀取數(shù)據(jù)
 BufferedReader ii=new BufferedReader(new InputStreamReader(System.in));
 System.out.println(br.readLine());
  //因?yàn)殚_啟了自動刷新，且調(diào)用的是println方法，所以可以不調(diào)用flush方法
 pw.println("請求進(jìn)入搖頭耶穌的世界");
 //pw.flush();
 while(true) {
  String str=ii.readLine();
  //使用了回車符來保證另一端的readLine方法正常結(jié)束
  pw.write(str+"\r");
  pw.flush();
  //如果輸入quit則退出聊天室
  if(str.equals("quit")) {
  break;
  }
 }
 socket.shutdownInput();
 socket.shutdownOutput();
 socket.close();
 }
}

以上就是在Java中使用Socket通信會遇到哪些問題，小編相信有部分知識點(diǎn)可能是我們?nèi)粘９ぷ鲿姷交蛴玫降摹ＯＭ隳芡ㄟ^這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注億速云行業(yè)資訊頻道。