Java客户端和C++服务器有时会接收全部信息

Question

我正在使用TCP编写多线程C++服务器和Java客户端。它适用于短字符串，但是当我想发送大字符串（例如 40 个字符）时，服务器只收到其中的几个，客户端正在等待响应。

多线程部分工作正常。

这里有代码。（对不起，变量的评论和名称。我是西班牙人。

服务器C++

void* SocketHandler(void*);

int main(int argv, char** argc){

//Puerto en el que recibe
int host_port= 1101;
//Estructura usada para especificar una direccion local o remota a la que conectar un socket
struct sockaddr_in my_addr;
int hsock;
int * p_int ;
int errno;
socklen_t addr_size = 0;
int* csock;
sockaddr_in sadr;
pthread_t thread_id=0;
//Se inicializa socket
hsock = socket(AF_INET, SOCK_STREAM, 0);
//Para comprobar que el socket se ha inicializado correctamente
if(hsock == -1){
    printf("Error inicializando socket %dn", errno);
    goto FINISH;
}
//Se reserva memoria
p_int = (int*)malloc(sizeof(int));
*p_int = 1;
//Se comprueba que al introducir las opciones del socket se introduzcan correctamente   
if( (setsockopt(hsock, SOL_SOCKET, SO_REUSEADDR, (char*)p_int, sizeof(int)) == -1 )||
    (setsockopt(hsock, SOL_SOCKET, SO_KEEPALIVE, (char*)p_int, sizeof(int)) == -1 ) ){
    printf("Error introduciendo opciones del socket %dn", errno);
    //Se libera la memoria reservada
    free(p_int);
    goto FINISH;
}
//Se libera la memoria reservada
free(p_int);
//Se añade la familia de direcciones a la que pertenece IPV4
my_addr.sin_family = AF_INET ;
//Se añade el puerto que es
my_addr.sin_port = htons(host_port);
//Relleno de sin zero con 8 ceros
bzero((char *) &(my_addr.sin_zero), sizeof(my_addr.sin_zero));
//memset(&(my_addr.sin_zero), 0, 8);
//Se añade la dirección IP
my_addr.sin_addr.s_addr = INADDR_ANY ;
//Enlaza el socket con la dirección IP, puerto
if( bind( hsock, (struct sockaddr*)&my_addr, sizeof(my_addr)) == -1 ){
    fprintf(stderr,"Error enlazando el socket, asegurate de que no hay nada más escuchando en este puerto %dn",errno);
    goto FINISH;
}
//Se pone a escuchar
if(listen( hsock, 5) == -1 ){
    fprintf(stderr, "Error listening %dn",errno);
    goto FINISH;
}

//Ahora se pasa a hacer las cosas en el servidor

addr_size = sizeof(sockaddr_in);
while(true){
    printf("Esperando a una conexiónn");
    //Se reserva memoria 
    csock = (int*)malloc(sizeof(long double));
    //Hay que encontrar porque no manda mas de x caracteres

    //LLamada que se bloquea esperando una conexion de un cliente
    if((*csock = accept( hsock, (struct sockaddr*)&sadr, &addr_size))!= -1){
        printf("---------------------nRecibida conexión de %sn",inet_ntoa(sadr.sin_addr));
        //Se crea un nuevo hilo por cliente, se llama a socket handler
        pthread_create(&thread_id,0,&SocketHandler, (void*)csock );
        //El almacenamiento del hilo puede ser reclamado cuando el hilo haya terminado
        pthread_detach(thread_id);
    }
    else{
        fprintf(stderr, "Error aceptando cliente %dn", errno);
    }
}
FINISH:
;
}
void* SocketHandler(void* lp){
int *csock = (int*)lp;
//Buffer en donde se guarda lo recibido
char buffer[8192];
//Longitud del buffer
//int buffer_len = 8192;
//Contador para saber el número de caracteres del buffer
int bytecount;
//Relleno del buffer con ceros
bzero((char *) &buffer, sizeof(buffer));
//memset(buffer, 0, sizeof(buffer));
//Se recibe la informacion del socket y se comprueba que sea valida
//recv(buffer,offset,size,socketflags) 
//buffer es un array de bytes que es la localización en donde se van a guardar los datos
//offset es la posicion en el buffer de datos desde la cual se quiere empezar a guardar
//size es el número de bytes a recibir
//socketflags es la combinacion de flas que se quieren utilizar 0 significa ninguno 
/*if((bytecount = recv(*csock, buffer, sizeof(buffer), 0))== -1){
    fprintf(stderr, "Error recibiendo los datos %dn", errno);
    goto FINISH;
}*/

if((bytecount = read(*csock,buffer,sizeof(buffer)))== -1){
        fprintf(stderr, "Error recibiendo los datos %dn", errno);
    goto FINISH;
}
printf("Bytes recibidos %dnstring recibido %sn", bytecount, buffer);
//Copia el string al buffer
//strcat(buffer, " SERVER ECHO");


//Se tienen que poner parentesis por el uso de go to de arriba
{       

    string comando = buffer;

    if(comando.compare("zzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzz") == 0){
        strcpy(buffer,"yyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyy");

    }
}

//Envía el mensaje de vuelta con el string añadido
//send(buffer,offset,size,socketflags) 
//buffer es un array de bytes que contiene los datos a ser enviados
//offset es la posicion en el buffer de datos desde la cual se quiere empezar a enviar datos
//size es el número de bytes a enviar
//socketflags es la combinacion de flas que se quieren utilizar 0 significa ninguno
{
    //Se hace esto ya que en el cliente parece que si no le llegua salto de linea no continua, y se queda esperando
string bufferbarran =  buffer;
bufferbarran +="n";    
strcpy(buffer,bufferbarran.c_str());
/*
if((bytecount = send(*csock, buffer, strlen(buffer), 0))== -1){
    fprintf(stderr, "Error enviando los datos %dn", errno);
    goto FINISH;
}
*/
if((bytecount = write(*csock,buffer,strlen(buffer)))== -1){
        fprintf(stderr, "Error enviando los datos %dn", errno);
    goto FINISH;
}
}
printf("Bytes enviados %dn", bytecount);

FINISH:
//Se libera la memoria reservada
free(csock);
return 0;
}

Answer 1

与其直接在套接字服务器（和客户端）中调用 read（），不如使用 select（） 来了解套接字何时准备好读取或写入。只调用读/写而不调用 select（） 被认为是不好的做法。select（） 将阻塞，直到套接字准备好读取/写入或超时（如果您配置超时）。

这是他们使用 select（） 的一个很好的例子：c++ 套接字选择和接收问题

Answer 2

TCP是一种面向流的传输 - 对write和read的调用之间的对应关系不是1：1（就像UDP这样的面向数据的传输一样）。

您需要循环阅读，直到收到一条（或多条）整条消息。 由您来编码某种方式来确定消息的结束位置。