Das deutsche Python-Forum

Code: Alles auswählen

# -*- coding: iso-8859-1 -*-

import  bluetooth 
import threading
import Queue


class MyBTServer(threading.Thread):

    def __init__(self, notify_window, QueueIn, QueueOut):
        
        threading.Thread.__init__(self)
        
        #Warteschlangen für den Server
        self.QueueIn = QueueIn
        self.QueueOut = QueueOut
        
        #vorerst standardport - Port wird später vor Aufruf von run gesetzt
        self.Port = 15
        
        #bei schliessen des Main-Threads auch Server beenden
        self.setDaemon(True)
        
        self.CreateServer()
        self.run()
        
        
    def CreateServer(self):
        """
        BT-Server auf PORT starten
        """
        self.server_sock=bluetooth.BluetoothSocket( bluetooth.RFCOMM )
        self.server_sock.bind(("",self.Port))
        self.server_sock.listen(1)
        print "Server erstellt auf  Port", self.Port
        
        
    def run(self):
        """
        Verbindungen Annehmen und an Handler weitergeben
        """
        while True:
            self.client_sock, self.client_info = self.server_sock.accept()
            print "Verbindung mit", self.client_info
            self.handle()
        
        
    def handle(self):
        
        StreamOffen = True
        while StreamOffen:
            data = self.client_sock.recv(1024)
            if data == "":
                StreamOffen = False
                
            print data
        
        print"Verbindung  mit ", self.client_info, "beendet" 
        self.client_sock.close()    
      
      
q1 = Queue.Queue()
q2 = Queue.Queue()

server = MyBTServer(None, q1, q2)