Python多线程Socket程序例子

如果没有multitask包，请从http://python-multitask.googlecode.com/files/multitask-0.2.0.zip下载 或从http://code.google.com/p/python-multitask/downloads/list?can=1查找最新版本

http://ghostfromheaven.iteye.com/admin/blogs/1305001

server端

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

client端测试

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)