Discussion :

[PERSONNE_LAMBDA]

Bonjour,

quelqu'un saurait comment on fait un thread pour une connexion tcp/ip qui tourne en boucle et qui incrémente une variable dans une boucle de mon programme principale a chaque fois que le client envoie un message ?

Thread communication TCP/IP :
communique avec client/ attend que le client envoie message en arriere plan

boucle infinie:
qui tourne tant que ne recoit pas le message du client. Si reception du message alors variable++

Un petit exemple serait le bienvenue

Aussi est-il possible d'envoyer des image grâce au TCP/IP ?

Merci

[wiztricks]

Salut,

Un petit exemple serait le bienvenue

Postez déjà ce que vous avez fait (sinon commencez par ouvrir un tuto.)
Le plus simple est déjà de faire fonctionner une fonction sans thread, puis lorsque votre fonction "marche", vous la démarrez en thread via target=...

Aussi est-il possible d'envoyer des image grâce au TCP/IP ?

Une image étant un fichier et un fichier étant une suite d'octets, on peut le faire.

- W

[PERSONNE_LAMBDA]

Mon code marche pas. C'est un peu de la m*rde, je le modifie depuis 3 jours pour voir si j'arrive à faire marcher quelque chose mais non ... du coup il ressemble a rien.

Ce thread est censé tourner en boucle et renvoyer x qui représente en fait l'appui sur "suivant" par le client. (C'est un operateur qui appuie sur suivant sur un autre ordi et envoi l'ordre au programme principale sur Raspberry d’incrémenter la variable qui fait tourner une boucle)

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
 
# coding: utf-8
 
import socket
from threading import Thread
 
 
class Communication(Thread):
 
    def __init__(self, hote, port, clientsocket):
 
        Thread.__init__(self)
        self.hote = ""
        self.port = 12805
        self.clientsocket= clientsocket
        self.x = None 
 
    def run(self):
        while 1:
            self.clientsocket.listen(5)
            sock = ""
            sock = self.clientsocket.recv(1024)
            self.x = sock.decode()
 
 
 
    def result(self):
        return self.x

La c'est la boucle qui doit étre incrémenter à chaque fois que le client envoie "suivant"

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
 
 
 
....
 
hote = ""
port = 12805
connexion_principale = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
connexion_principale.bind((hote, port))
 
thread_comm = Communication(hote, port, connexion_principale)
 
time.sleep(10)
 
thread_comm.start()
 
while 1 :
        continuer = True
 
        if num > 0:
 
            i = (ordre[num] - ordre[num-1])
            detect(i, d_min) #fonction que j'ai créé et qui marche, pas important ici
 
 
        while continuer :
            print(num)
            print("take picture") #que je remplacerais par l'ouverture d'un programme en c++
            time.sleep(10)
            x = thread_comm.result()
            if x == "suivant" :
                num = num +1
                x=""
                continuer = False
 
        if num == len(ordre)-1:
            break
            connexion_avec_client.close()
            connexion_principale.close()

[wiztricks]

Salut,

Mon code marche pas. C'est un peu de la m*rde, je le modifie depuis 3 jours pour voir si j'arrive à faire marcher quelque chose mais non ... du coup il ressemble a rien.

Vous devez essayer de comprendre comment fonctionnent TCP/IP et les threads avant de coder. Ce qui passe par potasser un tuto., la documentation et arriver à comprendre des exemples qui fonctionnent.
A défaut, vous pouvez toujours vous exciter sur votre clavier, il est peu probable que vous arriviez à faire fonctionner quoi que ce soit.

- W

[PERSONNE_LAMBDA]

J'ai regarder et compris des exemples simples et essayer de modifier mon code en fonction mais je n'arrive pas à trouver un exemple qui ressemble à ce que je fais. Du coup je suis un peu perdu, c'est d'ailleurs pour cela que je suis la.

[wiztricks]

Salut,

J'ai regarder et compris des exemples simples

