Outils pour utilisateurs
Panneau latéral
isn:raspberry_websocket2
Table des matières
Raspberry : un websocket pour recevoir et envoyer des messages en même temps
Le premier programme de Websocket serveur en python :
- écoutait tout d'abord le message envoyé par le client (la page html) qui se connecte,
- avant d'envoyer le message de bienvenu (Bonjour).
Pour, à la fois recevoir et envoyer des messages sur la même connexion, on combine les deux fonctions send() et recv() en les faisant s'exécuter dans des tâches parallèles :
#!/usr/bin/env python3 import asyncio import websockets # Gestion de l'envoi des messages du serveur au client async def gestion_envoi_message(websocket): i = 0 # boucle infinie pour envoyer toutes les secondes un message ; while True: await websocket.send("Bonjour {}".format(nb)) i = i + 1 await asyncio.sleep(1) # Gestion des messages recus du client async def gestion_reception_message(websocket): while True: # reception du message d'un client message = await websocket.recv() print(message) # fonction lancee à chaque connexion d'un client async def echange(websocket,path): # définir la fonction comme asynchrone #envoyer des messages en parallèle envoyer = asyncio.ensure_future(gestion_envoi_message(websocket)) #recevoir message en parallèle recevoir = asyncio.ensure_future(gestion_reception_message(websocket)) termine, attente = await asyncio.wait( [envoyer, recevoir], return_when = asyncio.FIRST_COMPLETED, ) # Definir la fonction qui sera appelee par le serveur a la connexion d'un client lancement_serveur = websockets.serve(echange,'10.3.141.1', 5678) # Creation de la boucle d'evenement (event loop) loop = asyncio.get_event_loop() loop.run_until_complete(lancement_serveur) loop.run_forever() loop.close()
- pour lancer le serveur ouvrez le terminal et lancez l'exéuction du programme python :
$ python3 serveur.py
Programme javascript du client
Dans la page Web HTML :
- la balise <span> affiche les messages envoyés toutes les secondes par le serveur,
- un bouton HTML est ajouté pour déclencher à la demande l'envoi d'un message au serveur.
<!DOCTYPE html> <html> <head> <meta charset="UTF-8"> </head> <body> <span id="messagerecu">En attente d'un message du serveur</span><br /> <input type="button" name="envoi" id="envoi" value="Envoyer message"/> <script> // selectionner la balise <span> avec son id var affichemessage = document.getElementById('messagerecu'); // creation du websocket client vers le websocket serveur du Raspnerry var ws = new WebSocket("ws://10.3.141.1:5678/"); ws.onopen = function (event) { ws.send("J'envoie un premier message au serveur."); }; ws.onmessage = function (event) { //affiche le message recu dans la balise <span> affichemessage.innerHTML = event.data; }; // Ajout d'un gestionnaire d'événement sur le bouton var envoi = document.getElementById('envoi') envoi.addEventListener('click',envoyerMessage); var numeroMessage = 1; // fonction qui envoie un message au serveur function envoyerMessage() { ws.send("J'envoie message " + numeroMessage + " au serveur."); numeroMessage += 1; } </script> </body> </html>
Vous pouvez à la fois :
- envoyer un message au serveur
- et recevoir en même temps un message du serveur
Pour visualiser l'envoi et la réception simultanés des messages, cliquez sur le bouton de la page et observez l'affichage du print dans le terminal du Raspberry
Envoyer plusieurs message en même temps
Il peut être utile d'envoyer en même temps plusieurs messages et non les uns à la suite des autres. C'est le cas par exemple pour :
- faire avancer la voiture et,
- faire tourner en même temps les roues.
Dans la fonction du programme serveur qui traite de la réception des message vous pouvez lancer des tâches parallèles de la manière suivante :
async def gestion_reception_message(websocket): while True: # reception du messsage d'un client message = await websocket.recv() print(message) # lancement de la tache qui gere le deplacement avant/arriere de la voiture asyncio.get_event_loop().create_task(deplacement(message)) # lancement de la tache qui gere la direction droite ou gauche asyncio.get_event_loop().create_task(direction(message))
Il reste à écrire les fonctions correspondantes deplacement() et direction() qui doivent analyser le contenu du message pour savoir le sens du déplacement (avant ou arrière) ainsi que la direction à prendre (droite ou gauche.
Les activités ...
isn/raspberry_websocket2.txt · Dernière modification: 2018/05/03 18:58 (modification externe)
Sauf mention contraire, le contenu de ce wiki est placé sous les termes de la licence suivante : CC Attribution-Noncommercial-Share Alike 4.0 International
