我想使用套接字模塊通過 TCP 將移動(dòng)點(diǎn)的位置發(fā)送到服務(wù)器。該點(diǎn)位置在循環(huán)的每次迭代中更新，并以已使用 pickle方法序列化for的元組的形式發(fā)送。(x, y)dumps問題：在服務(wù)器端，似乎我只能從該循環(huán)的第一次迭代中接收位置。好像在此過程中跳過或丟失了所有以下更新的位置。我不能確定這種行為背后的原因是什么，但我敢打賭我沒有在服務(wù)器端正確設(shè)置東西。我懷疑由于我可能在使用套接字模塊時(shí)犯了一些錯(cuò)誤（我對網(wǎng)絡(luò)接口的世界是全新的），數(shù)據(jù)將被完全發(fā)送但在接收時(shí)沒有得到充分處理。
1 回答
喵喔喔
TA貢獻(xiàn)1735條經(jīng)驗(yàn) 獲得超5個(gè)贊
您需要將 connection, address = s.accept() 放在 while 循環(huán)之外，否則您的服務(wù)器每次都會(huì)等待新連接。
您接收數(shù)據(jù)的方式也有問題。connection.recv(4096)并非每次收到完整的“數(shù)據(jù)”消息時(shí)都會(huì)返回 0 到 4096 之間的任意字節(jié)數(shù)。要處理此問題，您可以在向您發(fā)送 json 之前發(fā)送一個(gè)標(biāo)頭，指示應(yīng)接收多少數(shù)據(jù)通過添加標(biāo)頭，您將確保正確接收您發(fā)送的數(shù)據(jù)消息。
此示例中的標(biāo)頭是一個(gè)四字節(jié)的 int，指示數(shù)據(jù)的大小。
服務(wù)器
import pickle
import socket
import struct
HEADER_SIZE = 4
HOST = "127.0.0.1"
PORT = 12000
def receive(nb_bytes, conn):
# Ensure that exactly the desired amount of bytes is received
received = bytearray()
while len(received) < nb_bytes:
received += conn.recv(nb_bytes - len(received))
return received
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
connection, address = s.accept()
while True:
# receive header
header = receive(HEADER_SIZE, connection)
data_size = struct.unpack(">i", header)[0]
# receive data
data = receive(data_size, connection)
print(pickle.loads(data))
客戶
import socket
import pickle
import math
HEADER_SIZE = 4
HOST = "127.0.0.1"
PORT = 12000
den = 20
rad = 100
theta = math.tau / den
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
sock.connect((HOST, PORT)) #connect to server
for step in range(1000):
i = step%den
x = math.cos(i*theta) * rad
y = math.sin(i*theta) * rad
data = pickle.dumps((x, y), protocol=0)
# compute header by taking the byte representation of the int
header = len(data).to_bytes(HEADER_SIZE, byteorder ='big')
sock.sendall(header + data)
希望能幫助到你
添加回答
舉報(bào)
0/150
提交
取消