1

我目前正在实现以下代码以将数据包发送到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]”

4

2 回答 2

5

问题是，您试图一次发送太多字节，并且\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:  <
...
于 2014-11-05T23:37:56.580 回答
0

sock.recv最多可以读取 131072 个字节，但它只读取 1 个字节是完全可以的。如果您立即关闭套接字，则回复将丢失。您必须重复recv，直到您阅读了服务器发送的所有信息。所有数据包都由 终止\0吗？然后阅读直到你得到预期的 '\0' 数量。

于 2014-11-05T22:47:11.460 回答