C套接字服務器，Java套接字客戶端：阻塞！

Question

我正在將我的代碼粘貼到C和Java客戶端中的簡單套接字服務器上。

我使用寫入方法在Java中逐字發送。然而，在發送大塊字符（在這裏，'h'，'e'，'y'）後，Java客戶端被髮送阻塞，因爲C服務器不回覆它:(

我假設有一些問題，發送一個空字符（從Java寫），將在C面停止的recv

任何幫助，將不勝感激

C服務器：。

#include <stdio.h> /* standard in and output*/ 
#include <sys/socket.h> /* for socket() and socket functions*/ 
#include <arpa/inet.h> /* for sockaddr_in and inet_ntoa() */ 
#include <stdlib.h>  
#include <string.h>  
#include <unistd.h>  /* for close() */ 


int main(int argc, char *argv[]){ 
int sock, connected, bytes_received, true = 1; 
    char recv_data;  
char replyBuffer[32]; 

    struct sockaddr_in server_addr,client_addr;  
    int sin_size;  
    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) { 
     perror("Socket"); 
     exit(1); 
    } 

    if (setsockopt(sock,SOL_SOCKET,SO_REUSEADDR,&true,sizeof(int)) == -1) { 
     perror("Setsockopt"); 
     exit(1); 
    } 

    server_addr.sin_family = AF_INET;   
    server_addr.sin_port = htons(2400);  
    server_addr.sin_addr.s_addr = INADDR_ANY; 
    bzero(&(server_addr.sin_zero),8); 

    if (bind(sock, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) { 
     perror("Unable to bind"); 
      exit(1); 
    } 

    if (listen(sock, 5) == -1) { 
     perror("Listen"); 
     exit(1); 
    } 

printf("\nTCPServer Waiting for client on port 2400"); 

    while(1){ 
     sin_size = sizeof(client_addr); 
     connected = accept(sock, (struct sockaddr *)&client_addr,&sin_size); 
     printf("\n Got a connection from (%s , %d)",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port)); 


     while ((bytes_received = recv(connected,&recv_data,1,0)) > 0){ 
    printf("\nrecv= %c\n", recv_data); 
    } 
    int success = 1; 
    sprintf(replyBuffer, "%d", success); 
    printf("reply buffer = %s\n", replyBuffer); 
    if (send(connected, replyBuffer, strlen(replyBuffer), 0) == -1) 
    perror("send() failed"); 
    success = 0; 
    close(connected); 
} 
} 

Java客戶端：

import java.net.*; 
import java.io.*; 

public class Client1 
{ 
public static void main(String[] args) throws IOException { 
    if (args.length < 2) { 
    System.err.println("Usage: java Client1 <IP address> <Port number>"); 
    System.exit(0); 
    } 
    BufferedReader in = null; 
    OutputStream out = null; 
    Socket sock = null; 

    try { 
    sock = new Socket(args[0], Integer.parseInt(args[1])); 
    out = sock.getOutputStream(); 
    in = new BufferedReader(new InputStreamReader(sock.getInputStream())); 

    String line = "hey"; 
    String responseline = null; 
char[] strArray; 
strArray = line.toCharArray(); 

while (true) { 
for(int index = 0; index < strArray.length; index++){ 
out.write(strArray[index]); 
} 
out.flush(); 
System.out.println("data sent "); 
System.out.println("val returned"+in.readLine()); 
    } 
    } 
    catch (IOException ioe) { 
    System.err.println(ioe); 
    } 
    finally { 
    if (in != null) 
    in.close(); 

    if (out != null) 
    out.close(); 
    if (sock != null) 
    sock.close(); 
    } 
} 
} 

Answer 1

從Javadoc文檔BufferedReader.readLine（）

Read a line of text. A line is considered to be terminated by any one of a line feed ('\n'), a carriage return ('\r'), or a carriage return followed immediately by a linefeed. 

這就是爲什麼它塊（不LF，沒有CR，沒有CRLF）

[編輯]
你需要創建一個EOL指示C程序可以理解（就像在java客戶端中的readLine（）一樣）。讓該指標爲'\ n'（爲了一致性，如果沒有其他）
在Client.java中，將'\ n'附加到您發送的字符串。
在tst.c，測試 '\ n'，它在接收時，突破來自的recv（）循環
[/編輯]

Answer 2

你的問題的假設是正確的。調用recv將始終返回大於零的值。我建議使用特殊字符指定文本的結尾，並在讀取該字符時終止recv()循環。

Answer 3

在我看來，你的服務器代碼有錯誤。如果你在linux上編譯你的服務器代碼，會出現錯誤。 sin_size的類型應該是socklen_t。 或者你會看到一個錯誤信息 「從int *無效的轉換爲socklen_t」

Answer 4

客戶改變

out.write(line.getBytes()); 

服務器更改爲

char recv_data[32]; 
recv(connect,recv_data,32,0);