套接字readInt不總是工作

Question

我正在構建一個客戶端 - 服務器Java應用程序。問題是，當我用writeInt（）發送Integer時，有時會阻塞readInt（）。

客戶

PrintWriter socketOut = new PrintWriter(sock.getOutputStream()); 
DataOutputStream d = new DataOutputStream(sock.getOutputStream()); 
String s = "User"; 
socketOut.println(s); 
socketOut.flush(); 
d.writeInt(data[0]); 
d.flush(); 
d.writeInt(data[1]); 
d.flush(); 

服務器

while(true){ 
     System.out.println("Listening for clients..."); 
     clientSock = serverSock.accept(); 
     Scanner in = new Scanner(clientSock.getInputStream()); 

     String clientType = in.nextLine(); 

     switch(clientType){ 
      case "Resource": 
       new Thread(new ResourceService(clientSock)).start(); 
       break; 
      case "User": 
       new Thread(new UserService(clientSock)).start(); 
       break; 
     } 

    } 

用戶線程

@Override 
    public void run(){ 
     try{ 
     DataInputStream input = new DataInputStream(user.getInputStream()); 
     int i = 0; 
     int a = input.readInt(); // Sometimes it blocks here. 
     int b = input.readInt(); 
     System.out.println(a); 
     System.out.println(b); 
     ... 

我試圖根據發送到服務器的第一個字符串客戶端之間的區別。有時服務器讀取整型，有時會阻塞。 的輸出的例子是：

Listening for clients... 
Listening for clients... 
Listening for clients... 
Listening for clients... 
Listening for clients... 
1      // here the server didn't block 
100000 
Listening for clients... 

Answer 1

可能不是一個好主意，使用DataInputStream類/ DataOutputStream類與掃描儀和PrintWriter的混合在一起。建議使用Scanner和PrintWriter來進行用戶交互。

嘗試只使用DataOutputStream和DataInputStream。

客戶

DataOutputStream d = new DataOutputStream(sock.getOutputStream()); 
String s = "User"; 
d.writeUTF(s); 
d.writeInt(data[0]); 
d.flush(); 
d.writeInt(data[1]); 
d.flush(); 

服務器

DataInputStream input = new DataInputStream(clientSock.getInputStream()); 
String clientType = input.readUTF(); 

switch(clientType){ 
    case "Resource": 
     new Thread(new ResourceService(input)).start(); 
     break; 
    case "User": 
     new Thread(new UserService(input)).start(); 
     break; 

網友跟帖

int a = input.readInt(); 
int b = input.readInt(); 
System.out.println(a); 
System.out.println(b); 

注1：DataInputStream類/ DataOutputStream聯合使用自己的協議寫/讀UTF字符串，沒有必要使用線路終端。注意2：PrintWriter的方法不會拋出I/O異常，您必須檢查調用checkError（可能不是這裏的問題）。