websocekt-python與Js互動（2）

阿新 • • 發佈：2019-01-19

# -*- coding:utf8 -*-
import threading
import hashlib
import socket
import base64


class websocket_thread(threading.Thread):
    def __init__(self, connection):
        super(websocket_thread, self).__init__()
        self.connection = connection

    def run(self):
        print 'new websocket client joined!'
 
reply = 'i got u, from websocket server.'
length = len(reply)
        while True:
            data = self.connection.recv(1024)
            print parse_data(data)
            self.connection.send('%c%c%s' % (0x81, length, reply))


def parse_data(msg):
    v = ord(msg[1]) & 0x7f
if v == 0x7e:
        p = 4
 
elif v == 0x7f:
        p = 10
else:
        p = 2
mask = msg[p:p + 4]
    data = msg[p + 4:]

    return ''.join([chr(ord(v) ^ ord(mask[k % 4])) for k, v in enumerate(data)])


def parse_headers(msg):
    headers = {}
    header, data = msg.split('\r\n\r\n', 1)
    for line in header.split('\r\n')[1:]:
        key,  
value = line.split(': ', 1)
        headers[key] = value
    headers['data'] = data
    return headers


def generate_token(msg):
    key = msg + '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'
ser_key = hashlib.sha1(key).digest()
    return base64.b64encode(ser_key)


if __name__ == '__main__':
    #socket(family,type[,protocal]) 使用給定的地址族、套接字型別、協議編號（預設為0）來建立套接字。
'''
    socket.AF_UNIX  只能夠用於單一的Unix系統程序間通訊
    socket.AF_INET  伺服器之間網路通訊
    socket.AF_INET6 IPv6
    socket.SOCK_STREAM  流式socket , for TCP
    socket.SOCK_DGRAM   資料報式socket , for UDP
    建立TCP Socket：s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
    建立UDP Socket：s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
    '''
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    #s.setsockopt(level,optname,value) 設定給定套接字選項的值。
    #開啟或關閉地址複用功能。當option_value不等於0時，開啟，否則，關閉。它實際所做的工作是置sock->sk->sk_reuse為1或0。
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    sock.bind(('127.0.0.1', 9000))
    sock.listen(5)
    #首先，我們建立了一個套接字，然後讓套接字開始監聽介面，並且最多隻能監聽5個請求
    while True:
        connection, address = sock.accept()

#接受監聽到的連線請求，
        print address
        try:
            data = connection.recv(1024)
            headers = parse_headers(data)
            token = generate_token(headers['Sec-WebSocket-Key'])
            connection.send('\
HTTP/1.1 101 WebSocket Protocol Hybi-10\r\n\
Upgrade: WebSocket\r\n\
Connection: Upgrade\r\n\
Sec-WebSocket-Accept: %s\r\n\r\n' % (token))
            thread = websocket_thread(connection)
            thread.start()
        except socket.timeout:
            print 'websocket connection timeout'

<!--
@http://www.cnblogs.com/zhuweisky/p/3930780.html
-->
<!DOCTYPE html>
</html>
    <head>
        <meta charset="utf-8">
    </head>
    <body>
        <h3>WebSocketTest</h3>
        <div id="login">
            <div>
                <input id="serverIP" type="text" placeholder="伺服器IP" value="127.0.0.1" autofocus="autofocus" />
                <input id="serverPort" type="text" placeholder="伺服器埠" value="9000" />
                <input id="btnConnect" type="button" value="連線" onclick="connect()" />
            </div>
            <div>
                <input id="sendText" type="text" placeholder="傳送文字" value="I'm WebSocket Client!" />
                <input id="btnSend" type="button" value="傳送" onclick="send()" />
            </div>
            <div>
                <div>
來自服務端的訊息
                </div>
                <textarea id="txtContent" cols="50" rows="10" readonly="readonly"></textarea>
            </div>
        </div>
    </body>
    <script>
