socket 编程初探

一 简介 socket是两个应用程序进行通信的管道,这两个应用程序可以在同一台机器上，也可以位于两台不同的机器上,相同的网络或者不同网络之间的。Python socket有丰富的类和方法，可以简化socket编程。 二 socket 2.1 socket类型

例子 创建TCP Socket: import socket tcpSerSock=socket.socket(socket.AF_INET,socket.SOCK_STREAM) 创建UDP Socket： tcpSerSock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) 注意点: 1）TCP发送数据时，已建立好TCP连接，所以不需要指定地址。UDP是面向无连接的，每次发送要指定是发给谁。 2）服务端与客户端不能直接发送列表，元组，字典。需要字符串化repr(data)。 2.2 socket函数 服务端socket函数

客户端socket函数

公用函数

三 创建socket连接 服务端 1 创建socket对象。 tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 2 使用bind方法来将socket绑定到指定地址和端口。 tcpSock.bind(address,port) 3 使用listen方法接收连接请求。 tcpSock.listen( backlog ) backlog指定最多允许多少个客户连接到服务器。它的值至少为1。收到连接请求后，这些请求需要排队，如果队列满，就拒绝请求。 4 通过socket的accept方法等待客户请求连接。 connection, address = socket.accept() 调用accept方法时，socket会时入"waiting"状态,等待客户请求连接，当客户端发送请求到服务端时,accept方法建立连接并返回服务器。accept方法返回一个含有两个元素的 元组(connection,address)。 第一个元素 connection是新的socket对象，服务器必须通过它与客户通信； 第二个元素 address是客户的IP地址。 5 处理阶段，服务器和客户端通过send和recv方法通信(传输数据)。服务器调用send方法以字符串形式向客户发送数据，也可以使用recv方法从客户接收信息。调用recv时， 服务器必须设置接收的最大数据量。recv方法在接收数据时会进入“blocked”状态，最后返回一个字符串，用它表示收到的数据。 如果发送的数据量超过recv所允许接收的限制，数据会被截断。多余的数据将缓冲于接收端。下一次调用recv时，多余的数据会从缓冲区删除(以及自上次调用recv以来，客户可能发送的其它任何数据) 6 传输结束，服务器调用socket的close方法关闭连接。 客户端 1 创建一个socket以连接服务器,和服务器端创建socket对象一样。 tcpCliSock = socket.socket(socket.AF_INET,socket.SOCK_STREAM) 2 使用socket的connect方法连接服务器。 tcpCliSock.connect( (host,port) ) host代表服务器主机名或IP，port代表服务器进程所绑定的端口号。如连接成功，客户就可通过套接字与服务器通信，如果连接失败，会引发socket.error异常。 3 处理阶段，客户和服务器将通过send方法和recv方法通信。 tcpCliSock.send(data) 4 传输结束，客户通过调用socket的close方法关闭连接。 tcpCliSock.close() 一图胜千言 ，socket 建立连接的过程 via

图片来自于 《socket 套接字》 四 talk is cheap ,show me the code . 代码实现了一个client 端通过socket 向 server端发送信息的程序 server.py

1. #coding:utf8
2. import socket
3. from time import ctime
4. HOST=''
5. PORT=9999
6. BUFSIZE=1024
7. ADDR=(HOST,PORT)
8. tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
9. tcpSock.bind(ADDR)
10. tcpSock.listen(5)
11. while True:
12. print 'waiting for connection ....'
13. tcpCliSock,addr = tcpSock.accept()
14. print '...connected from ',addr
15. while True:
16. data = tcpCliSock.recv(BUFSIZE)
17. if not data:
18. break
19. elif data == 'exit':
20. tcpCliSock.send('see you agine')
21. tcpCliSock.close()
22. exit(0)
23. tcpCliSock.send('%s, %s ' %(ctime(),data))
24. print [ctime()],':',data
25. tcpCliSock.close()
26. tcpSock.close()
27. exit(0)

client.py

1. #coding:utf8
2. import socket
3. HOST= '10.0.2.6' #server 主机ip
4. PORT=9999
5. BUFSIZE=1024
6. ADDR=(HOST,PORT)
7. tcpCliSock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
8. tcpCliSock.connect(ADDR)
9. while True:
10. try:
11. data = raw_input('>')
12. if not data :
13. break
14. tcpCliSock.send(data)
15. data = tcpCliSock.recv(BUFSIZE)
16. if not data:
17. break
18. print '%s say: %s' %(HOST,data)
19. if data == 'see you agine':
20. exit(0)
21. except (KeyboardInterrupt, SystemExit):
22. tcpCliSock.close()
23. exit(-1)

五 推荐阅读 1 python socket 官方文档 2 《socket 网络编程》 3 《Linux socket 编程》