通过 Python 套接字发送数千条消息

Question

我有以下代码：

for mydetails in allthelists:
    hostype = mydetails[0]
    graphType = mydetails[1]
    hostNodeName = mydetails[2]
    frequency = mydetails[3]
    diskName = mydetails[4]
    avgOfMultiDays = mydetails[5]
    eachEpoch = mydetails[6]

    messageA = '{hostype}.{graphType}.{hostNodeName}.{frequency}.{diskName}-altavg {avgOfMultiDays} {eachEpoch}\n'.format(**locals())
    print 'sending message:\n%s' % messageA
    sock = socket.socket()
    sock.connect((CSERVER, CPORT))
    sock.sendall(messageA)

我遇到的问题是我必须向我的石墨服务器发送数千个 "messageA"。代码为每条发送的消息打开和关闭套接字……我知道这很糟糕。原谅我。我是 python 的新手。

我正在寻找一种优化方法。我相信为每条消息打开和关闭套接字是一个非常糟糕的主意。但我似乎无法找到解决方法。如果对此有任何帮助，我将不胜感激。

我的思路是：

messageA = "blah blah blah"
messageB = "blah blah blah"
messageC = "blah blah blah"
..... and so on
#then, 
sock = socket.socket()
sock.connect((CSERVER, CPORT))
sock.sendall(messageA,messageB,messageC,.....)

但这不是 python 套接字的工作方式。

Answer 1

您的初始代码存在重大问题，因为它在使用后没有关闭套接字。如果您以这种方式处理了数以千计的消息，您将打开数以千计的套接字连接。因此，如果您要按原样使用初始代码，则需要在 sock.sendall().

之后放置一个 sock.close()

您真正想在这里做什么取决于服务器的期望。对于侦听套接字的任意服务器，您可以为每个连接发送一条消息或在单个连接上发送一堆消息，这不一定是正确的。由于您使用 EOL 终止消息，因此服务器可以使用它来了解每条消息的结尾位置（一行是一条消息），在这种情况下它可以处理多条消息。但是，服务器也可能希望每个连接只收到一条消息，在这种情况下，您将被迫执行您在初始代码块中所做的操作。

假设您可以在一个连接上发送多条消息，您想按照@GarethMa 的建议进行操作...只需在循环和处理您发送的每条消息之前创建并连接套接字：

sock = socket.socket()
sock.connect((CSERVER, CPORT))
for mydetails in allthelists:
    hostype = mydetails[0]
    graphType = mydetails[1]
    hostNodeName = mydetails[2]
    frequency = mydetails[3]
    diskName = mydetails[4]
    avgOfMultiDays = mydetails[5]
    eachEpoch = mydetails[6]

    messageA = '{hostype}.{graphType}.{hostNodeName}.{frequency}.{diskName}-altavg {avgOfMultiDays} {eachEpoch}\n'.format(**locals())
    print 'sending message:\n%s' % messageA
    sock.sendall(messageA)
socket.close()

通过 Python 套接字发送数千条消息

Sending thousands of messages through Python Socket

python

python-sockets