var socket;
function connect() {
            var host = "ws://" + $("serverIP").value + ":" + $("serverPort").value + "/"
socket = new WebSocket(host);
try {

                socket.onopen = function (msg) {
                    $("btnConnect").disabled = true;
alert("連線成功！");
};
socket.onmessage = function (msg) {
                    if (typeof msg.data == "string") {
                        displayContent(msg.data);
}
                    else {
                        alert("非文字訊息");
}
                };
socket.onclose = function (msg) { alert("socket closed!") };
}
            catch (ex) {
                log(ex);
}
        }

        function send() {
            var msg = $("sendText").value
socket.send(msg);
}

        window.onbeforeunload = function () {
            try {
                socket.close();
socket = null;
}
            catch (ex) {
            }
        };
function $(id) { return document.getElementById(id); }

        Date.prototype.Format = function (fmt) { //author: meizz
var o = {
                "M+": this.getMonth() + 1, //月份
"d+": this.getDate(), //日
"h+": this.getHours(), //小時
"m+": this.getMinutes(), //分
"s+": this.getSeconds(), //秒
"q+": Math.floor((this.getMonth() + 3) / 3), //季度
"S": this.getMilliseconds() //毫秒
};
if (/(y+)/.test(fmt)) fmt = fmt.replace(RegExp.$1, (this.getFullYear() + "").substr(4 - RegExp.$1.length));
for (var k in o)
                if (new RegExp("(" + k + ")").test(fmt)) fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ? (o[k]) : (("00" + o[k]).substr(("" + o[k]).length)));
return fmt;
}

        function displayContent(msg) {
            $("txtContent").value += "\r\n" +new Date().Format("yyyy/MM/dd hh:mm:ss")+ ":  " + msg;
}
        function onkey(event) { if (event.keyCode == 13) { send(); } }
    </script>
</html>

websocekt-python與Js互動（2）

# -*- coding:utf8 -*- import threading import hashlib import socket import base64 class websocket_thread(threading.Thread): def __i

Android與js互動（四）自定義cordova外掛

首先昨天我做測試的時候js端一直無法呼叫寫在js的方法後來查了資料才知道是在index.html中使用js時需要刪除這一行 <meta http-equiv="Content-Security-Policy" content="default-src 'self'

程序與執行緒（2）- python實現多程序

python 實現多程序參考連結： https://morvanzhou.github.io/tutorials/python-basic/multiprocessing/ python中實現多程序的模組：multiprocessing 注意：在windows系統下

python數字影象處理（2）：影象的讀取、顯示與儲存

skimage提供了io模組，顧名思義，這個模組是用來圖片輸入輸出操作的。為了方便練習，也提供一個data模組，裡面嵌套了一些示例圖片，我們可以直接使用。引入skimage模組可用： 1 from skimage import io

Struts2框架與頁面的資料互動（2）--OGNL表示式&ValueStack

3、Struts2框架與頁面的資料互動（2）--OGNL表示式&ValueStack 上接Struts2礦街與頁面的資料互動（1）--資料封裝：https://blog.csdn.net/biggerchong/article/details/84564912 目錄

四十八、mysql資料庫7：Mysql與python的互動、引數化（重點python與mysql互動傳參）

一、使用python命令連線資料庫流程二、python3 安裝pymysql包建立py檔案，進行插入資料：通過python檔案來連線資料庫實現互動（前提需要安裝pymysql包） 1、Li

Python 影象處理 OpenCV （2）：畫素處理與 Numpy 操作以及 Matplotlib 顯示影象

