Python 3 Threaded-Websockets-Server

Question

May 11, 2016, 09:47 PM

Python 3 Threaded-Websockets-Server

Ich erstelle eine Websocket-Server-Anwendung in Python 3. Ich verwende diese Implementierung:https: //websockets.readthedocs.io

rundsätzlich möchte ich mehrere Clients verwalten. Außerdem möchte ich Daten von 2 verschiedenen Threads senden (einer für GPS + einer für IMU). GPS-Thread wird bei 1 Hz aktualisiert, während IMU-Thread bei 25 Hz aktualisiert wird.

Mein Problem ist in der MSGWorker.sendData-Methode: Sobald ich die Zeile @ asyncio.coroutine auskommentiere und aus websocket.send ('{"GPS": "% s"}'% data) erhalte, führt die gesamte Methode nichts aus (nein print ("Daten senden: foo") im Terminal)

Mit diesen zwei kommentierten Zeilen funktioniert mein Code jedoch wie erwartet, außer dass ich nichts über den Websocket sende.

Aber mein Ziel ist es natürlich, Daten über den Websocket zu senden. Ich verstehe einfach nicht, warum es nicht funktioniert. Irgendeine Idee

server.py

#!/usr/bin/env python3
import signal, sys
sys.path.append('.')
import time
import websockets
import asyncio
import threading

connected = set()
stopFlag = False



class GPSWorker (threading.Thread):
  def __init__(self):
    threading.Thread.__init__(self)
    self.data = 0
    self.lastData = 0
    self.inc = 0

  # Simulate GPS data
  def run(self):
    while not stopFlag:
      self.data = self.inc
      self.inc += 1
      time.sleep(1)

  def get(self):
    if self.lastData is not self.data:
      self.lastData = self.data
      return self.data



class IMUWorker (threading.Thread):
  def __init__(self):
    threading.Thread.__init__(self)
    self.data = 0
    self.lastData = 0
    self.inc = 0

  # Simulate IMU data
  def run(self):
    while not stopFlag:
      self.data = self.inc
      self.inc += 1
      time.sleep(0.04)

  def get(self):
    if self.lastData is not self.data:
      self.lastData = self.data
      return self.data



class MSGWorker (threading.Thread):
  def __init__(self):
    threading.Thread.__init__(self)

  def run(self):
    while not stopFlag:
      data = gpsWorker.get()
      if data:
        self.sendData('{"GPS": "%s"}' % data)          

      data = imuWorker.get()
      if data:
        self.sendData('{"IMU": "%s"}' % data)

      time.sleep(0.04)

  #@asyncio.coroutine
  def sendData(self, data):
    for websocket in connected.copy():
      print("Sending data: %s" % data)
      #yield from websocket.send('{"GPS": "%s"}' % data)



@asyncio.coroutine
def handler(websocket, path):
  global connected
  connected.add(websocket)
  #TODO: handle client disconnection
  # i.e connected.remove(websocket)



if __name__ == "__main__":
  print('aeroPi server')
  gpsWorker = GPSWorker()
  imuWorker = IMUWorker()
  msgWorker = MSGWorker()

  try:
    gpsWorker.start()
    imuWorker.start()
    msgWorker.start()

    start_server = websockets.serve(handler, 'localhost', 7700)
    loop = asyncio.get_event_loop()
    loop.run_until_complete(start_server)
    loop.run_forever()

  except KeyboardInterrupt:
    stopFlag = True
    loop.close()
    print("Exiting program...")

client.html

<!doctype html>
<html>
<head>
  <meta charset="UTF-8" />
</head>
<body>
</body>
</html>
<script type="text/javascript">
  var ws = new WebSocket("ws://localhost:7700", 'json');
  ws.onmessage = function (e) {
    var data = JSON.parse(e.data);
    console.log(data);
  };
</script>

Danke für Deine Hilf