python - 有时会出现乱码结果，通过 TCP 套接字将 base64 编码图像从 python 发送到 node.js

Question

我正在尝试在 python 中按程序生成图像以发送到 node.js 实例，这样我就可以通过 websocket 将这些图像实时传送到浏览器。

我的第一个测试迭代只是在我的 node.js 服务器中打开一个 jpeg 文件，将其编码为 base64，然后使用 socket.io(在端口 81 上)将其发送到浏览器。这在每次发送数据时都运行良好。

然后我尝试在 python 中打开相同的文件，连接到原始 TCP node.js 服务器(在端口 9090 上)，并将文件发送到 Node 服务器以转发到浏览器(在端口 81 上)。大约有一半时间，数据 Node 接收到的数据似乎已损坏，但 python 从文件中读取的数据每次都没有问题。

令我吃惊的是，node 和浏览器之间的数据通道很好，而 python 和 node 之间的数据通道却不行。是不是 websockets 提供了原始 TCP 套接字中不存在的一些错误纠正。如果不是，是什么导致了这个错误？

谢谢。

JS代码

var io = require('socket.io').listen(81);
var fs = require('fs');
var path = require('path');
var net = require('net');

var mousex = 0;
var mousey = 0;
var imgdata = "";
var oldimgdata = "";
var imagehaschanged = true;

//Serving python
var server = net.createServer(function (stream) {
  stream.setEncoding("base64");
  stream.on("connect", function () {
    console.log("rendering client connected");
  });
  stream.on("data", function (data) {

    //parsed = JSON.parse(data);
    imgdata = data;
    preview = imgdata.substr(0,50);
    console.log(preview);
    if (imgdata!=oldimgdata) {
        imagehaschanged=true;
    }

    console.log("rendering client sent data:");
    posdata = JSON.stringify({'x':mousex ,'y':mousey});
    stream.write(posdata, "ascii", function() {
        console.log("Sent response");
    });

  });
  stream.on("end", function () {
    stream.end();
    console.log("rendering client closed connection");
  });
});
server.listen(9090);

//Serving web
io.sockets.on('connection', function (socket) {
  socket.emit('ready');
  socket.on('position', function(data){
      mousex = data.x;
      mousey = data.y;

      if (imagehaschanged) {
        socket.emit('image', {data: imgdata});
        oldimgdata = imgdata;
        imagehaschanged = false;
      }


      //fs.readFile("1.jpg", processRead);
      //console.log(data.x + ", " + data.y)
  });
});

Python 代码

import socket, json,# base64
from time import sleep, time

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('localhost', 9090))

while 1:
    t0 = time()
    f = open("1.jpg")
    data = f.read()
    f.close()
    imgdata = data # base64.b64encode(data)
    print imgdata[:50]
    len = s.send(imgdata)
    response = json.loads(s.recv(4096))
    print "Response is:", response
    sleep(2)
    print "Time taken is: ", time()-t0

Answer 1

无论 tcp 套接字的客户端有多少写入以及消息的大小，您通常无法控制数据 block 的大小，您将获得服务器的“数据”处理程序(tcp 仅保证它们在命令)。您需要手动构建数据框架(最简单的方法是使用框架大小作为前缀并缓冲传入数据)

另见 this question