html5与python的websocket会话

找到了一个早期的版本,配置是python2.x,websocket 6 or 7。版本已经很早了,websocket协议已经有了大的更新,版本已经更迭到了13,同时python本人已经在用python 3k了,因此造成网上的代码无法运行,经过一天的晚上,已经可以运行。代码附上。

服务端(Python)

#coding=utf8
#!/usr/bin/python

import struct,socket,sys
import hashlib
import threading,random
import time
from base64 import b64encode, b64decode

connectionlist = {}

#python3k 版本recv返回字节数组
def decode(data):
    if not len(data):
        return False
    length = data[1] & 127
    if length == 126:
        mask = data[4:8]
        raw = data[8:]
    elif length == 127:
        mask = data[10:14]
        raw = data[14:]
    else:
        mask = data[2:6]
        raw = data[6:]
    ret = ‘‘
    for cnt, d in enumerate(raw):
        ret += chr(d ^ mask[cnt%4])
    return ret

def encode(data):
    data=str.encode(data)
    head = b‘\x81‘

    if len(data) < 126:
        head += struct.pack(‘B‘, len(data))
    elif len(data) <= 0xFFFF:
        head += struct.pack(‘!BH‘, 126, len(data))
    else:
        head += struct.pack(‘!BQ‘, 127, len(data))
    return head+data

def sendMessage(message):
    global connectionlist
    for connection in connectionlist.values():
        connection.send(encode(message))

def deleteconnection(item):
    global connectionlist
    del connectionlist[‘connection‘+item]

class WebSocket(threading.Thread):

    GUID = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"

    def __init__(self,conn,index,name,remote, path="/"):
        threading.Thread.__init__(self)
        self.conn = conn
        self.index = index
        self.name = name
        self.remote = remote
        self.path = path
        self.buffer = ""
    def run(self):
        print(‘Socket%s Start!‘ % self.index)
        headers = {}
        self.handshaken = False

        while True:
            if self.handshaken == False:
                print (‘Socket%s Start Handshaken with %s!‘ % (self.index,self.remote))
                self.buffer += bytes.decode(self.conn.recv(1024))

                if self.buffer.find(‘\r\n\r\n‘) != -1:
                    header, data = self.buffer.split(‘\r\n\r\n‘, 1)
                    for line in header.split("\r\n")[1:]:
                        key, value = line.split(": ", 1)
                        headers[key] = value

                    headers["Location"] = ("ws://%s%s" %(headers["Host"], self.path))
                    key = headers[‘Sec-WebSocket-Key‘]
                    token = b64encode(hashlib.sha1(str.encode(str(key + self.GUID))).digest())

                    handshake="HTTP/1.1 101 Switching Protocols\r\n"                        "Upgrade: websocket\r\n"                        "Connection: Upgrade\r\n"                        "Sec-WebSocket-Accept: "+bytes.decode(token)+"\r\n"                        "WebSocket-Origin: "+str(headers["Origin"])+"\r\n"                        "WebSocket-Location: "+str(headers["Location"])+"\r\n\r\n"

                    self.conn.send(str.encode(str(handshake)))
                    self.handshaken = True
                    print (‘Socket%s Handshaken with %s success!‘ %(self.index, self.remote))
                    sendMessage(‘Welcome, ‘ + self.name + ‘ !‘)  

            else:
                msg=decode(self.conn.recv(1024))
                if msg==‘quit‘:
                    print (‘Socket%s Logout!‘ % (self.index))
                    nowTime = time.strftime(‘%H:%M:%S‘,time.localtime(time.time()))
                    sendMessage(‘%s %s say: %s‘ % (nowTime, self.remote, self.name+‘ Logout‘))
                    deleteconnection(str(self.index))
                    self.conn.close()
                    break
                else:
                    print (‘Socket%s Got msg:%s from %s!‘ % (self.index, msg, self.remote))
                    nowTime = time.strftime(‘%H:%M:%S‘,time.localtime(time.time()))
                    sendMessage(‘%s %s say: %s‘ % (nowTime, self.remote, msg))       

            self.buffer = ""

class WebSocketServer(object):
    def __init__(self):
        self.socket = None
    def begin(self):
        print( ‘WebSocketServer Start!‘)
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.bind(("127.0.0.1",12345))
        self.socket.listen(50)

        global connectionlist

        i=0
        while True:
            connection, address = self.socket.accept()

            username=address[0]
            newSocket = WebSocket(connection,i,username,address)
            newSocket.start()
            connectionlist[‘connection‘+str(i)]=connection
            i = i + 1

if __name__ == "__main__":
    server = WebSocketServer()
    server.begin()

客户端(Html5+JS)

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket</title>

    <style>
        html, body {
            font: normal 0.9em arial, helvetica;
        }

        #log {
            width: 440px;
            height: 200px;
            border: 1px solid #7F9DB9;
            overflow: auto;
        }

        #msg {
            width: 330px;
        }
    </style>

    <script>
        var socket;

        function init() {
            var host = "ws://127.0.0.1:12345/";
            try {
                socket = new WebSocket(host);
                socket.onopen = function (msg) {
                    log("Begin Connection!");
                };
                socket.onmessage = function (msg) {
                    log(msg.data);
                };
                socket.onclose = function (msg) {
                    log("Lose Connection!");
                };
            }
            catch (ex) {
                log(ex);
            }
            $("msg").focus();
        }

        function send() {
            var txt, msg;
            txt = $("msg");
            msg = txt.value;
            if (!msg) {
                alert("Message can not be empty");
                return;
            }
            txt.value = "";
            txt.focus();
            try {
                socket.send(msg);
            } catch (ex) {
                log(ex);
            }
        }

        window.onbeforeunload = function () {
            try {
                socket.send(‘quit‘);
                socket.close();
                socket = null;
            }
            catch (ex) {
                log(ex);
            }
        };

        function $(id) {
            return document.getElementById(id);
        }
        function log(msg) {
            $("log").innerHTML += "<br>" + msg;
        }
        function onkey(event) {
            if (event.keyCode == 13) {
                send();
            }
        }
    </script>

