chat multithread serveur/client

**babacar0** · 10/09/2012, 00h18

j essai de faire un chat simple en utilisant des threads ! le probléme c est que le programme n arrive pas a s exécuter et on me signal des erreur sur le serveur et notamment sur le client !

serveur.c

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>
#include <pthread.h>
#include <fcntl.h>
#include <sys/ioctl.h>
 
#define SIZE 10000
#define port 1000
 
 
struct thread_info{
	int socket_tmp;}
 
int create_tcp_server( int port, int nb_max_clients ) {
	int socket_id;
	int optval = 1;
	struct sockaddr_in sockname;
 
	//On établi la connexion
	if( -1 == (socket_id = socket( AF_INET, SOCK_STREAM, 0 ) ) ) {
		fprintf( stderr, "problème création socket\n" );
		exit( EXIT_FAILURE );
	}
 
	setsockopt( socket_id, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof( int ) );
	memset( (char*)&sockname, 0, sizeof( struct sockaddr_in ) );
 
	/* Bind socket to a port */
 
	sockname.sin_family = AF_INET; /* Internet address family */
	sockname.sin_port = htons( port ); /* Local port */
	sockname.sin_addr.s_addr = htonl( INADDR_ANY );/* Any incoming interface */
 
	if( (bind( socket_id, (struct sockaddr*)&sockname, sizeof(struct sockaddr_in))) == -1)
	{
		fprintf( stderr, "problème avec bind\n" );
		exit( EXIT_FAILURE );
	}
	/* Set socket to listen : Mark the socket so it will listen for incoming connections */
	if((listen(socket_id,nb_max_clients)) == -1)
	{
		fprintf( stderr, "problème avec listen\n" );
		exit( EXIT_FAILURE );
	}
 
	return socket_id;
}
 
static void search(char *chaine){
 
    	char *p = strchr(chaine, '\n');
 
   	if (p)
      	*p = 0;
}
 
static void* envoi(void* arg){
	char msg[32]="";
	short int client_id1=0;
	struct thread_info *info=(struct thread_info *)arg;
	int socket_id=info->socket_tmp;
 
	if((client_id1 = accept((int)socket_id,NULL,0)) == -1)
	{
		fprintf( stderr, "problème avec accept\n" );
		exit( EXIT_FAILURE );
	}
	do{
             printf ("Client1 %s\n >", inet_ntoa(sockname.sin_addr.s_addr)); 
		fgets(msg, sizeof(msg), stdin);
		search(msg);
		send(client_id1, msg,sizeof(msg),0);
	}
	while(strcmp(msg,"exit")!=0);
	return NULL;
}
 
int main( int argc, char** argv ) {
	int socket_id,client_id;
	char buffer[128]= "";
	pthread_t thread;
	//permet le passage d'arguments aux threads
	struct thread_info *info;
	info = malloc(sizeof(struct thread_info));
	//SERVEUR TEXTE
	socket_id = create_tcp_server(1000,4);
	info->socket_tmp=socket_id;
	pthread_create(&thread, NULL, envoi,info);
 
	if((client_id = accept(socket_id,NULL,0)) == -1){
		fprintf( stderr, "probleme avec accept texte\n" );
		exit( EXIT_FAILURE );
	}
	else{
		printf("Connexion serveur texte reussi sur socket %d\n",client_id);
		while(recv(client_id,buffer, sizeof(buffer),0)){
			printf("Stranger: %s\n", buffer);
		}
	}
 
	// 0, pour fermer la socket en réception, 1, en émission, 2 dans les deux sens.
	shutdown( socket_id, 2 );
	close( socket_id );
	shutdown( client_id, 2 );
	close( client_id );
 
	pthread_cancel(thread);
	free(info);
         exit( EXIT_SUCCESS );}

client.c

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <netdb.h>
#include <pthread.h>
#include <fcntl.h>
#include <sys/ioctl.h>
#define port 1000
#define SIZE 10000
 
struct thread_info{
	int socket_tmp;
};
 
