Python 套接字 - 向服务器发送数据包并等待响应

Question

我目前正在执行以下代码以将数据包发送到 Parallels PVA XML API。我正在尝试向服务器发送两个 XML 数据包。第一个是指定用户凭据的登录数据包，第二个是包含有关 API 请求信息的数据包。这些数据包应该由空字节 \0 分隔。通常，服务器会发回多个数据包，第一个数据包说明登录成功，第二个数据包包含有关 API 请求的信息。

我遇到的问题是似乎没有发送第二个数据包。我得到的唯一响应是第一个说明登录成功的数据包，但我没有得到包含有关 API 请求信息的数据包。我认为这可能是因为我发送了一个空字节，所以我尝试使用 base64 对所有内容进行编码，但结果相同。

那么在我看来要么连接正在关闭并且服务器没有足够的时间发送它的第二个数据包，要么由于空字节而完全忽略该数据包。

任何帮助或意见将不胜感激。提前致谢!

import socket
import base64

def client(string):
    HOST, PORT = '[IP_ADDRESS]', 4433
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.settimeout(10)
    sock.connect((HOST, PORT))
    sock.send(base64.b64encode(string))
    reply = sock.recv(131072)
    sock.close()

    return reply

packet = "<packet></packet>\0<packet></packet>"
print client(packet)

请不要故意在数据包中没有信息，因为它包含敏感信息，并且 ip 地址被故意替换为“[IP_ADDRESS]”

Answer 1

问题是，您试图一次发送太多字节，\0 将终止整个消息，因此剩余部分从未发送过。 我模拟了一个类似的客户端/服务器，这里是响应:

服务器只是一个回显类型

...

客户端，从您的代码稍作更改

import socket
from time import sleep
def client():
    # I change second packet to 2packet for visually distinguish the packets
    packet = "<packet></packet>\0<2packet></2packet>"
    HOST, PORT = '127.0.0.1', 4433
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.settimeout(10)
    sock.connect((HOST, PORT))
    while True:
        try:
            sock.send(packet)
            sleep(1)
            # this is the problem here
            reply = sock.recv(131072)
            if not reply:
                break
            print "recvd: ", reply
        except KeyboardInterrupt:
            print "bye"
            break
    sock.close()
    return

client()
recvd:  WelcomeOK...<packet></packet> # the null byte teminate the send and skip all remaining message
recvd:  OK...<packet></packet>
recvd:  OK...<packet></packet>
recvd:  OK...<packet></packet>
...

您会看到，2packet 从未发送过，因为它由空字节终止，消息正文超过 131072 字节，比第二部分消息正文长.

因此，为了解决这个问题，您只需要在每个循环中发送一个字节，因此空字节只会自行终止，并且可以发送下一个字节直到消息结束:

发送单字节修改版

... previous code
    while True:
        try:
            sock.send(packet)
            sleep(1)
            reply = sock.recv(1)
            if not reply:
                break
            print "recvd: ", reply
        except KeyboardInterrupt:
            print "bye"
            break
    sock.close()
    return

client()
recvd:  W
recvd:  e
recvd:  l
recvd:  c
recvd:  o
recvd:  m
recvd:  e
recvd:  O
recvd:  K
recvd:  .
recvd:  .
recvd:  .
recvd:  <
recvd:  p
recvd:  a
recvd:  c
recvd:  k
recvd:  e
recvd:  t
recvd:  >
recvd:  <
recvd:  /
recvd:  p
recvd:  a
recvd:  c
recvd:  k
recvd:  e
recvd:  t
recvd:  >
recvd:       # <== this null byte terminates single byte send
recvd:  <    # <== and next loop it tries to send the next byte, goal achieved
recvd:  2
recvd:  p
recvd:  a
recvd:  c
recvd:  k
recvd:  e
recvd:  t
recvd:  >
recvd:  <
...