Code: Alles auswählen
import SocketServer, socket, BaseHTTPServer, os
def cacheFile(datei):
return open(datei, 'rb').read()
_bild = cacheFile('%s/htdocs/wow.jpg' % os.getcwd())
_html = '''<html>
<head>
<link rel="stylesheet" href="style/style.css" type="text/css" />
</head>
<body>
<img src="/wow.jpg" alt="Europa-Release" title="Europa-Release" align="absmiddle" />
<p>Hello World!</p>
</body>
</html>'''
_css = 'body {font-family:arial,sans-serif; background-color: #000000; color: #FFFFFF}'
class MyRequestHandler(BaseHTTPServer.BaseHTTPRequestHandler):
protocol_version = 'HTTP/1.1'
def do_GET(self):
print 'neuer thread'
if self.path == '/dev':
self.send_stream(_html, 'text/html', 200, 'Keep-Alive')
self.send_stream(_css, 'text/css', 200, 'Keep-Alive')
self.send_stream(_bild, 'image/jpeg', 200, 'close')
elif self.path == '/style/style.css':
#self.send_stream(_css, 'text/css', 200, 'close')
#print 'style.css'
pass
elif self.path == '/wow.jpg':
#self.send_stream(_bild, 'image/jpeg', 200, 'close')
#print 'wow.jpg'
pass
else:
self.send_stream('Error 404 - File not found!', 'text/html', 404)
#def handle(self):
# print 'handle do it'
# print self.protocol_version
# self.send_stream(_html, 'text/html', 200)
def send_stream(self, stream, mimetype, code, connection):
self.send_response(code)
self.send_header('Content-type', mimetype)
self.send_header('Content-Length', str(len(stream)))
self.send_header('Connection', connection)
self.end_headers()
self.wfile.write(stream)
self.wfile.flush()
def send_text(self, text, mimetype='text/html', code=200):
self.send_response(code)
self.send_header('Content-type', mimetype)
self.send_header('Content-Length', str(len(text)))
self.end_headers()
self.wfile.write(text)
self.wfile.flush()
class MyThreadingServer(SocketServer.ThreadingTCPServer):
def __init__(self, server_address, request_handler, AllowIPs):
SocketServer.ThreadingTCPServer.__init__(self, server_address, request_handler)
self.AllowIPs = [mask.split('.') for mask in AllowIPs]
def server_bind(self):
SocketServer.ThreadingTCPServer.server_bind(self)
host, self.server_port = self.socket.getsockname()[:2]
self.server_name = socket.getfqdn(host)
def verify_request(self, dummy, client_address):
def check_ip(mask):
for mask_part, ip_part in zip(mask, ip):
if mask_part != ip_part and mask_part != '*':
return False
return True
ip = client_address[0].split('.')
for mask in self.AllowIPs:
if check_ip(mask):
return True
print "IP [%s] not allowed!" % client_address
return False
def ServerStart(ListenPort, AllowIPs):
print "Starte HTTP-Server auf Port .:", ListenPort
print "Zugelassener IP-Bereich .....:", AllowIPs
httpd = MyThreadingServer(("", ListenPort), MyRequestHandler, AllowIPs)
httpd.serve_forever()
if __name__=="__main__":
ServerStart(ListenPort=6667, AllowIPs=('*.*.*.*'))
leider funktioniert es nicht wirklich, habe mir bissel im netz bezüglich Connection: keel-alive durchgelesen (http://www.http.header.free.fr/http.html) und das schheint richtig zu sein, nur scheint es dem BaseHTTP handler nicht zu interessieren, und die methode handle() verstehe ich nicht wirklich also wie ich die benutzen soll...
