Dotaz: Klient se pripoji k serveru a prijima a odesila data.

[VytliNoha]

Zdravicko, progrmauji jednoduchecho klienta ktery se pripoji na server a posila nebo prijima data. Pro odeslani pouzivam send() a pro prijem recv() to cele v nekonecne smicce. Bez prijimani zprav od serveru klient data posila ale kdyz tam pridam recv() tak uz se to kousne po prijeti 1. zpravy od serveru je to tim ze porad ceka u fce recv() co prijde.. Mam to resit pomoci selectu nebo vlaken. Prosim poradte dekuji moc. Coucasny kod:

#define BUFSIZE 100
#define PORT 5555


int main(int argc, char *argv[])
{
    hostent *host;              // Vzdálený počítač;
    sockaddr_in serverSock;     // Vzdálený "konec potrubí"
    int mySocket;               // Soket
    char buf_in[BUFSIZE];          // Přijímací buffer
	char buf_out[BUFSIZE];		// Odesilaci buffer
	fd_set inputs, testfds;
    struct timeval timeout;
	
	
    // Zjistíme info o vzdáleném počítači
    if ((host = gethostbyname(argv[1])) == NULL)
    {
        printf("Špatná adresa\n");
        return -1;
    }
    // Vytvoříme soket
    if ((mySocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
    {
        printf("Nelze vytvořit soket\n");
        return -1;
    }
    // Zaplníme strukturu sockaddr_in
    // 1) Rodina protokolů
    serverSock.sin_family = AF_INET;
    // 2) Číslo portu, ke kterému se připojíme
    serverSock.sin_port = htons(PORT);
    // 3) Nastavení IP adresy, ke které se připojíme
    memcpy(&(serverSock.sin_addr), host->h_addr, host->h_length);
    // Připojení soketu
    if (connect(mySocket, (sockaddr *)&serverSock, sizeof(serverSock)) == -1)
    {
		printf("Nelze navázat spojení\n");
        return -1;
    }
    // Odeslání dat
	while(1){
		fgets(buf_out, BUFSIZE, stdin);
		buf_out[strlen(buf_out)-1] = '\0';//odstraneni kone radky
		if(strcmp(buf_out,"LOGOUT")!=0){
			if (send(mySocket, buf_out, strlen(buf_out), 0) == -1)
    		{
        		printf("Problém s odesláním dat\n");
        		return -1;
    		}
			// Příjem dat
			
    		//if((size = recv(mySocket, buf_in, BUFSIZE, 0)) != -1) 
    		//{        
        	//	printf("Přijato: [%s]\n");
    		//}
		}
		else{
			// odhlasime spojeni
			close(mySocket);
			exit(0);
		}
	}
		printf("Odeslano\n");
    return 0;
}

Odpovědi

[Luboš Doležel (Doli)]

Asi pomocí selectu - kdyby tam byla vlákna, tak by např. zatímco píšeš text na jedné straně ti mohl někdo poslat text z druhé strany a dělalo by to pořádný bordel na obrazovce.

[VytliNoha]

Muzete mi rict co je na tom spatne, data to odesila ale neprijima od serveru. Dekuji moc

#define BUFSIZE 100
#define PORT 5555


int main(int argc, char *argv[])
{
    hostent *host;              // Vzdálený počítač;
    sockaddr_in serverSock;     // Vzdálený "konec potrubí"
    int mySocket;               // Soket
    char buf_in[BUFSIZE];          // Přijímací buffer
	char buf_out[BUFSIZE];		// Odesilaci buffer
	fd_set read, write;
	
	FD_ZERO(&read);
	FD_ZERO(&write);

    // Zjistíme info o vzdáleném počítači
    if ((host = gethostbyname(argv[1])) == NULL)
    {
        printf("Špatná adresa\n");
        return -1;
    }
    // Vytvoříme soket
    if ((mySocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
    {
        printf("Nelze vytvořit soket\n");
        return -1;
    }
	else{
		// Zaplnění množiny sokety
		FD_SET(mySocket, &read);
		FD_SET(STDIN_FILENO, &read);
	}
    // Zaplníme strukturu sockaddr_in
    // 1) Rodina protokolů
    serverSock.sin_family = AF_INET;
    // 2) Číslo portu, ke kterému se připojíme
    serverSock.sin_port = htons(PORT);
    // 3) Nastavení IP adresy, ke které se připojíme
    memcpy(&(serverSock.sin_addr), host->h_addr, host->h_length);
    // Připojení soketu
    if (connect(mySocket, (sockaddr *)&serverSock, sizeof(serverSock)) == -1)
    {
		printf("Nelze navázat spojení\n");
        return -1;
    }
	// Zavolám select (V Linuxu musím mít nastavenou proměnnou max.)
	int ret = select(2, &read, NULL, NULL, NULL);
	
	while(1){
	    if (ret == -1){
			perror("select()");
		}
    	else if(ret){
			// odeslam data
			if(FD_ISSET(STDIN_FILENO, &read)){
				fgets(buf_out, BUFSIZE, stdin);
				buf_out[strlen(buf_out)-1] = '\0';//odstraneni kone radky
				if(strcmp(buf_out,"LOGOUT")!=0){
					if (send(mySocket, buf_out, strlen(buf_out), 0) == -1){
		 				return -1;
					}
				}
				else{
					// odhlasime spojeni
					close(mySocket);
					exit(0);
				}
			}
			//Příjem dat
			else if(FD_ISSET(mySocket, &read)){
				if(recv(mySocket, buf_in, BUFSIZE, 0) != -1) {
					printf("Přijato: [%s]\n");
				}
			}
		}
	}
		printf("Odeslano\n");
    return 0;
}

[Michal Marek (twofish)]

// Zavolám select (V Linuxu musím mít nastavenou proměnnou max.)

Tak si ji nastav... man select, číslo nejvyššího fd plus jedna.

[VytliNoha]

jako treba na: int ret = select(3, &read, NULL, NULL, NULL); nebo int ret = select( MAX( STDIN_FILENO, mySocket ) + 1, &read, NULL, NULL, NULL);

druhou variantu mi nechce kompilator zkompilovat"

[Michal Marek (twofish)]

Asi nemá makro MAX, nebo ti vypisuje nějakou jinou chybu

select(STDIN_FILENO>mySocket ? STDIN_FILENO+1 : MySocket+1, ...

jinak stdin je nula, takže to bude MySocket+1

[Josef Kufner]

Nebylo by lepší použít makro FD_SETSIZE ?

... select(FD_SETSIZE, ...

[Voty]

Mozna spatne koukam, ale rekl bych, ze ten select() by mel byt vevnitr toho nekonecnyho cyklu. Jinak je tam skoro na houby.

[Michal Marek (twofish)]

Nj, to jsem si nevšim

[VytliNoha]

Tak podle me to mam uplne podle vasich rad a stale to stejne neprijima data od serveru. Kdyz se na dany server pripojim tak data telnet dostava i prijima. Ale kdyz se pripojim pomoci tohoto klienta tak data pouze odesila .-( Nechcete to nekdo otestovat na vase Linuxcackovi

soucasny kod:

int main(int argc, char *argv[])
{
    hostent *host;              // Vzdálený počítač;
    sockaddr_in serverSock;     // Vzdálený "konec potrubí"
    int mySocket;               // Soket
    char buf_in[BUFSIZE];          // Přijímací buffer
	char buf_out[BUFSIZE];		// Odesilaci buffer
	fd_set read, write;
	
	FD_ZERO(&read);
	FD_ZERO(&write);

    // Zjistíme info o vzdáleném počítači
    if ((host = gethostbyname(argv[1])) == NULL)
    {
        printf("Špatná adresa\n");
        return -1;
    }
    // Vytvoříme soket
    if ((mySocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
    {
        printf("Nelze vytvořit soket\n");
        return -1;
    }
	else{
		// Zaplnění množiny sokety
		FD_SET(mySocket, &read);
		FD_SET(STDIN_FILENO, &read);
	}
    // Zaplníme strukturu sockaddr_in
    // 1) Rodina protokolů
    serverSock.sin_family = AF_INET;
    // 2) Číslo portu, ke kterému se připojíme
    serverSock.sin_port = htons(PORT);
    // 3) Nastavení IP adresy, ke které se připojíme
    memcpy(&(serverSock.sin_addr), host->h_addr, host->h_length);
    // Připojení soketu
    if (connect(mySocket, (sockaddr *)&serverSock, sizeof(serverSock)) == -1)
    {
		printf("Nelze navázat spojení\n");
        return -1;
    }
	while(1){
		// Zavolám select (V Linuxu musím mít nastavenou proměnnou max.)
		int ret = select(STDIN_FILENO > mySocket ? STDIN_FILENO+1 : mySocket+1, &read, NULL, NULL, NULL);
		
	    if (ret == -1){
			perror("select()");
		}
    	else if(ret){
			// odeslam data
			if(FD_ISSET(STDIN_FILENO, &read)){
				fgets(buf_out, BUFSIZE, stdin);
				buf_out[strlen(buf_out)-1] = '\0';//odstraneni kone radky
				if(strcmp(buf_out,"LOGOUT")!=0){
					if (send(mySocket, buf_out, strlen(buf_out), 0) == -1){
		 				return -1;
					}
				}
				else{
					// odhlasime spojeni
					close(mySocket);
					exit(0);
				}
			}
			//Příjem dat
			else if(FD_ISSET(mySocket, &read)){
				if(recv(mySocket, buf_in, BUFSIZE, 0) != -1) {
					printf("Přijato: [%s]\n", buf_in);
				}
			}
		}
	}
		printf("Odeslano\n");
    return 0;
}

[VytliNoha]

Tak podle me to mam uplne podle vasich rad a stale to stejne neprijima data od serveru. Kdyz se na dany server pripojim tak data telnet dostava i prijima. Ale kdyz se pripojim pomoci tohoto klienta tak data pouze odesila .-( Nechcete to nekdo otestovat na vase Linuxcackovi

soucasny kod:

int main(int argc, char *argv[])
{
    hostent *host;              // Vzdálený počítač;
    sockaddr_in serverSock;     // Vzdálený "konec potrubí"
    int mySocket;               // Soket
    char buf_in[BUFSIZE];          // Přijímací buffer
	char buf_out[BUFSIZE];		// Odesilaci buffer
	fd_set read, write;
	
	FD_ZERO(&read);
	FD_ZERO(&write);

    // Zjistíme info o vzdáleném počítači
    if ((host = gethostbyname(argv[1])) == NULL)
    {
        printf("Špatná adresa\n");
        return -1;
    }
    // Vytvoříme soket
    if ((mySocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
    {
        printf("Nelze vytvořit soket\n");
        return -1;
    }
	else{
		// Zaplnění množiny sokety
		FD_SET(mySocket, &read);
		FD_SET(STDIN_FILENO, &read);
	}
    // Zaplníme strukturu sockaddr_in
    // 1) Rodina protokolů
    serverSock.sin_family = AF_INET;
    // 2) Číslo portu, ke kterému se připojíme
    serverSock.sin_port = htons(PORT);
    // 3) Nastavení IP adresy, ke které se připojíme
    memcpy(&(serverSock.sin_addr), host->h_addr, host->h_length);
    // Připojení soketu
    if (connect(mySocket, (sockaddr *)&serverSock, sizeof(serverSock)) == -1)
    {
		printf("Nelze navázat spojení\n");
        return -1;
    }
	while(1){
		// Zavolám select (V Linuxu musím mít nastavenou proměnnou max.)
		int ret = select(STDIN_FILENO > mySocket ? STDIN_FILENO+1 : mySocket+1, &read, NULL, NULL, NULL);
		
	    if (ret == -1){
			perror("select()");
		}
    	else if(ret){
			// odeslam data
			if(FD_ISSET(STDIN_FILENO, &read)){
				fgets(buf_out, BUFSIZE, stdin);
				buf_out[strlen(buf_out)-1] = '\0';//odstraneni kone radky
				if(strcmp(buf_out,"LOGOUT")!=0){
					if (send(mySocket, buf_out, strlen(buf_out), 0) == -1){
		 				return -1;
					}
				}
				else{
					// odhlasime spojeni
					close(mySocket);
					exit(0);
				}
			}
			//Příjem dat
			else if(FD_ISSET(mySocket, &read)){
				if(recv(mySocket, buf_in, BUFSIZE, 0) != -1) {
					printf("Přijato: [%s]\n", buf_in);
				}
			}
		}
	}
		printf("Odeslano\n");
    return 0;
}