Si vous n'avez pas compris la séquence bind, listen, accept,... (ce que montre votre code). c'est que vous n'avez pas ouvert un tuto. ou alors que vous l'avez survolé histoire d'y piocher un truc tout fait plutôt que de prendre le temps d'apprendre.

Du coup je suis un peu perdu, c'est d'ailleurs pour cela que je suis la.

Ceci est la conséquence de cela.
Après, c'est bien gentil mais je ne vais pas vous raconter ce que vous pourriez trouvrer par vous même dans un tuto. ni écrire le code à votre place.

- W

[tyrtamos]

Bonjour,

Le problème est que je ne comprends pas ce que tu veux faire.

Tu parles de tcp/ip. Il y a donc probablement un serveur et un client.

- Le serveur est un programme à part, qui attend qu'un client lui demande quelque chose (=une requête), et lui répond en fonction de sa demande. Il attend ensuite de nouveau. A la base, on n'a pas besoin d'un thread puisque c'est plutôt une boucle while. On peut avoir besoin d'un thread si on veut que le serveur puisse servir plusieurs clients en même temps. A défaut, le serveur ne peut prendre une nouvelle demande avant que la précédente ne soit traitée.

- Le client envoie sa requête au serveur à n'importe quel moment. Il peut bien sûr y avoir plusieurs clients pour le même serveur.

Récemment, j'ai proposé un code qui faisait quelque chose de particulier: le code du serveur avait un thread en plus qui renseignait en permanence une variable (la date et l'heure pour l'exemple), et le serveur prenait le contenu de cette variable pour répondre au client qui lui demandait. Tu trouveras la discussion ici, et tu pourras peut-être t'en servir en tant que source d'inspiration:
- Pour le serveur: https://www.developpez.net/forums/d1.../#post10715773
- Pour le client: https://www.developpez.net/forums/d1.../#post10764846

A noter tout de même qu'on parle ici de TCP, mais ce n'est pas du web: un navigateur ne serait pas un client valable.

[PERSONNE_LAMBDA]

Si vous n'avez pas compris la séquence bind, listen, accept,... (ce que montre votre code). c'est que vous n'avez pas ouvert un tuto. ou alors que vous l'avez survolé histoire d'y piocher un truc tout fait plutôt que de prendre le temps d'apprendre.
- W

J'ai très bien compris la séquence normal comme décrite dans le cour. Le code que je vous ai partagé était juste pour vous donner un idée de la tête que le programme doit avoir. Je sais qu'il est mal fait et qu'il manque des trucs, comme je l'ai dit j'ai modifier au fur et à mesure pour voir comment tout cela marche, c'est une facon de découvrir la technologie. J'ai un autre programme qui utilise le TCP/IP qui marche très bien mais qui est plus simple et qui ressemble a ce qu'on trouve dans le cours.

Après c'est vrai que ce que j'essaye de faire est bien plus complexe. Et j'ai pas trouver de tuto qui match avec mon besoin.

Ceci est la conséquence de cela.
Après, c'est bien gentil mais je ne vais pas vous raconter ce que vous pourriez trouvrer par vous même dans un tuto. ni écrire le code à votre place.

Je vous l'ai pas demandé. Par contre sa aurait sympa de partager au moins un lien avec un bon tuto qui correspond a ce que je recherche si vous en aviez un au lieu d'être à la limite du désagraéble ...



@tyrtamos Merci pour les liens je vais les regarder. Oui il y a bien deux machines. Un raspberry qui tourne un programme en python où je met le serveur. Et un ordi windows avec un programme en C qui fera office de client. Si je ne fait pas de thread le programme va s'arreter pour demander le message au client (?) ce que je ne veux pas. Il faut qu'il continue jusqu'a que le client lui envoie "suivant" et la il sort de la boucle et incrémente la variable ...

Le Raspberry fait un programme "semi-automatique". Il fait tourner (une boucle) un moteur, s'arrête et prend des photos en gros et lorsque l'appli sur ordi Windows lui envoie un signale il incrémente une variable dans la boucle qui appelle le programme pour faire tourner le moteur, puis s’arrêter et prendre des photos.

