我有以下腳本,我試圖使它異步。它可以很好地作爲客戶端通過TCP連接併發送文本文件。但是,我正在從另一個軟件程序執行它,並且正在減慢我運行它的程序(因此需要異步)。我的目標是讓腳本運行在它自己的後臺線程中,以便它不影響正在執行的程序。使python套接字異步?
我試着添加asyncore,但我只是不斷收到錯誤,它似乎不會連接。我也嘗試過線程,但無法讓這個工作。將不勝感激任何指示如何使這種異步
我曾嘗試使用這裏的教程 - http://www.mechanicalcat.net/richard/log/Python/A_simple_asyncore__echo_server__example但是,他們的腳本的體系結構是如此不同,以至於我似乎無法將它合併到我的腳本中。
import socket
import struct
import sys
import os
import time
import os.path
_MAX_BLOCK_SIZE = 1448
_PORT = 8002
IP_ADDRESS = '192.168.1.5'
FILE = sys.path[0] + "/MyFile.txt"
class FileSender(object):
def __init__(self, host):
self.__host = IP_ADDRESS
def __Pad(self, buf):
"""Returns copy of buf padded with NULLs to make its length a multiple of 4 bytes."""
if len(buf) % 4 == 0:
return buf
pad_buf = ""
for i in range(4 - (len(buf) % 4)):
pad_buf += "\x00"
return buf + pad_buf
def __FormatInt(self, int):
"""Returns string containing 32-bit integer in network byte order."""
return struct.pack("!i", int)
def Send(self, buf):
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
s.connect((self.__host, _PORT))
padded_buf = self.__Pad(buf)
# Send header packet.
s.send("%s%s%s%s" % (self.__FormatInt(16 + len(padded_buf)),
self.__Pad("/txtl"),
self.__Pad(",b"),
self.__FormatInt(len(buf))))
# Send data packets.
bytes_sent = 0
while (bytes_sent < len(padded_buf)):
bytes_to_send = len(padded_buf) - bytes_sent
assert bytes_to_send % 4 == 0
bytes_this_block = min(_MAX_BLOCK_SIZE, bytes_to_send)
s.send(padded_buf[bytes_sent:(bytes_sent + bytes_this_block)])
bytes_sent += bytes_this_block
s.close()
return bytes_sent
def main(argv):
sendtextfile = FileSender(IP_ADDRESS)
# Read input data.
input_file = open(_FILE)
data = input_file.read().strip()
input_file.close()
datasend = data[:-7]
bytes_sent = sendtextfile.Send(datasend)
if __name__ == "__main__":
main(sys.argv)
線程確實是這樣的。 – MeetTitan