</head>

<body onload="init()">
<h3>WebSocket</h3>
<br><br>

<div id="log"></div>
<input id="msg" type="textbox" onkeypress="onkey(event)"/>
<button onclick="send()">发送</button>
</body>

</html>

Html5+JS代码还存在一个问题,发送中文会出现乱码,原因应该为websocket.send的默认解码问题。

时间: 2024-11-13 04:45:00

html5与python的websocket会话的相关文章

基于html5 localStorage , web SQL, websocket的简单聊天程序

new function() { var ws = null; var connected = false; var serverUrl; var connectionStatus; var sendMessage; var connectButton; var disconnectButton; var sendButton; var open = function() { var url = serverUrl.val(); ws = new WebSocket(url); ws.onope

[Python]通过websocket与js客户端通信

网站大多使用HTTP协议通信,而HTTP是无连接的协议.只有客户端请求时,服务器端才能发出相应的应答,HTTP请求的包也比较大,如果只是很小的数据通信,开销过大.于是,我们可以使用websocket这个协议,用最小的开销实现面向连接的通信. 具体的websocket介绍可见http://zh.wikipedia.org/wiki/WebSocket 这里,介绍如何使用Python与前端js进行通信. websocket使用HTTP协议完成握手之后,不通过HTTP直接进行websocket通信.

HTML5新特性之WebSocket

一.WebSocket简介: 谈到Web实时推送,就不得不说WebSocket.在WebSocket出现之前,很多网站为了实现实时推送技术,通常采用的方案 是轮询(Polling)和Comet技术,Comet又可细分为两种实现方式,一种是长轮询机制,一种称为流技术,这两种方式实际上是对 轮询技术的改进,这些方案带来很明显的缺点,需要由浏览器对服务器发出HTTP request,大量消耗服务器带宽和资源.面对 这种状况,HTML5定义了WebSocket协议,能更好的节省服务器资源和带宽并实现真正

HTML5开发之旅WebSocket添加事件监听器(6)

WebSocket编程遵循异步编程模型;打开socket后,只需要等待事件发生,而不需要主动向服务器轮询,所以需要在WebSocket对象中添加回调函数来监听事件. WebSocket对象有三个事件:open,close和message.当连接建立时触发open事件,当收到消息时触发message事件,当 WebSocket连接关闭时触发close事件.同大多数Javascript API一样,事件处理时会调用相应的(onopen, onmessage, 和onclose)回调函数. 1 w.o

HTML5开发之旅WebSocket对象的创建及其与WebSocket服务器的连接(5)

WebSocket接口的使用非常简单,要连接通信端点,只需要创建一个新的WebSocket实例,并提供希望连接URL. 1 //ws://和wss://前缀分别表示WebSocket连接和安全的WebSocket连接. 2 url = "ws://localhost:8080/echo";//表示WebSocket连接 3 var w = new WebSocket(url);//创建一个新的WebSocket实例,并提供希望连接URL. HTML5开发之旅WebSocket对象的创建

python 实现websocket

python中websocket需要我们自己实现握手代码,流程是这样:服务端启动websocket服务,并监听.当客户端连接过来时,(需要我们自己实现)服务端就接收客户端的请求数据,拿到请求头,根据请求头信息封装响应头,并将响应头发给前端,这样就完成了一次握手,接下来服务端和客户端才可以通信. 上代码,我的代码只涉及到服务端发消息给客户端的情况 先说一下代码涉及到的知识 1.单例模式 2.多线程 3.redis 4.websokcet 5.在docker容器中运行 #!/usr/bin pyth

python之websocket

一.websocket WebSocket协议是基于TCP的一种新的协议.WebSocket最初在HTML5规范中被引用为TCP连接,作为基于TCP的套接字API的占位符.它实现了浏览器与服务器全双工(full-duplex)通信.其本质是保持TCP连接,在浏览器和服务端通过Socket进行通信. 本文将使用Python编写Socket服务端,一步一步分析请求过程!!! 1. 启动服务端 import socket sock = socket.socket(socket.AF_INET, soc

python模拟websocket握手过程中计算sec-websocket-accept

背景 以前,很多网站使用轮询实现推送技术.轮询是在特定的的时间间隔(比如1秒),由浏览器对服务器发出HTTP request,然后由服务器返回最新的数据给浏览器.轮询的缺点很明显,浏览器需要不断的向服务器发出请求,然而HTTP请求的header是非常长 的,而实际传输的数据可能很小,这就造成了带宽和服务器资源的浪费. Comet使用了AJAX改进了轮询,可以实现双向通信.但是Comet依然需要发出请求,而且在Comet中,普遍采用了长链接,这也会大量消耗服务器带宽和资源. 于是,WebSocke

[Python]通过websocket与jsclient通信

站点大多使用HTTP协议通信.而HTTP是无连接的协议.仅仅有client请求时,server端才干发出对应的应答.HTTP请求的包也比較大,假设仅仅是非常小的数据通信.开销过大.于是,我们能够使用websocket这个协议,用最小的开销实现面向连接的通信. 详细的websocket介绍可见http://zh.wikipedia.org/wiki/WebSocket 这里,介绍怎样使用Python与前端js进行通信. websocket使用HTTP协议完毕握手之后,不通过HTTP直接进行webs