[wiztricks]

Salut,

Je vous l'ai pas demandé. Par contre sa aurait sympa de partager au moins un lien avec un bon tuto qui correspond a ce que je recherche si vous en aviez un au lieu d'être à la limite du désagraéble ...

Tous les bons tutos sont indiqués dans ma signature...
Par contre, on dirait que vous y cherchez un exemple de ce que vous voulez faire plutôt que d'apprendre à le construire.

Après c'est vrai que ce que j'essaye de faire est bien plus complexe que le petit tuto. Et j'ai pas trouver de tuto qui match avec mon besoin.

Le code qui répondra à vos besoins sera la composition de fonctionnalités simples: les threads, TCP/IP, ...
Et tout le boulot du programmeur va être de décomposer en fonctions/méthodes simples qu'il pourra écrire et tester indépendamment puis de les composer.

J'ai un autre programme qui utilise le TCP/IP qui marche très bien mais qui est plus simple et qui ressemble a ce qu'on trouve dans le cours

Vous pouvez partir de ce code là et voir que faire pour l'améliorer en une ou plusieurs étapes. Au moins vous aurez quelque chose de fonctionnel à montrer et la possibilité de décrire les difficultés que vous rencontrez à y ajouter une de ces améliorations.

- W

[PERSONNE_LAMBDA]

Bon j'ai réussi à faire un programme qui marche assez bien et qui est pas aussi compliqué que le tien tyrtamos

La ce n'est que le test du programme qu'il me faudra adapté a mon projet.

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
 
from communication import *
import time
 
connexion_principale = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
connexion_principale.bind(('', 12805))
connexion_principale.listen(5)
connexion_avec_client, infos_connexion = connexion_principale.accept()
comm = Communication('', 12805, connexion_avec_client)
comm.start()
 
 
while 1:
    x = comm.result()
    print(x)
    time.sleep(5)

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
import socket
from threading import Thread
 
 
class Communication(Thread):
 
    def __init__(self, hote, port, clientsocket):
 
        Thread.__init__(self)
        self.clientsocket= clientsocket
        self.x = None 
 
    def run(self):
        while 1:
            self.clientsocket.send(b"voulez vous passezau suivant ?")
            sock = ""
            sock = self.clientsocket.recv(1024)
            self.x = int(sock.decode())
 
    def result(self):
        return self.x

Du coup quand je change le msg à envoyé chez le client, le serveur le recoit et cela change la variable x dans mon programme. Maintenant il me reste à adapté cela à mon projet.

N'étant pas expert en python, je suis ouvert au critiques donc n'hésitez pas a me dire si un truc est vraiment mauvais dans le code.

[wiztricks]

Salut,

N'étant pas expert en python, je suis ouvert au critiques donc n'hésitez pas a me dire si un truc est vraiment mauvais dans le code.

Si vous écrivez:

Code :

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

1
2
3
4
5
        while 1:
            self.clientsocket.send(b"voulez vous passezau suivant ?")
            sock = ""
            sock = self.clientsocket.recv(1024)
            self.x = int(sock.decode())

Vous avez deux sujets Python.
- pourquoi la ligne sock = "" juste avant d'assigner autre chose à la variable "sock"?
- comment on sort du "while 1"? Parce que on, là tout de suite, si le client se déconnecte, le serveur (et les services) se plante aussi.
Et un sujet réseau: TCP/IP ne vous garantit pas que .recv retournera tous les octets/bytes de la réponse du client.
Donc même s'il a l'air de fonctionner, c'est mal construit (et une maison mal construite menace de s'écrouler sur ses occupants...)

- W

[PERSONNE_LAMBDA]

pourquoi la ligne sock = "" juste avant d'assigner autre chose à la variable "sock"?

Parce que dans le cours c'est fait comme cela. Du coup j'ai refait la meme chose.

