Envoi d'un fichier csv d'un client TCP en C vers un serveur Java

**nabil.brarou** · 08/10/2013, 16h48

Bonjour,

J'ai besoin d'implémenter un serveur Java qui reçoie un fichier csv provenant d'un client C qui se connecte à ce serveur à l'aide d'une socket TCP.

J'ai essayé pas mal de solution au niveau de la reception mais sans résultat.
Veuillez me guider svp.
Merci.
Pour savoir sur client pour ceux qui veulent:

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
 
void send_file_to_android_server(FILE *file){
 
    int sockfd,n;
 
    char *filename = "/mnt/sdcard/pcap-test03-09-2013.csv";
 
    unsigned int file_size = get_file_size(filename);
    printf("File size %d\n",file_size);
 
    printf("--------------------\n");
    printf("Connecting to server\n");
    sockfd = connect_to_server();
    printf("--------------------\n");
 
    printf("prepare file to send it to android server...\n");
 
    if(file != NULL){
        bool check_EOF = false;         
        while(check_EOF == false){
            if(fgetc(file)== EOF)
                 check_EOF = true;
                if(send(sockfd,file,file_size,0) < 0) {
                    perror("send ");
                    exit(1);
                }
        }
 
    fclose(file);
/*            printf("source %s\n",source);*/     
    }
/*    free(source);*/
    printf("-----------------------------------\n");
    printf("the file was sent successfully\n");
    printf("-----------------------------------\n");
 
    close(sockfd);
}

avec connect_to_server () :

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
 
int connect_to_server(){
 
    int socketfd;
    int local_port = 2222;
    bool connected = false; 
    struct sockaddr_in servaddr;
    struct timeval tv;
    double time_in_millisc = (tv.tv_sec) * 1000 + (tv.tv_usec) / 1000;
 
    socketfd = socket(AF_INET,SOCK_STREAM,0);
    if(socketfd == -1) {
            perror("socket"); 
            return -1;
    }
 
    bzero(&servaddr,sizeof(servaddr));
    servaddr.sin_family = AF_INET;                          
    servaddr.sin_addr.s_addr=inet_addr("127.0.0.1");        
    servaddr.sin_port=htons(local_port);
 
    while(connected == false){
         if (connect(socketfd, (const struct sockaddr *)&servaddr, sizeof(struct sockaddr_in)) == 0) { 
            printf("current time %f\n",time_in_millisc);
            connected = true; 
          } else {
          strerror(errno);
          perror("connect");
          }
    }  
return socketfd;
}

**nabil.brarou** · 08/10/2013, 17h57

J'ai essayé une version :

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
 
public class TCPreceiver implements Runnable {
 
		ServerSocket _socket;
		String pcap_message;
		Socket pcapclient;										
		int local_port = 2222;
		BufferedReader inFromPcapServer;
		@Override
		public void run() {
 
			Log.d(TAG, "...TCP SERVER...");
			long start = System.currentTimeMillis();
				try {
					// Set new Socket
					_socket = new ServerSocket(local_port);
				} catch (IOException e1) {
					Log.e(TAG,"Could not listen on port:"+ local_port);
				}				
				Log.i(TAG,"waiting for connection...");
 
				try { 
					// Accept new TCP client
				   pcapclient = _socket.accept(); 
				   Log.i(TAG,"current time " + System.currentTimeMillis());
 
				} catch (IOException e) 
				{ 
				   Log.e(ERROR,"Can't accept client connection."); 
				} 	
 
				try {
					inFromPcapServer = new BufferedReader(
							new InputStreamReader(pcapclient.getInputStream()));
				} catch (IOException e1) {
					Log.e(ERROR,"Problem in BufferedReader : ",e1);
				}
 
				try {
					pcap_message = inFromPcapServer.readLine();
				} catch (IOException e1) {		
					Log.e(ERROR,"Reading from socket failed : ",e1);
				}					
				Log.d(TAG, "New client, address " + pcapclient.getInetAddress()
						+ " on " + pcapclient.getPort() + ".");
 
//				boolean isnextline = true;
//				while(isnextline){
					if(pcap_message != null){
 
					Log.d(TAG, "Received from pcap program \n" + pcap_message);
						// Write the message and close the connection
					}
//					else 
//						isnextline = false;
//				}	
				Log.d(TAG, "File received from pcap_server");
				long end = System.currentTimeMillis();
				Log.d(TAG,"time execution : " + (end -start));
				try {
					pcapclient.close();
					_socket.close();
				} catch (IOException e) {
 
					Log.e(ERROR,"Problem on closing the sockets", e);
				}
		}
	}