int create_tcp_client( const char* hostname, int port ) {
	struct hostent* host_address;
	struct sockaddr_in sockname;
	int optval;
	int socket_id;
 
	if( NULL == ( host_address = gethostbyname( hostname ) ) ) {
		fprintf( stderr, "machine %s inconnue\n", hostname );
		return( EXIT_FAILURE );
	}
	/* Create a reliable, stream socket using TCP */
	if( -1 == ( socket_id = socket( AF_INET, SOCK_STREAM, 0 ) ) ) {
		fprintf( stderr, "création de socket impossible\n" );
		return( EXIT_FAILURE );
	}
 
	optval = 1;
	setsockopt(socket_id, SOL_SOCKET, SO_REUSEADDR, &optval, sizeof(int) );
 
	/*Establish connection*/
	sockname.sin_family = host_address->h_addrtype;
        sockname.sin_addr.s_addr = inet_addr(“10.0.3.15”);
 /* l'adresse se trouve dans le champ h_addr de la structure host_adress */
	sockname.sin_port = htons( port );/* Server port */
	memcpy( (char*)&(sockname.sin_addr.s_addr), host_address->h_addr, host_address->h_length );
 
	if((connect( socket_id, (struct sockaddr*)&sockname, sizeof(struct sockaddr_in)))==-1) {
		fprintf( stderr, "connexion impossible socket au server %s\n", hostname );
		return( EXIT_FAILURE );
	}
 
	return socket_id;
}
 
static void search(char *chaine){
 
    	char *p = strchr(chaine, '\n');
 
   	if (p)
      	*p = 0;       
}
 
void* recep(void* socket_id){
 
	char buffer[64] = "";
	int socket_id1 = create_tcp_client( "localhost", 1000 );
 
	while(recv(socket_id1,buffer, sizeof(buffer), 0))
		printf("Stranger: %s\n", buffer);
	return 0;
}
 
int main( int argc, char** argv ) {
	int socket_id=0;
	char msg[128]="";
	pthread_t thread;
	struct thread_info *info; //permet le passage d'arguments aux threads
	info = malloc(sizeof(struct thread_info));
 
	//SOCKET TEXTE
	socket_id = create_tcp_client( "localhost", 2000);
	info->socket_tmp=socket_id;
	pthread_create(&thread, NULL, recep, info);
 
	//ENVOI DE TEXTE
	do{	
		fgets(msg, sizeof(msg), stdin);
		search(msg);
		send(socket_id, msg,sizeof(msg),0);
	}
	while(strcmp(msg,"exit")!=0);
 
	//On ferme les threads
	pthread_cancel(thread);
	//On ferme les sockets
	shutdown( socket_id, 2 );
	close( socket_id );
	free(info);
	exit( EXIT_SUCCESS );
 
}

**Neckara** · 10/09/2012, 07h17

Bonjour,

Pourrais-tu au moins nous donner ces erreurs qu'on sache où chercher?

**babacar0** · 10/09/2012, 13h26

pour le client pour le moment y a plus de probléme j avais fais une erreur en fixant le la valeur du port ! mais pour le serveur je comprend pas il me dique "serveurchat1.c:18:1: erreur: expected ‘;’, identifier or ‘(’ before ‘int’ c est sur la ligne 20 int create_tcp_server( int port, int nb_max_clients ) {

**Bktero** · 10/09/2012, 14h22

Met un ; après la déclaration de la structure, comme te le dit ton compilateur.

**babacar0** · 10/09/2012, 14h23

merci Bktero! le serveur s execute! mais y a un nouveau probléme ! il me retourne "problème avec bind " surement a partir du ligne 40 !

**mala92** · 10/09/2012, 16h14

