Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/python3.4


from System.bottle import route, run, static_file, request, abort, error
import threading
import socketserver
import queue


class ThreadedRCPRequestHandler(socketserver.BaseRequestHandler):

    def handle(self):
        data = self.request.recv(1024)
        print(data)
        self.server.setData(data)


class RCPRequestServer(socketserver.ThreadingMixIn, socketserver.TCPServer):
    
    def __init__(self, server_address):
        socketserver.TCPServer.__init__(self, server_address, ThreadedRCPRequestHandler, bind_and_activate=True)
        self._queue = queue.Queue()
    
    def getNextMessage(self):
        return self._queue.get()
    
    def hasMessages(self):
        return not self._queue.empty()
    
    def setData(self, data):
        self._queue.put(data)
        print("valide Daten empfangen")
        
    def start(self):
        server_thread = threading.Thread(target=self.serve_forever)
        server_thread.daemon = True         # Exit the server thread when the main thread terminates
        server_thread.start()
        print("RCP Request Server running in thread: " + server_thread.name)



@route('/')
def callMyCMS():
    return "ich zeige die Messwerte"

r = RCPRequestServer(("0.0.0.0", 1756))
r.start()

run(host="localhost", port=8080, debug=False)

Code: Alles auswählen

#!/usr/bin/python3.4


from System.bottle import route, run
import threading
import time


class TestThread():
     
    def __init__(self):
        self._serving = False
        print("TestThread created ...")
         
    def __del__(self):
        print("TestThread destroyed ...")
        
    def start(self):
        self._serving = True
        server_thread = threading.Thread(target=self.serve)
        server_thread.daemon = True         # Exit the server thread when the main thread terminates
        server_thread.start()
        print("TestThread running in thread: " + server_thread.name)

    def stop(self):
        self._serving = False
     
    def serve(self):
        while self._serving:
            time.sleep(1)
            print("TestThread heartbeat")
#             pass
        print("TestThread stopped ...")


class cnt():
    
    def __init__(self):
        self._v = 0
    
    def inc(self):
        self._v += 1
        return self._v


c = cnt()

@route('/')
def callMyCMS():
    return "ich zeige die Messwerte " + str(c.inc())

r = TestThread()
r.start()

run(host="localhost", port=8080, debug=False)