Code: Alles auswählen
import os, sys
def main():
pass # hier ist das Hauptprogramm
tmplockname = "C:\\tmp\testprog.lock"
if os.path.exists(tmplockname):
print "Testprog läuft schon"
sys.exit()
f = file(tmplockname,'w')
f.write(" ")
f.close()
main()
os.remove(tmplockname)
Code: Alles auswählen
try:
HOST = '' # Symbolic name meaning the local host
PORT = 1234567890 # Arbitrary non-privileged port
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
except:
sys.exit()
Code: Alles auswählen
# -*- coding: iso-8859-1 -*-
import socket
import sys
def DoConnect():
try:
HOST = '' # Symbolic name meaning the local host
PORT = 65007 # Arbitrary non-privileged port
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
except:
sys.exit()
Code: Alles auswählen
# -*- coding: iso-8859-1 -*-
import socket
import sys
_sock=[None]
def DoConnect():
try:
HOST = '' # Symbolic name meaning the local host
PORT = 65007 # Arbitrary non-privileged port
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
_sock[0]=s
except:
sys.exit()
Dazu ist es unter anderem ganz nützlich, dass du den Socket noch weiter speicherst. So kannst du Daten darüber empfangen. Hier mal ein längeres Codebeispiel, was dein Modul schon mal in die Richtung ausbaut:HarryH hat geschrieben:Jetzt muss ich es nur noch schaffen in dem Hauptprogramm eine Funktion aufzurufen. Könntest du mir dabei bitte auch einen Lösungsansatz schenken?
Code: Alles auswählen
# -*- coding: UTF-8 -*-
import socket
import sys
import threading
_sock=[None]
HOST = 'localhost'
PORT = 65007
class Miniserver(threading.Thread):
def __init__(self,sock):
threading.Thread.__init__(self)
self.s=sock
def run(self):
while 1: # Empfange Anfragen vom 2. Programm
conn, addr = self.s.accept()
print 'Connected by', addr
while 1:
data = conn.recv(1024)
if not data: break
conn.close()
Funktion(data)
def Funktion(text):
print "Habe Nachricht empfangen: %s"%text
def DoConnect():
try:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
_sock[0]=s
serv=Miniserver(s)
serv.start()
print "Server gestartet"
except: #Hauptprogramm existiert, verbinde mit Programm
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.send('Hello, world')
s.close()
print "Funktion gestartet, beende mich..."
if __name__=="__main__":
DoConnect()Code: Alles auswählen
class Miniserver(threading.Thread):
def __init__(self,sock):
threading.Thread.__init__(self)
self.s=sock
def run(self):
while 1: # Empfange Anfragen vom 2. Programm
conn, addr = self.s.accept()
print 'Connected by', addr
while 1:
data = conn.recv(1024)
if not data: break
conn.close()
if data == "zu Ende" and self.quit:
break
Funktion(data)Code: Alles auswählen
# -*- coding: iso-8859-1 -*-
import socket
import sys
import threading
#Socketspeicher
_sock=[None]
#Verbinden
def DoConnect(text="END", funktion=None, parameter=None):
HOST = "localhost"
PORT = 65012
try:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
_sock[0] = s
serv = Miniserver(s, funktion, parameter)
serv.start()
print "Server gestartet"
except:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.send(text)
s.close()
return "CLOSE"
#Server
class Miniserver(threading.Thread):
def __init__(self, sock, funktion, parameter):
threading.Thread.__init__(self)
self.s = sock
self.funktion = funktion
self.parameter = parameter
def run(self):
while 1:
conn, addr = self.s.accept()
data = conn.recv(1024)
conn.close()
if data == "END":
print "Server beendet"
break
print "Server hat folgendes Signal erhalten: %s"%data
if self.funktion:
self.funktion(self.parameter)
print "Übergebene Funktion wurde gestartet"
if __name__=="__main__":
DoConnect()
Code: Alles auswählen
# -*- coding: iso-8859-1 -*-
import socket
import sys
import threading
#Socket- und Portspeicher
_sock=[None]
_port=[None]
#Verbinden
def DoConnect(progName, funktion=None, parameter=None):
if not progName or type(progName) != str:
raise ValueError, 'Value must be a string and may be not empty'
HOST = socket.getfqdn()
for newport in xrange(65000, 65536):
if not _port[0]:
port = newport
else:
port = _port[0]
try:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, port))
s.listen(1)
_sock[0] = s
_port[0] = port
serv = Miniserver(s, progName, port, funktion, parameter)
serv.start()
print "Port %s gestartet"% port
break
except:
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, port))
s.send(progName)
data=s.recv(1024)
s.close()
if data != progName and progName != "!%END%!":
continue
else:
return "LOCK"
#Verbindung trennen
def DoDisconnect():
DoConnect("!%END%!")
#Server
class Miniserver(threading.Thread):
def __init__(self, sock, progName, port, funktion, parameter):
threading.Thread.__init__(self)
self.s = sock
self.progName= progName
self.port= port
self.funktion = funktion
self.parameter = parameter
def run(self):
while 1:
client, addr = self.s.accept()
port = client.getsockname()[1]
client.send(self.progName)
progName = client.recv(1024)
client.close()
if self.port == port and self.progName != progName and progName != "!%END%!":
continue
if self.port == port and progName == "!%END%!":
print "Port %s beendet"% port
break
if self.port == port and self.funktion:
self.funktion(self.parameter)
print "Übergebene Funktion des Ports %s wurde gestartet"% port
if __name__=="__main__":
pass