每个连接都必须创建新线程(或进程)来处理，否则，单线程在处理连接的过程中，无法接受其他客户端的连接。
服务端：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() 来与用户交互。
