[Socket] optimiser les paramètres de connexion

**Auteur** · 22/05/2009, 19h02

bonjour,

j'ouvre un port puis j'envoie un tableau sur ce port. Tout se passe bien je reçois exactement ce que je veux. Le problème est que la durée d'envoi des données est trop longue. Elle est de 300ms. On m'impose d'envoyer ces données en moins de 30ms.

Comment je peux accélérer le débit ? J'utilise un DataOuptuStream pour envoyer mon tableau :

Voici mon code : (j'ai volontairement enlevé les try{}catch{})
Le code après la méthode accept dure 300ms.

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
 
socketServerSender=new ServerSocket(4000);
 
socketServerSender.setSoTimeout(2000);
socketSender=this.socketServerSender.accept();
 
 
out=socketSender.getOutputStream();
dos=new DataOutputStream(out);
 
dos.writeInt(255);
dos.flush();
out.flush();
 
int n, m, o;
int i, j, k;
n = tabInt.length;		//9(objets)
m = tabInt[0].length;	//50(lignes)
o = tabInt[0][0].length;	//20(colonnes)
 
 
for (i=0;i<n;i++)
{
	for (j=0;j<m;j++)
	{
		for (k=0;k<o;k++)
		{
			dos.writeInt(tabInt[i][j][k]);
		}
	}
}
 
dos.flush();
out.flush();

J'ai essayé de remplacer mon tableau 3D par un tableau 1D, même chose j'ai un temps d'envoi de 300ms environ.

[edit]
Petite précision :
ce code se trouve dans un thread. Est-ce que ça peut expliquer la lenteur d'exécution ?
[/edit]

**gifffftane** · 22/05/2009, 23h51

D'abord, comment vérifies-tu les 30ms ?

Ensuite, je suis un peu étonné que tu utilises un DataOutpurStream, un flux assez évolué, qui fait des traitements sur les données, risque de perte de temps j'imagine ; pourquoi n'utilises-tu pas un BufferedOutputStream, ou même directement l'OutputStream de la socket ?

Ensuite, peut être aussi examiner les possibilités de nio, mais j'ai jamais su si c'était vraiment plus rapide, en tous cas c'est prévu pour.

**Auteur** · 23/05/2009, 00h05

Envoyé par gifffftane

D'abord, comment vérifies-tu les 30ms ?

sur le programme client. Je mesure le temps avant et après exécution du programme.

Petite remarque importante : le programme client n'est pas en Java mais en matlab (la fonction pnet pour être précis).

Envoyé par gifffftane

Ensuite, je suis un peu étonné que tu utilises un DataOutpurStream, un flux assez évolué, qui fait des traitements sur les données, risque de perte de temps j'imagine ; pourquoi n'utilises-tu pas un BufferedOutputStream, ou même directement l'OutputStream de la socket ?

Disons que j'ai pris le DataOutputStream car c'est à ma connaissance le seul objet capable d'envoyer des int32.
Quant au BufferedOutputStream j'avoue que je ne sais pas vraiment m'en servir

J'ai essayé d'envoyer des informations via cet objet je recueillais n'importe quoi à l'arrivée (sans doute parce j'ai dû mal configurer pnet).

Envoyé par gifffftane

Ensuite, peut être aussi examiner les possibilités de nio, mais j'ai jamais su si c'était vraiment plus rapide, en tous cas c'est prévu pour.

tu penses au IntBuffer ? Mais je ne vois pas comment l'associer au OutputStream de mon socket

**gifffftane** · 23/05/2009, 09h14

Envoyé par Auteur

sur le programme client. Je mesure le temps avant et après exécution du programme.

Petite remarque importante : le programme client n'est pas en Java mais en matlab (la fonction pnet pour être précis).

Donc à ce que je comprends de la doc, le temps compté est non seulement celui du transfert, mais de plus il y a dedans le temps d'ouverture de la connexion socket, non ?

**Auteur** · 23/05/2009, 09h34

Envoyé par gifffftane

Donc à ce que je comprends de la doc, le temps compté est non seulement celui du transfert, mais de plus il y a dedans le temps d'ouverture de la connexion socket, non ?

Tout à fait.

Du côté matlab : j'ouvre le port, je reçois les données puis je ferme le port. Pour ce programme Matlab, je n'ai pas le choix, je dois procéder ainsi. Donc du côté Java je dois me plier à cette contrainte.

Du côté Java : j'attends l'ouverture du port, dès qu'il est ouvert j'envoie mes données. Donc en Java, je suis obligé de faire un thread dans lequel je mets une boucle avec la méthode accept(). Dès que la connexion est établie, un flag passe à true, je sors de la boucle et j'envoie les données.

Quand je vois mon programme Java, je constate qu'il n'est pas très optimisé :red: :red:

**gifffftane** · 23/05/2009, 12h14

Pour en revenir à nio, tu as un exemple de serveur dans la doc du jdk à NIO Examples :TimeServer renvoie l'heure - ce n'est pas très différent de tes entiers je suppose - de façon nio-teligente.

**Auteur** · 23/05/2009, 12h44

Je crois que je vais devoir passer par un SocketChannel pour aller plus vite.

La plupart des exemples trouvés sur le net utilisent des PrintWriter pour écrire les données via la méthode print(). Seul souci est que les informations envoyées sont converties en code ASCII (même les nombres).

Reste à trouver côté matlab la bonne configuration pour réceptionner le flux

Au fait si je passe par un SocketChannel pour envoyer mes données est-ce que je dois le configurer comme bloquant ou non bloquant ? Sur ce point je n'ai pas très bien compris la différence entre bloquant et non bloquant.

Penses-tu que je peux améliorer le débit en modifiant les paramètres de connexion de mon socket ? Je pensais à la méthode setTrafficClass et fermer le flux d'entrée (shutdownInput) car par ce port je ne reçois aucune donnée.

**gifffftane** · 23/05/2009, 12h49

Malheureusement je ne peux pas beaucoup t'aider sur la partie optimisation des paramètres de connexion. Pose une autre question sur ce point précis, et peut être auras-tu plus de chance.

Concernant nio vs io, vérifie bien avant de t'embarquer que tu obtiens bien de meilleurs résultats sur une maquette basée sur nio.

**Auteur** · 23/05/2009, 14h13

bonjour,

j'ouvre un port de cette manière :

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
socketServerSender=new ServerSocket(4000);
 
socketServerSender.setSoTimeout(2000);
socketSender=this.socketServerSender.accept();
 
// envoi des données
out=socketSender.getOutputStream();
dos=new DataOutputStream(out);
 
dos.writeInt(255);
dos.flush();
out.flush();
 
int n, m, o;
int i, j, k;
n = tabInt.length;		//9(objets)
m = tabInt[0].length;	//50(lignes)
o = tabInt[0][0].length;	//20(colonnes)
 
 
for (i=0;i<n;i++)
{
	for (j=0;j<m;j++)
	{
		for (k=0;k<o;k++)
		{
			dos.writeInt(tabInt[i][j][k]);
		}
	}
}
 
dos.flush();
out.flush();
 
//.... etc.

Mon souci est que le débit est un peu lent : 300ms pour tout envoyer. Je voudrais envoyer les données en 30ms. De plus la méthode accept étant bloquante, je suis obligé de placer ce code dans un thread.

Les 300ms sont mesurés sur le poste client : le programme client ouvre le port, reçoit les données, puis ferme le port.

Mais visiblement un DataOuputStream n'est pas l'idéal pour ça il faudrait que j'utilise l'API nio plutôt que io.

A priori il faudrait que je passe par un SocketChannel pour envoyer mes données plus rapidement. Du coup je me demande :

est-ce que je dois le configurer comme bloquant ou non bloquant ? Sur ce point je n'ai pas très bien compris la différence entre bloquant et non bloquant.
est-ce je peux améliorer le débit en modifiant les paramètres de connexion de mon socket ? Je pensais à la méthode setTrafficClass et fermer le flux d'entrée (shutdownInput) car par ce port je ne reçois aucune donnée.

**fr1man** · 23/05/2009, 14h23

T'as essayé de passer par un BufferedOutputStream ?

**Auteur** · 23/05/2009, 14h27

Oui, mais les données reçues sont visiblement mal interprétées par le programme client. Sans douter une mauvaise configuration du programme client... Donc je réessayerai.

En fait, j'avais choisi le DataOuputStream car je peux envoyer directement des entiers 32 bits, tandis que les autre types d'objets (comme le BufferedOutputStream) n'envoient que des Bytes ou des Char.
Ce qui pose quelques soucis pour réceptionner les données (le programme client est sous Matlab, pas en java).

Pour le BufferedOutputStream tu peux me donner un exemple d'utilisation ? Comment ferais-tu pour envoyer des entiers 32 bits en utilisant un tableau de Bytes (car visiblement le BufferedOutputStream ne gère que ce format) ?

**fr1man** · 23/05/2009, 14h45

Ben d'après la Javadoc, le BufferedOutputStream a les méthodes:

Code :

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

1
2
 
write(byte[] b, int off, int len)

Writes len bytes from the specified byte array starting at offset off to this buffered output stream.

Code :

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

1
2
 
void	write(int b)

Writes the specified byte to this buffered output stream.

Il suffit d'encapsuler ton DataOutputStream dans le BufferedOutputStream.

A tester.

**Auteur** · 23/05/2009, 18h53

Envoyé par fr1man

Il suffit d'encapsuler ton DataOutputStream dans le BufferedOutputStream.

Certains concepts m'échappent encore en Java.

Peux-tu me dire comment tu ferais ? Pour moi les types sont incompatibles....

Tu ne sais pas si en jouant sur ces paramètres de connexion je peux améliorer la vitesse de transfert des données (cf. mon 1er message) ?

**adiGuba** · 25/05/2009, 10h59

Salut,

J'ai fusionné les discussions : inutile d'éparpiller les infos si tu veux une réponse

L'encapsulation permet englober plusieurs type de flux différents pour profiter des avantages de chacun :

Le DataOutputStream permet d'écrit des types de données tels quel (entiers sur 32 bits, etc...).
Le BufferedOutputStream utilise un buffer pour écrire les données, puis copiera ces données sur le flux par la suite pour minimiser le nombre d'appel d'entré/sortie et donc améliorer les performances.

Code :

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

DataOutputStream out = new DataOutputStream( new BufferedOutputStream( socketSender.getOutputStream() ) );

Sans oublier les try/finally pour la libération...

a++

**Auteur** · 25/05/2009, 11h46

adiGuba

Excellent, génial

Merci à vous. Là grâce au buffer, j'envoie mes données en.... 8ms

au mieux, 20ms au pire

Ça répond parfaitement au cahier des charges

Je vais juste rajouter une remarque :
il faut faire le flush() sur le BufferedOutputStream pas sur le DataOutputStream ou le OutputStream du socket

Sinon là on a à nouveau des temps de transmission très long (~300ms)

**Auteur** · 25/05/2009, 11h56

D'ailleurs je ne comprends pas pourquoi la durée de la transmission avec le buffer varie comme ça du simple au double : entre 8ms et 20ms ? Je m'attendais à quelque chose de plus constant...

Est-ce le fait que la fonction soit dans un thread ?

[Socket] optimiser les paramètres de connexion

Entrée/Sortie Java

Discussions similaires

Partager

Partager