le backtrace est :

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
 
================================================
10-08 17:50:16.155: D/wbest_server(1115): ...TCP SERVER...
10-08 17:50:16.165: D/wbest_server(1115): Write_csv_file...
10-08 17:50:16.175: I/wbest_server(1115): waiting for connection...
10-08 17:50:16.185: I/wbest_server(1115): current time 1381247416187
10-08 17:50:16.205: D/wbest_server(1115): New client, address /127.0.0.1 on 40859.
10-08 17:50:16.210: D/wbest_server(1115):  SDCard state is ok
10-08 17:50:16.220: D/wbest_server(1115): Received from pcap program 
10-08 17:50:16.220: D/wbest_server(1115): (������������������@����(�����������������hX
10-08 17:50:16.220: D/wbest_server(1115): File received from pcap_server
10-08 17:50:16.220: D/wbest_server(1115): time execution : 65
10-08 17:50:16.225: D/wbest_server(1115): Writing into Java csv file...
10-08 17:50:16.225: I/wbest_server(1115): Date 08/10/13 17:50:16:1381247416128
10-08 17:50:16.230: D/wbest_server(1115): finish runOnUIthread...
10-08 17:50:16.230: D/wbest_server(1115): =============================================
 
Je reçois le la première ligne encodée.

le fichier à envoyer ressemble à ça :

[1] 08-10-13 17:50:08 1381247408131
[2] 08-10-13 17:50:09 1381247409974
[3] 08-10-13 17:50:12 1381247412021
[4] 08-10-13 17:50:14 1381247414070
[5] 08-10-13 17:50:16 1381247416118
...etc

**thelvin** · 08/10/2013, 22h03

Faudrait boucler sur toutes les lignes au lieu de lire juste la première.

Mais à part ça, pas de soucis côté réception. Vérifie ce que le C envoie, avec un espion réseau.

**tchize_** · 08/10/2013, 22h33

J'ai l'impression que le code C envoie du caca: tu fais des fgetc() sur le fichier à lire, mais tu droppe directement le résultat:

Code :

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

1
2
 
if(fgetc(file)== EOF)

Du coup tu perd au moins un caractère par boucle.

Ensuite, ce serait peut-être bien d'avoir le code d'envoi derrière send. Mais j'ai l'impression que la seule chose que tu écrit sur le réseau, c'est ton handle de fichier plutot que son contenu

**nabil.brarou** · 09/10/2013, 11h46

@thelvin:

Quand je fais while(_pcapclient.readline() !⁼null)
pour boucler sur toutes les lignes le serveur plante.

**thelvin** · 09/10/2013, 12h11

Sans doute du fait que le client envoie n'importe quoi.

Et puis, "plante," mais encore ? Il prend un géranium et le met en terre ?

**tchize_** · 09/10/2013, 12h59

Envoyé par thelvin

Et puis, "plante," mais encore ? Il prend un géranium et le met en terre ?

Ca veux peut-être dire que le code attends comme un poireau?

**nabil.brarou** · 09/10/2013, 15h01

j'ai fait ça au coté client :

Code :

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

1
2
3
4
5
6
7
8
9
10
 
  char *buffer = malloc(file_size + 1);
    fread(buffer, file_size, 1,file);
    fclose(file);
    buffer[file_size] ='\0';
    printf("Buffer \n%s\n",buffer);
    if(send(sockfd,buffer,file_size,0) < 0) {
        perror("send ");
        exit(1);
    }

Je mets le fichier dans une chaine de caractère puis j'envoie la chaine dans le send avec file_size (la taille du fichier calculé avant)

Au niveau serveur si je fais mon test sur BufferedReader.readLine() une seule fois j'obtiens
la première ligne du buffer envoyé ce qui est normal, cependant quand je boucle, au niveau du serveur ce dernier plante.

**tchize_** · 09/10/2013, 15h22

Envoyé par nabil.brarou

ce dernier plante.

Merci de

1) donner le code que tu utilise maintenant sur le serveur
2) définir "plante" comme on te l'a demandé....

**nabil.brarou** · 09/10/2013, 15h27

plante = le programme Java ne répond plus, l'application de réception s'arrete de fonctionner toute seule.
Alors au niveau de mon client j'ai bien mis le fichier dans la chaine pour éviter toute sorte d'erreure provenant dr celui-ci...

**nabil.brarou** · 09/10/2013, 15h33

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
 
public class TCPreceiver implements Runnable {
 
