使python套接字异步？

我有以下脚本，我试图使它异步。它可以很好地作为客户端通过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)

来源

2015-02-04 Ke.

线程确实是这样的。 – MeetTitan

线程将是我会使用的方法。试试这个：

thread = threading.Thread(target = sendtextfile.Send, args = (datasend,)) 
thread.start()

来源

2015-02-04 18:35:33 MeetTitan

嗨MeetTitan，对不起，我的Python有点基本，只是想知道这可能会在脚本中出现在哪里？我如何实现它？我猜我还需要在顶部声明线程？ –

将您的调用替换为您的main（）函数中的'sendtextfile.Send（datasend）'，并使用我的代码片断，并且您的函数将异步运行。是的，还记得导入'Threading'。 – MeetTitan

Hmmn，变量Im填充是bytes_sent而不是“线程”，当我将其更改为“线程”时，它不能正常工作与类？ –

使python套接字异步？

回答

相关问题