comment on sort du "while 1"? Parce que on, là tout de suite, si le client se déconnecte, le serveur (et les services) se plante aussi.
Et un sujet réseau: TCP/IP ne vous garantit pas que .recv retournera tous les octets/bytes de la réponse du client.
Donc même s'il a l'air de fonctionner, c'est mal construit (et une maison mal construite menace de s'écrouler sur ses occupants...)

On en ressort une fois que la boucle dans l'autre programme se finit. J'en suis pas encore à cette étape. Je rajouterais un if msg == "fini" > close() ... quand j'y arriverais.

Le client sera implémenter dans le code de l'application devloppé en C sur l'autre ordi et il marcherons de façon automatique donc normalement la seul façon de l’arrêter sera que l’opérateur appuie sur un bouton. Deux boucles infinies de part et d'autre. Normalement ca devrait marcher. Mon but n'est pas de faire un serveur web ou je ne sais quoi. Je veux juste faire un simple lien entre les deux ordis et envoyer de simple messages. Dans l'idéal, recv ne recoit qu'un 1 ou un 0 et surement un "fin" pour lui dire que c'est la fin du programme. Le risque de perte est mince je pense.


Par contre, je vais aussi avoir besoin d'envoyer des image du raspi vers l'ordi en continue, j'ai trouvé un programme TCP/IP que j'ai modifié et qui arrive à envoyer une image d'un ordi à l'autre mais il envoie juste une partie, surement à cause de la taille(quand j'augmente le .recv(1024) en .recv(9999999) il envoit une plus grosse partie de l'image).

Est-ce que vous savez quel autre outil mieux adapté je peux utiliser? A savoir que je veux implémenter un code dans mon programme en python et non pas un logiciel qui marcherais à coté.

[wiztricks]

Salut,

Est-ce que vous savez quel autre outil mieux adapté je peux utiliser?

Si vous connaissiez un peu la programmation réseau, c'est quelques dizaines de lignes de code.
Donc l'"outil", vous l'avez... reste à avoir la patience d'apprendre à l'utiliser correctement.

- W

[PERSONNE_LAMBDA]

Si vous connaissiez un peu la programmation réseau, c'est quelques dizaines de lignes de code.
Donc l'"outil", vous l'avez... reste à avoir la patience d'apprendre à l'utiliser correctement.

Justement j'en ai jamais fait de la programmation réseau.

[wiztricks]

Justement j'en ai jamais fait de la programmation réseau.

Vu les questions que vous vous posez et le code que vous écrivez...
Mais on ne peut pas ouvrir un tuto/cours et apprendre à votre place (ce qui n'a rien à voir avec bricoler ou recopier quelques lignes de codes qui fonctionnent sans trop savoir pourquoi).


- W

[PERSONNE_LAMBDA]

Mais on ne peut pas ouvrir un tuto/cours et apprendre à votre place (ce qui n'a rien à voir avec bricoler ou recopier quelques lignes de codes qui fonctionnent sans trop savoir pourquoi).

Je compte pas faire du réseaux plus que ca dans mon projet, j'avais juste besoin de quelques éclaircissements.

Bon finalement je pense pas en avoir besoin du thread. La boucle de la fonction principale est suffisante pour la communication.

Sinon j'ai une autre question. Je viens de configurer un réseau wifi ad-hoc sur mon raspberry. J'arrive à le détecter avec mon ordi et me connecter dessus. Je voulais savoir si la communication TCP/IP peux marcher sur le reseaux ad-hoc entre le raspi et l'ordi ? Si je remplace dans le client.py hote="adresse ethernet du raspi" par "adresse wifi ad hoc du raspi" est ce que cela pourrra communiquer ?

J'ai un ordi assez sécurisé qui ne me permet pas d'autoriser le partage de fichier, du coup je peux pas tester mes codes. La connexion se fait, mais pas d'échange possible entre les deux. J'attends un ordi "normal' qui puisse supporter les réseaux ad-hoc. Quand je ping de l'ordi vers le raspi c'est bon mais dans l'autre sens ca ne marche pas.