		ServerSocket _socket;
		String pcap_message;
		Socket pcapclient;										
		int local_port = 2222;
		BufferedReader inFromPcapServer;
		@Override
		public void run() {
 
			Log.d(TAG, "...TCP SERVER...");
			long start = System.currentTimeMillis();
				try {
					// Set new Socket
					_socket = new ServerSocket(local_port);
				} catch (IOException e1) {
					Log.e(TAG,"Could not listen on port:"+ local_port);
				}				
				Log.i(TAG,"waiting for connection...");
 
				try { 
					// Accept new TCP client
				   pcapclient = _socket.accept(); 
				   Log.i(TAG,"current time " + System.currentTimeMillis());
 
				} catch (IOException e) 
				{ 
				   Log.e(ERROR,"Can't accept client connection."); 
				} 	
 
//				byte[] buffer;
//				ByteArrayOutputStream getBytes = new ByteArrayOutputStream();
//				
//				int numBytesRead;
//				buffer = new byte[1024];
//				
//				try {
//					numBytesRead = pcapclient.getInputStream().read(buffer, 0,1024);
//				} catch (IOException e2) {
//					Log.e(ERROR,"IOException");
//				}
 
				try {
					inFromPcapServer = new BufferedReader(
							new InputStreamReader(pcapclient.getInputStream()));
				} catch (IOException e1) {
					Log.e(ERROR,"Problem in BufferedReader : ",e1);
				}
				try {
					pcap_message = new String(inFromPcapServer.readLine());
 
				} catch (IOException e1) {		
					Log.e(ERROR,"Reading from socket failed : ",e1);
				}					
				Log.d(TAG, "New client, address " + pcapclient.getInetAddress()
						+ " on " + pcapclient.getPort() + ".");
 
 
				while(pcap_message != null){
 
 
					Log.d(TAG, "Received from pcap program \n" + pcap_message);
						// Write the message and close the connection
 
 
 
				}	
				Log.d(TAG, "File received from pcap_server");
				long end = System.currentTimeMillis();
				Log.d(TAG,"time execution : " + (end -start));
				try {
					pcapclient.close();
					_socket.close();
				} catch (IOException e) {
 
					Log.e(ERROR,"Problem on closing the sockets", e);
				}
		}
	}

**tchize_** · 09/10/2013, 16h08

Code :

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

1
2
3
4
5
6
7
8
9
				while(pcap_message != null){
 
 
					Log.d(TAG, "Received from pcap program \n" + pcap_message);
						// Write the message and close the connection
 
 
 
				}

si pcap_message n'est pas null, tu va tourner en boucle infinie là. Tu fait juste un log et tu ne modifie jamais pcap_message. Ta boucle est équivalente à while(true). Tu dois au moins changer pcap_message dans ta boucle, par exemple en lisant la ligne suivante du Stream.

Aussi,

Code :

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

pcap_message = new String(inFromPcapServer.readLine());

Le new String est totalement inutile là. readLine retourne déjà une String.

**nabil.brarou** · 09/10/2013, 16h51

effectivement tu as raison, c'est bete de ne pas penser à ça...

**Elendhil** · 10/10/2013, 14h50

Hmm tu as pas l'intention de mettre ce code dans ton programme ?

Quel intérêt de faire autant de try catch si c'est juste pour les logs , un seul suffit car la ça fait un peu crado comme code. A la limite deux try-catch , pour permettre un system.exit dans le premier si ton programme est un pur serveur.

Pourquoi tu utilises un vieux "logger" interne à Sun qui est censé ne plus être utilisé ? tu peux remplacer par "java.util.logging.Logger" ?

**tchize_** · 10/10/2013, 16h17

moi ce qui m'ennuie surtout c'est qu'après le catch on continue quand même et tant pis pour les null

Pour ce qui est du logger, c'est le logger standard d'android qu'il utilise (logcat)

**Elendhil** · 10/10/2013, 19h45

Ah d'accord !
C'est fun, on peut lancer un petit serveur comme ça avec du code java standard sous android ? Le système bloque pas les ports entrants ?

**nabil.brarou** · 11/10/2013, 10h55

En fait les try & catch que j'ai utilisé je les ai remplacé par un seul, ça s'était une première version non optimisé du code... comme il dit Elendhil c'est crad...

Pourquoi tu utilises un vieux "logger" interne à Sun qui est censé ne plus être utilisé ? tu peux remplacer par "java.util.logging.Logger" ?

j'utilise cette classe "android.util.Log" et non pas le logger, enfin si j'ai bien compris ce n'est pas la meme chose.

Envoi d'un fichier csv d'un client TCP en C vers un serveur Java

Langage Java

Discussions similaires

Partager

Partager