Python多线程Socket程序例子-CSDN博客

本文链接：https://blog.csdn.net/iteye_21281/article/details/82232568

本文介绍如何利用multitask包在Python中创建一个并发服务器和客户端实例，详细展示了从下载并导入所需模块到实现服务器与客户端交互的全过程。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

如果没有multitask包，请从[url]http://python-multitask.googlecode.com/files/multitask-0.2.0.zip[/url]下载

[url]http://blog.csdn.net/ghostfromheaven/article/details/7061387[/url]

[size=medium]server端[/size]


from __future__ import with_statement
from contextlib import closing
import socket
import multitask

def client_handler(sock):
    with closing(sock):
        while True:
            data = (yield multitask.recv(sock, 1024))
            if not data:
                break
            yield multitask.send(sock, data)

def echo_server(hostname, port):
    addrinfo = socket.getaddrinfo(hostname, port,
                                  socket.AF_INET,
                                  socket.SOCK_STREAM)

    (family, socketype, porot, canonname, sockaddr) = addrinfo[0]
    with closing(socket.socket(family,
                               socketype,
                               porot)) as sock:
        sock.setsockopt(socket.SOL_SOCKET,
                        socket.SO_REUSEADDR, 1)
        sock.bind(sockaddr)
        sock.listen(5)
        while True:
            multitask.add(client_handler((
                        yield multitask.accept(sock))[0]))

if __name__ == '__main__':
    import sys
    hostname = '192.168.2.102'
    port = 1111

    if len(sys.argv) > 1:
        hostname = sys.argv[1]

    if len(sys.argv) > 2:
        port = int(sys.argv[2])

    multitask.add(echo_server(hostname, port))

    try:
        multitask.run()
    except KeyboardInterrupt:
        pass

[size=medium]client端测试[/size]


import socket

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('192.168.2.102', 1111))

sock.send('hello')

data = sock.recv(1024)
sock.close()
print 'Received', repr(data)