![](https://cdn.geekdigging.com/opencv/opencv_header.png) 前文傳送門： [「Python 影象處理 OpenCV （1）：入門」](https://www.geekdigging.com/2020/05/17/5513454552/) ## 普通

python--DenyHttp項目（2）--ACM監考客戶端測試版（1階段完成總結）

tdi text class 測試版 window etl operate comm decode 　　客戶端： ‘‘‘ DenyManager.py 調用客戶端與客戶端界面 ‘‘‘ from DenyClient import * from DenyGui import

我的第一個python web開發框架（2）——一個簡單的小外包

span 技術進行 target 最好自己 blog height 描述　　第一部分說明　　第一部分大概有20來章，主要講的是一些開發常識、開發前中後期準備內容、開發環境與服務器部署環境安裝設置、python基礎框架結構與功能等內容，代碼會比較簡單。　　

Python叠代器（2） —— 實現for循環

auth style code true next() logs div nbsp while Python的for循環本質上就是通過不斷調用next()函數實現的，例如： 1 #_*_coding:utf-8_*_ 2 #__author__ = "csy" 3

C++類與對象（2）——類的組合

hang 執行 .get 自動賦值 rec 自定義類類的定義對象當我們創建一個類時，我們總是習慣用C++的基本數據類型作為類的組成部件。但實際上類的成員數據既可以是基本類型也可以是自定義類型，當然也可以是類的對象。這就是類的組合，它描述的就是一個類內嵌其他類的對象作

caffe的python接口學習（2）生成solver文件

慢慢 oot __name__ nap gpu 計算 snapshot pro copy caffe在訓練的時候，需要一些參數設置，我們一般將這些參數設置在一個叫solver.prototxt的文件裏面有一些參數需要計算的，也不是亂設置。假設我們有50000個訓練樣本

Python學習之路（2）——Python種類介紹

VM 種類廣泛分享 java字節碼流程字節碼基礎上 python Python的種類 Cpython Python的官方版本，使用C語言實現，使用最為廣泛，CPython實現會將源文件（py文件）轉換成字節碼文件（pyc文件），然後運行在Python虛擬

python圖像處理（2）圖像水印和PIL模式轉化

tex 我們參考 height rom 設置分享 show pen 模式轉化： PIL模式轉化：將圖片轉化成其他模式 1 # 我們將image圖像轉化為灰度圖像（python） 2 from PIL import Image 3 img = Image.open

appium+python的APP自動化（2）

.exe path 輸入地址 cat 打開 installer tor sof 上節說到安卓上的測試環境都安裝好了，這個時候要安裝python了 1python的安裝 https://www.python.org/15官網下載python2.7(3.0以上也行，個人愛好)

爬蟲開發python工具包介紹（2）

dir 部分 loop 網易 pat 選擇服務器 mode follow 本文來自網易雲社區作者：王濤可選參數我們一一介紹一下：參數釋義示例params生成url中?號後面的查詢Key=value示例1： >>>payload = {‘key1‘: ‘v

python與zmq系列（5）

我們已經瞭解REQ/REP,PUB/SUB,PULL/PUSH這三種模式，也曾提到過，一個上下文可以建立多個socket套接字，那麼如何管理這些套接字呢？假設我們的一個客戶端既有pull又有sub，他們兩個都需要接收訊息，該如何協調呢，畢竟，當一個

python與zmq系列（4）

今天為大家介紹push/pull模式，這是一個什麼模式呢？戰爭時期，食物緊缺，實行配給制，大家都排好隊，有人專門發放食物，前一個人領取了食物，後一個人跟上繼續領取食物，這個push端就是發放食物的，pull

python與zmq系列（3）

本篇部落格將介紹zmq應答模式，所謂應答模式，就是一問一答，規則有這麼幾條 1、必須先提問，後回答 2、對於一個提問，只能回答一次

vue 元件與通訊與vuex與computed與生命週期（2）

二：vuex 先看官方文件 Vuex 官方文件：https://vuex.vuejs.org/zh-cn/ vuex 是一個專為vue應用程式開發的狀態管理模式。它採用集中式儲存管理應用的所有元件的狀態，並以相應的規則保證狀態以一種可預測的方式發生變化。 vuex 不同於lo

websocekt-python與Js互動（2）

相關推薦