基于Python多线程的TCP客户端/服务端应用示例

每个连接都必须创建新线程（或进程）来处理，否则，单线程在处理连接的过程中，无法接受其他客户端的连接。

服务端：server.py

# -*- coding:utf-8 -*-

import sys
import socket
import threading

def threadfun(sock, addr):
try:
while True:
data = sock.recv(1024)
if data == "quit" or data=="exit":
print "Client %s exit." % addr[0]
break
if data:
print "Message from %s: %s" % (addr[0],data)
sock.send("Hello,%s" % data)
sock.close()
except socket.errno, e:
print "Socket error: %s" % str(e)
except Exception as e:
print "Other exception: %s" % str(e)
finally:
sock.close()

def test_server(port):

# 创建TCP套接字
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 启用地址重用
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# 绑定地址和端口号
srv_addr = ("0.0.0.0", port)
sock.bind(srv_addr)

# 侦听客户端
sock.listen(5)

while True:
# 接受客户端连接
conn, addr = sock.accept()
t = threading.Thread(target=threadfun, args=(conn, addr))
t.start()

if __name__ == "__main__":
if len(sys.argv) == 2:
port = sys.argv[1]
test_server(int(port))
else:
print "Input error."

客户端：client.py
# -*- coding:utf-8 -*-

import sys
import socket
import argparse

def test_client(host, port):

# 创建TCP套接字
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 连接服务器
srv_addr = (host, port)
sock.connect(srv_addr)

# 发送并接收数据
try:
# 发送消息
while True:
msg = raw_input("Please nput:")
sock.sendall(msg)

if msg=="quit" or msg=="exit":
break

# 接收消息
data = sock.recv(1024)
print "Message from server: %s" % data
sock.close()
except socket.errno, e:
print "Socket error: %s" % str(e)
except Exception as e:
print "Other exception: %s" % str(e)
finally:
sock.close()

if __name__ == "__main__":
parser = argparse.ArgumentParser(description="Socket Server Example")
parser.add_argument("--ip", action="store", dest="host", type=str, required=True)
parser.add_argument("--port", action="store", dest="port", type=int, required=True)
given_args = parser.parse_args()
host = given_args.host
port = given_args.port
test_client(host, port)



几点说明：

1.bind本地IP地址
socket.bind(("localhost",8099))，除localhost:8099之外其它地址都不能访问。

socket.bind(("127.0.0.1",8099))，除127.0.0.1:8099、localhost:8099之外其它地址都不能访问。

因此最好的方式是绑定机器所以IP地址：

socket.bind(("0.0.0.0",8099)) 或者 socket.bind(("",8099))

2.线程模块
(1) thread模块: 允许程序员创建和管理线程，它提供了基本的线程和锁的支持。

(2) threading模块: 允许程序员创建和管理线程，它提供了更高级别，更强的线程管理的功能。

3.控制台输入
raw_input()直接读取控制台的输入（任何类型的输入它都可以接收）。

而对于input()，它希望能够读取一个合法的python表达式，

即你输入字符串的时候必须使用引号将它括起来，否则它会引发一个 SyntaxError 。

raw_input()将所有输入作为字符串看待，返回字符串类型。

而 input()在对待纯数字输入时具有自己的特性，它返回所输入的数字的类型（ int, float ）；

所以input()可接受合法的python表达式，举例：input( 1 + 3 )会返回int型的4。

input()本质上还是使用 raw_input()来实现的，只是调用完raw_input()之后再调用eval()函数，

所以，你甚至可以将表达式作为input()的参数，并且它会计算表达式的值并返回它。

因此除非对input()有特别需要，否则一般情况下都是推荐使用 raw_input() 来与用户交互。