il semblerait que tu sois sous linux, quel est la valeur de errno ? (quand tu as l'erreur avec bind)

**babacar0** · 10/09/2012, 16h29

si la reponse retournée est égale a -1

**Bktero** · 10/09/2012, 17h15

Bien tenté mais ce n'est pas la bonne réponse car ce n'est pas la bonne question à laquelle tu réponds ^^

ERRNO est une variable globale contenant des codes d'erreur, tu peux t'en servir pour avoir des informations sur la cause des échecs des fonctions de la bibliothèque standard (et plus si affinités).

Fais un #include <errno.h> et rajoute des instructions telles que printf("%d : %s", errno, strerror(errno)); avec des printf() de messages d'erreur.

**babacar0** · 10/09/2012, 17h15

je viens de modifier ca en perror("problème avec bind"); exit(-1); et apres execution on me dit que problème avec bind: Permission denied

**babacar0** · 10/09/2012, 17h33

j ai corriger le bind printf("problème avec listen\n %d : %s", errno, strerror(errno)); exit(-1); et j ai essayé avec le listen et j ai de nouveau un probléme avec printf( "problème avec listen \n %d : %s", errno, strerror(errno) ); exit(-1); et le méme probléme problème avec listen
13 : Permission denied

**Neckara** · 10/09/2012, 18h06

Il est inutile de m'envoyer des MP et de poster une réponse ici en disant la même chose, quand on répond à un sujet on "s'abonne" au sujet et on voit s'il y a des nouvelles réponses ou non.

Concernant ton problème actuel, je parie que tu fermes mal ton socket à la fin du programme serveur et que lorsque tu relance le serveur, le socket ne s'est pas encore fermé.
Une des solutions est de changer le numéro du port (surtout quand on fait du débug).

**babacar0** · 10/09/2012, 18h24

j ai changer de port de port et j arrive a executer et ca s arréte comme si il était en standby en attendant un client mais seulement pour le client le programme renvoie strange strange infiniement !ca s arréte au niveau de la ligne 67-68

**babacar0** · 10/09/2012, 19h08

pour le client : dans la boucle while de la ligne 66 j ai modifier en if pour voir les problémes qui sont au dessus de ca !et je vient de me rendre compte que ca se bloque au niveau de la connexion ! ca me dit connexion impossible !

**Neckara** · 10/09/2012, 19h09

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
	int socket_id1 = create_tcp_client( "localhost", 1000 );
 
	while(recv(socket_id1,buffer, sizeof(buffer), 0))

Quand vérifies-tu que socket_id1 est un socket valide?
Quand tu as modifié le port côté serveur, tu l'as aussi modifié côté client?

EDIT : pense aussi à lire le man de recv car ta boucle est fausse, que se passe-t-il en cas d'erreur? (question rhétorique).

**babacar0** · 11/09/2012, 02h48

est ce que socket_id1 a besoin fait appel a la fonction create_tcp_client !
et pour la fonction recv je crois que y a pas d erreur
recv(le_socket,tableau_contenant_message,taille_du_tableau,0)
j ai changer le port en mettant 1030 !
et jesuis toujours bloquer !
merci !

**babacar0** · 11/09/2012, 03h04

est ce que socket_id1 a besoin d'étre verifier puisqu'il fait appel a la fonction create_tcp_client !
et pour la fonction recv je crois que y a pas d erreur
recv(le_socket,tableau_contenant_message,taille_du_tableau,0)
j ai changer le port en mettant 1030 !
mais il me renvoie aussi le message connexion impossible socket au server localhost
d ou il ne crée méme pas le socket-id1 !
et je suis toujours bloquer !
las je suis un peut perdu !
ho que c est dure d étre debutant !
mais merci de votre aide !

**jabbounet** · 11/09/2012, 08h27

Envoyé par babacar0

est ce que socket_id1 a besoin d'étre verifier puisqu'il fait appel a la fonction create_tcp_client !
et pour la fonction recv je crois que y a pas d erreur
recv(le_socket,tableau_contenant_message,taille_du_tableau,0)
j ai changer le port en mettant 1030 !
mais il me renvoie aussi le message connexion impossible socket au server localhost
d ou il ne crée méme pas le socket-id1 !
et je suis toujours bloquer !
las je suis un peut perdu !
ho que c est dure d étre debutant !
mais merci de votre aide !

il serait bon de récupérer l'errno remonté par connect.

ici tu as

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
if((connect( socket_id, (struct sockaddr*)&sockname, sizeof(struct sockaddr_in)))==-1) {
		fprintf( stderr, "connexion impossible socket au server %s\n", hostname );
		return( EXIT_FAILURE );
	}

Mais cela n'aide pas si tu n'as pas la raison de l'erreur, d'un manière générale utiliser errno sur les appel système te permettra d'avoir des informations supplémentaires sur le problème que ton application rencontre.

essaye

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
if((connect( socket_id, (struct sockaddr*)&sockname, sizeof(struct sockaddr_in)))==-1) {
		fprintf( stderr, "connexion impossible au serveur %s: errno=%d : %s\n", hostname, errno, strerror(errno) );
		return( EXIT_FAILURE );
	}