#!/usr/bin/env python
import asyncore
import socket
import struct
import time
import hashlib
class WebSocketConnection(asyncore.dispatcher_with_send):
def __init__(self, conn, server):
asyncore.dispatcher_with_send.__init__(self, conn)
self.server = server
self.server.sessions.append(self)
self.readystate = "connecting"
self.buffer = ""
def handle_read(self):
data = self.recv(1024)
self.buffer += data
if self.readystate == "connecting":
self.parse_connecting()
elif self.readystate == "open":
self.parse_frametype()
def handle_close(self):
self.server.sessions.remove(self)
self.close()
def parse_connecting(self):
header_end = self.buffer.find("\r\n\r\n")
if header_end == -1:
return
else:
header = self.buffer[:header_end]
# remove header and four bytes of line endings from buffer
self.buffer = self.buffer[header_end+4:]
header_lines = header.split("\r\n")
headers = {}
# validate HTTP request and construct location
method, path, protocol = header_lines[0].split(" ")
if method != "GET" or protocol != "HTTP/1.1" or path[0] != "/":
self.terminate()
return
# parse headers
for line in header_lines[1:]:
key, value = line.split(": ")
headers[key] = value
headers["Location"] = "ws://" + headers["Host"] + path
self.readystate = "open"
self.handler = self.server.handlers.get(path, None)(self)
if "Sec-WebSocket-Key1" in headers.keys():
self.send_server_handshake_76(headers)
else:
self.send_server_handshake_75(headers)
def terminate(self):
self.ready_state = "closed"
self.close()
def send_server_handshake_76(self, headers):
"""
Send the WebSocket Protocol v.76 handshake response
"""
key1 = headers["Sec-WebSocket-Key1"]
key2 = headers["Sec-WebSocket-Key2"]
# read additional 8 bytes from buffer
key3, self.buffer = self.buffer[:8], self.buffer[8:]
response_token = self.calculate_key(key1, key2, key3)
# write out response headers
self.send_bytes("HTTP/1.1 101 Web Socket Protocol Handshake\r\n")
self.send_bytes("Upgrade: WebSocket\r\n")
self.send_bytes("Connection: Upgrade\r\n")
self.send_bytes("Sec-WebSocket-Origin: %s\r\n" % headers["Origin"])
self.send_bytes("Sec-WebSocket-Location: %s\r\n" % headers["Location"])
if "Sec-WebSocket-Protocol" in headers:
protocol = headers["Sec-WebSocket-Protocol"]
self.send_bytes("Sec-WebSocket-Protocol: %s\r\n" % protocol)
self.send_bytes("\r\n")
# write out hashed response token
self.send_bytes(response_token)
def calculate_key(self, key1, key2, key3):
# parse keys 1 and 2 by extracting numerical characters
num1 = int("".join([digit for digit in list(key1) if digit.isdigit()]))
spaces1 = len([char for char in list(key1) if char == " "])
num2 = int("".join([digit for digit in list(key2) if digit.isdigit()]))
spaces2 = len([char for char in list(key2) if char == " "])
combined = struct.pack(">II", num1/spaces1, num2/spaces2) + key3
# md5 sum the combined bytes
return hashlib.md5(combined).digest()
def send_server_handshake_75(self, headers):
"""
Send the WebSocket Protocol v.75 handshake response
"""
self.send_bytes("HTTP/1.1 101 Web Socket Protocol Handshake\r\n")
self.send_bytes("Upgrade: WebSocket\r\n")
self.send_bytes("Connection: Upgrade\r\n")
self.send_bytes("WebSocket-Origin: %s\r\n" % headers["Origin"])
self.send_bytes("WebSocket-Location: %s\r\n" % headers["Location"])
if "Protocol" in headers:
self.send_bytes("WebSocket-Protocol: %s\r\n" % headers["Protocol"])
self.send_bytes("\r\n")
def parse_frametype(self):
while len(self.buffer):
type_byte = self.buffer[0]
if type_byte == "\x00":
if not self.parse_textframe():
return
def parse_textframe(self):
terminator_index = self.buffer.find("\xFF")
if terminator_index != -1:
frame = self.buffer[1:terminator_index]
self.buffer = self.buffer[terminator_index+1:]
s = frame.decode("UTF8")
self.handler.dispatch(s)
return True
else:
# incomplete frame
return false
def send(self, s):
if self.readystate == "open":
self.send_bytes("\x00")
self.send_bytes(s.encode("UTF8"))
self.send_bytes("\xFF")
def send_bytes(self, bytes):
asyncore.dispatcher_with_send.send(self, bytes)
class EchoHandler(object):
"""
The EchoHandler repeats each incoming string to the same Web Socket.
"""
def __init__(self, conn):
self.conn = conn
def dispatch(self, data):
self.conn.send("echo: " + data)
class WebSocketServer(asyncore.dispatcher):
def __init__(self, port=80, handlers=None):
asyncore.dispatcher.__init__(self)
self.handlers = handlers
self.sessions = []
self.port = port
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
self.set_reuse_addr()
self.bind(("", port))
self.listen(5)
def handle_accept(self):
conn, addr = self.accept()
session = WebSocketConnection(conn, self)
if __name__ == "__main__":
print "Starting WebSocket Server"
WebSocketServer(port=8080, handlers={"/echo": EchoHandler})
asyncore.loop()
没有合适的资源?快使用搜索试试~ 我知道了~
HTML5高级程序设计-配套源码
共92个文件
html:52个
css:12个
js:6个
需积分: 10 10 下载量 67 浏览量
2012-05-23
11:21:39
上传
评论
收藏 34.45MB RAR 举报
温馨提示
今天,大多数现代浏览器都已经支持HTML5。学习体验HTML5带给Web开发的便捷、快速和强大功能,是每一位Web设计和开发人员的当务之急。这个是《HTML5高级程序设计》配套的源代码,
资源推荐
资源详情
资源评论
收起资源包目录
HTML5高级程序设计-CODE.rar (92个子文件)
geolocation
styles.css 4KB
odometer.html 4KB
status-info.png 1KB
geolocation.html 2KB
canvas
trails-strokeStyle.html 1KB
trails-gradient.html 3KB
trails-pattern.html 3KB
styles.css 4KB
trails-fillStyle.html 1KB
mapbg.jpg 5KB
trails-final.html 3KB
trails-text.html 4KB
trails-diagonal.html 727B
trails-diagonalTranslate.html 921B
trails-transform.html 4KB
trails-shadow.html 4KB
gravel.jpg 4KB
trails-closedPath.html 1KB
bark.jpg 25KB
trails-fillRect.html 2KB
heatmap.html 2KB
trails-scaling.html 3KB
trails-image.html 2KB
trails-curve.html 2KB
websocket
styles.css 5KB
websocket.py 6KB
broadcast.html 1KB
websocket.html 961B
tracker.html 4KB
broadcast.py 550B
start-server.sh 87B
workers
styles.css 4KB
blur.js 1KB
blurWorker.js 1KB
example2.png 523KB
echoWorker.js 137B
example.png 37KB
blur.html 4KB
echo.html 1KB
start-server.sh 87B
offline
offline.js 2KB
tracker.html 579B
tracker.manifest 119B
log.js 210B
html5.css 2KB
style.css 154B
tracker.js 1KB
communication
crossOriginUpload.html 3KB
styles.css 4KB
postMessagePortal.html 2KB
start-server.sh 87B
CORSServer.py 1KB
postMessageWidget.html 1KB
storage
browser-test.html 1KB
index.html 5KB
styles.css 4KB
happy-trails-rc.gif 6KB
about.html 6KB
testQuota.html 10KB
storageLog.html 721B
storageInsert.html 544B
signup.html 5KB
lake-tahoe.JPG 16KB
sql.html 2KB
racerBroadcast.html 3KB
html5.css 2KB
session.html 569B
start-server.sh 90B
av
mouseoverVideo.html 485B
styles.css 4KB
arrp.wav 2KB
Intermission-Walk-in.ogv 15.73MB
johann_sebastian_bach_air.ogg 2.13MB
videoTimeline.html 4KB
Intermission-Walk-in_512kb.mp4 13.56MB
audio_simple.html 227B
audio_multisource.html 291B
audio_type.html 341B
audio.html 381B
audio_no_control.html 341B
audioCue.html 715B
johann_sebastian_bach_air.mp3 2.8MB
backgroundMusic.html 297B
intro
sample.html 2KB
html5.css 2KB
querySelector.html 1KB
querySelectorAll.html 2KB
forms
passwordMatch.html 2KB
happy-trails-rc.gif 6KB
signup.html 5KB
patternList.html 2KB
html5.css 2KB
共 92 条
- 1
资源评论
jtxlive
- 粉丝: 2
- 资源: 7
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功