Python 的 Socket 编程教程

except socket.error:

print 'Failed to create socket' sys.exit()

print 'Socket Created' host = 'oschina.net'; port = 80; try:

remote_ip = socket.gethostbyname( host ) except socket.gaierror:

#could not resolve

print 'Hostname could not be resolved. Exiting' sys.exit()

#Connect to remote server s.connect((remote_ip , port))

print 'Socket Connected to ' + host + ' on ip ' + remote_ip Send some data to remote server

message = \ try :

#Set the whole string s.sendall(message) except socket.error:

#Send failed

print 'Send failed' sys.exit()

print 'Message send successfully' #Now receive data reply = s.recv(4096)

print reply

下面是上述程序执行的结果：

$ python client.py Socket Created

Ip address of oschina.net is 61.145.122.

Socket Connected to oschina.net on ip 61.145.122.155 Message send successfully

HTTP/1.1 301 Moved Permanently Server: nginx

Date: Wed, 24 Oct 2012 13:26:46 GMT Content-Type: text/html Content-Length: 178 Connection: keep-alive

Keep-Alive: timeout=20

Location: http://www.oschina.net/

oschina.net 回应了我们所请求的 URL 的内容，很简单。数据接收完了，可以关闭 Socket 了。

关闭 socket

close 函数用于关闭 Socket： s.close() 这就是了。

让我们回顾一下

上述的示例中我们学到了如何：

1. 创建 Socket 2. 连接到远程服务器 3. 发送数据 4. 接收回应

当你用浏览器打开 www.oschina.net 时，其过程也是一样。包含两种类型，分别是客户端和服务器，客户端连接到服务器并读取数据，服务器使用 Socket 接收进入的连接并提供数据。因此在这里 www.oschina.net 是服务器端，而你的浏览器是客户端。

接下来我们开始在服务器端做点编码。

服务器端编程

服务器端编程主要包括下面几步：

1. 打开 socket

2. 绑定到一个地址和端口 3. 侦听进来的连接 4. 接受连接

5. 读写数据

我们已经学习过如何打开 Socket 了，下面是绑定到指定的地址和端口上。

绑定 Socket

bind 函数用于将 Socket 绑定到一个特定的地址和端口，它需要一个类似 connect 函数所需的 sockaddr_in 结构体。

示例代码：

#!/usr/bin/python import socket

import sys

HOST = '' # Symbolic name meaning all available interfaces PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) print 'Socket created'

try:

s.bind((HOST, PORT)) except socket.error , msg:

print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1] sys.exit() print 'Socket bind complete'

绑定完成后，就需要让 Socket 开始侦听连接。很显然，你不能将两个不同的 Socket 绑定到同一个端口之上。

连接侦听

绑定 Socket 之后就可以开始侦听连接，我们需要将 Socket 变成侦听模式。socket 的 listen 函数用于实现侦听模式： s.listen(10)

print 'Socket now listening'

listen 函数所需的参数成为 backlog，用来控制程序忙时可保持等待状态的连接数。这里我们传递的是 10，意味着如果已经有 10 个连接在等待处理，那么第 11 个连接将会被拒绝。当检查了 socket_accept 后这个会更加清晰。

接受连接 示例代码：

#!/usr/bin/python import socket import sys

HOST = '' # Symbolic name meaning all available interfaces PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) print 'Socket created' try:

s.bind((HOST, PORT))

except socket.error , msg:

print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1] sys.exit()

print 'Socket bind complete' s.listen(10)

print 'Socket now listening'

#wait to accept a connection - blocking call conn, addr = s.accept()

#display client information

print 'Connected with ' + addr[0] + ':' + str(addr[1])

运行该程序将会显示： $ python server.py Socket created

Socket bind complete

ocket now listening

现在这个程序开始等待连接进入，端口是 8888，请不要关闭这个程序，我们来通过 telnet 程序来进行测试。

打开命令行窗口并输入：

$ telnet localhost 8888 It will immediately show $ telnet localhost 8888 Trying 127.0.0.1... Connected to localhost.

Escape character is '^]'.

Connection closed by foreign host. 而服务器端窗口显示的是： $ python server.py Socket created

Socket bind complete Socket now listening

Connected with 127.0.0.1:59954

我们可看到客户端已经成功连接到服务器。

上面例子我们接收到连接并立即关闭，这样的程序没什么实际的价值，连接建立后一般会有大量的事情需要处理，因此让我们来给客户端做出点回应吧。

sendall 函数可通过 Socket 给客户端发送数据：

#!/usr/bin/python import socket import sys

HOST = '' # Symbolic name meaning all available interfaces PORT = 8888 # Arbitrary non-privileged port

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) print 'Socket created' try:

s.bind((HOST, PORT)) except socket.error , msg:

print 'Bind failed. Error Code : ' + str(msg[0]) + ' Message ' + msg[1] sys.exit() print 'Socket bind complete' s.listen(10)

print 'Socket now listening'

#wait to accept a connection - blocking call conn, addr = s.accept()