Outils pour utilisateurs

Outils du site


Panneau latéral

ACCUEIL

Support de cours

SNT

ICN

Semestre 1

Semestre 2

Semestre 3 et 4

Les livres du BTS SIO

* accès limité

isn:raspberry_websocket2

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)