Discussion :

[m29poff]

Bonjour,

je suis en train d'écrire un programme sous linux qui doit gérer un nombre important de connections tcp.

je souhaiterais, lors d'un évènement sur une socket, pouvoir accéder à un tableau dont l'indice est le numéro de socket concerné par l'évènement.

Exemple: un évènement se produit sur la socket dont le descripteur est 1515.

j'aurais besoin d'accéder à l'élément tableau[1515].

jusque là ... c'est simple ... me direz vous. Le problème réside dans la taille du tableau à déclarer. Le descripteur de socket est un int. En conséquence, si on souhaite couvrir toutes les valeurs possible du descripteur de socket, il faut déclarer un tableau ayant 2.147.483.647 (valeur de INT_MAX dans limits.h) entrées. C’est bien entendu impossible.

quelqu’un aurait-il une solution à m’apporter qui me permettrait de conserver un accès direct très rapide par un tableau ou suis-je condamné à mettre en place un arbre ou une liste chainée ?

Merci d’avance pour tous vos conseils.

[imperio]

Tu peux toujours créer un tableau que tu ré-alloueras au besoin, mais une liste chaînée me semble être la meilleure solution.

[ram-0000]

Tu peux toujours créer un tableau que tu ré-alloueras au besoin, mais une liste chaînée me semble être la meilleure solution.

+1 pour la liste chainée.

Sinon, au lieu d'utiliser le numéro de socket, tu peux utiliser le numéro de port local (c'est très facile à récupérer, c'est getsockname()), il n'y a que 65536 ports pour TCP et 65536 pour UDP.

Je viens de faire passer ton tableau de 4 milliard potentiel à 2 X 65536, c'est un beau gain

[m29poff]

Bonjour,

Je trouve l'idée d'utiliser le numéro de port local très intéressante. Cependant, cela ne peut fonctionner que pour les connexions sortantes.

Il se trouve que mon programme accepte aussi des connexions tcp (mode serveur).

Dans ce cas, le port local est forcément toujours le même. De plus, on ne peut pas prendre le port source du client comme indice car 2 clients peuvent très bien utiliser 2 ports sources identiques.

En guise de pis-aller j'utiliserai la liste chainée.

Quoiqu'il en soit, je vous remercie pour le coup de main.

[Obsidian]

Avant d'envisager d'allouer 2 milliards de connexions, tu peux déjà te renseigner sur le nombre total de descripteurs de fichiers que le système lui-même est capable d'allouer. Sur un Linux récent, tu trouves cela dans « /proc/sys/fs/file-max ». Sur ma machine, c'est un peu moins de 400.000, ce qui est déjà plus raisonnable. Et évidemment, « ulimit -n » qui te donne la limite imposée par défaut à un processus donné.

Ensuite, plutôt qu'un immense tableau ou une liste chaînée un peu lourde à mettre en place et à parcourir, tu peux opter pour une structure entre les deux. Le mieux, je pense, consiste à allouer plusieurs plages de taille arbitraire, reliées entre elles par une hash table. L'idée étant de pouvoir jouer sur le compromis entre complexité de calcul et mémoire occupée.

En outre, ce n'est pas la peine de prévoir la place pour plus de connexions que tu pourras en gérer : à raison de 1000 connexions par secondes, ce qui est énorme, il te faudrait 24 jours pour recevoir deux milliards de connexions. À titre indicatif, Developpez.com|net reçoit jusqu'à 220.000 visites par jour, ce qui fait une moyenne de… 2,5 connexions par seconde.

À ce stade, l'indice le plus pertinent est la durée moyenne d'une de tes connexions. Si c'est du FTP, elle peuvent perdurer pendant des dizaines de minutes. Si c'est du web, une durée de vie de 2 à 3 secondes maximum suffit. À toi de multiplier ce chiffre par le nombre de connexions par seconde + une marge de sécurité pour définir une taille maximale à ton tableau, quitte à la ré-évaluer en changeant la configuration en cas de besoin.

[Bktero]

Il se trouve que mon programme accepte aussi des connexions tcp (mode serveur). Dans ce cas, le port local est forcément toujours le même.

Si je ne dis pas de bêtise, ceci n'est pas vrai. Tu as un socket serveur à l'écoute sur un port donné et toutes les connexions entrantes passent par ce port. C'est le rôle de la fonction accept(), qui renvoie un nouveau descripteur de socket quand une connexion entrante a lieu. Ce socket utilise alors un port différent du port du socket serveur. Tu peux donc différencier les connexions entrantes via le port du socket de communication. C'est d'ailleurs bien pour ça que tu peux avoir des connexions entrantes simultanées sans qu'elles ne se marchent sur les pieds.

Edit : j'ai dit des bêtises

[ram-0000]

Ce socket utilise alors un port différent du port du socket serveur.

Le numéro de port local (je ne parle pas du numéro de socket) est bien le numéro de port bindé par le serveur.

En fait, une session TCP ou UDP (pour autant que l'on puisse parler de session en UDP) est identifiée de manière unique par le quintuplet :

• protocole (TCP ou UDP)
• adresse IP locale
• adresse IP distante
• numéro de port local
• numéro de port distant

[Bktero]

Bon ben j'ai dit des bêtises

Je viens de faire des tests et j'ai compris d'où venait ma confusion : 1) de mon collègue qui me l'a dit (je balance un peu) 2) de moi qui est mal lu la doc de Python (langage avec lequel j'avais fait des tests à ce sujet).

Petite vérification en Python.
Client :

Code :

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

1
2
3
4
5
6
import socket
sc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
address = ('192.168.2.220', 8080)        
sc.connect(address)
print sc.getsockname()
print "END CLIENT"

--> sortie -->

Code :

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

1
2
('192.168.2.220', 49981)
END CLIENT

Serveur :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
import socket
ss = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ss.bind(("192.168.2.220", 8080))
ss.listen(10)
sc, addr = ss.accept()
print "Get socket : ", sc
print "Get addr: ", addr
print
print "Server socket : ", ss.getsockname()
print "Communication socket : ", sc.getsockname()
print "END SERVER"

--> sortie -->

Code :

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

1
2
3
4
5
6
Get socket :  <socket._socketobject object at 0x0000000002789180>
Get addr:  ('192.168.2.220', 49981)
 
Server socket :  ('192.168.2.220', 8080)
Communication socket :  ('192.168.2.220', 8080)
END SERVER

La valeur de addr rendue par accept()est celle de la paire distante, ce qui est clairement écrit dans la documentation que j'avais lu trop vite : "the address bound to the socket on the other end of the connection."


Un jour moi aussi je serai fort et omniscient

[m29poff]

Bonjour,

merci à tous pour votre aide ... précieuse.

Une dernière question : Dois-je mettre le sujet en Résolu si les réponses apportées me conviennent ?

[Bktero]

C'est le principe même du bouton

Il te suffit de cliquer dessus.