2

ブラウザクライアントからPythonサーバーに文字列/テキストデータを送信して、単に印刷しようとしています。私はインターネットでいくつかの例をたどりましたが、すべて同じです:javascript

web_socket.send("text to be sent")

そして（パイソン）

data = web_socket.recv(1024)
print data

彼らは彼らが望むもの、サーバーサイトでの明確で素敵な印刷物「送信されるテキスト」を受け取ります。

私.htmlと.py以下を見つけることができます：

<!DOCTYPE html>

<html lang="en">
<head>
    <title>Test</title>
    <script src="jquery.js"></script>  
    <script type="application/javascript">
        var ws;

        function init() {
            var servermsg = document.getElementById("servermsg");
            ws = new WebSocket("ws://127.0.0.1:9877/");
            ws.onopen = function(){
                servermsg.innerHTML = servermsg.innerHTML + "<br>Server connected";
            };
            ws.onmessage = function(e){
                servermsg.innerHTML = servermsg.innerHTML + "<br><< Recieved data: " + e.data;
            };
            ws.onclose = function(){
                servermsg.innerHTML = servermsg.innerHTML + "<br>Server disconnected";
            };
        }
        function postmsg(){
            var text = document.getElementById("message").value;
            ws.send(text);
            servermsg.innerHTML = servermsg.innerHTML + "<br>>> Data sent: " + text;
        }
        //$(function(){
        //    var text = document.getElementById("message").value;
        //    ws.send(text);
        //    servermsg.innerHTML = servermsg.innerHTML + "<br>Sent: " + text;            
        //});


    </script>
</head>
<body onload="init();">
    <form action="" onSubmit="postmsg();return false;">
        <input type="text" name="message" value="" id="message">
        <input type="submit" name="submit" value="" id="submit">
    </form>
    <div id="servermsg"><h1>Message log:</h1></div>
</body>

</html>

サーバ：

#!/usr/bin/env python

import socket
import threading
import struct
import hashlib
import base64

PORT = 9877
_address = ""

def create_handshake_resp(handshake):
final_line = ""
lines = handshake.splitlines()
for line in lines:
    parts = line.partition(": ")
    if parts[0] == "Sec-WebSocket-Key":
        key = parts[2]


magic = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11'

accept_key = base64.b64encode(hashlib.sha1(key+magic).digest())

return (
    "HTTP/1.1 101 Switching Protocols\r\n"
    "Upgrade: WebSocket\r\n"
    "Connection: Upgrade\r\n"
    "Sec-WebSocket-Accept: " + accept_key + "\r\n\r\n")


def handle(s, addr):
data = s.recv(1024)
response = create_handshake_resp(data)
s.sendto(response, addr)
lock = threading.Lock()
while 1:
    print "Waiting for data from", addr
    data = s.recv(1024)
    print "Done"
    if not data:
        print "No data"
        break

    print 'Data from', addr, ':', data

print 'Client closed:', addr
lock.acquire()
clients.remove(s)
lock.release()
s.close()

def start_server():
print 'STARTING SERVER...'
s = socket.socket()
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.bind(('', PORT))
s.listen(1)
print 'SERVER STARTED'
while 1:
    conn, addr = s.accept()
    print 'NEW CONNECTION ['+str(len(clients))+'], connected by ', addr
    clients.append(conn)
    threading.Thread(target = handle, args = (conn, addr)).start()

clients = []
start_server()

サーバーの出力 (入力が「AA」または「ABC」のような場合):

STARTING SERVER...
SERVER STARTED
NEW CONNECTION [0], connected by  ('127.0.0.1', 43877)
Waiting for data from ('127.0.0.1', 43877)
Done
Data from ('127.0.0.1', 43877) : ����w�q
Waiting for data from ('127.0.0.1', 43877)
Done
Data from ('127.0.0.1', 43877) : ��)B�h
Waiting for data from ('127.0.0.1', 43877)
4

3 に答える 3

1

私は自分自身で似たようなことに取り組んでいます。Websocket プロトコルは、クライアントがマスクを使用してすべてのデータを送信することを義務付けています。これが「ガベージ」と表示される理由です。これはマスクされたテキストです。

https://www.rfc-editor.org/rfc/rfc6455#section-5

「クライアントは、サーバーに送信するすべてのフレームをマスクする必要があります」

プロトコルのセクション 5 を読むと、すべてが明らかになります。ブラウザ (つまりクライアント) は、必要に応じて (ws.send を呼び出したときに) プロトコルを実装しているだけです。あなたは自分のビットを行う必要があります。

サーバーがクライアントにデータを送信するときは、マスクしてはならないことにも注意してください。ただし、実際のデータ (型、長さなど) の前に他の情報を提供する必要があります。

于 2013-05-17T14:59:46.187 に答える
0

サーバー側から websocket クライアントにメッセージを送信するには、次のようにする必要があります。

message = bytearray([0b10000001, len(original_msg)])

for byte in bytearray(original_msg): 
    message.append(byte)

https://github.com/westial/SingleSocketで安定したサーバーからクライアントへの一方向ソケット ライブラリを参照してください。

于 2015-10-09T15:15:40.080 に答える