Python网络Socket编程

jieforest · 发表于 2012-11-1 22:24

服务器端编程

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

1. 打开 socket

2. 绑定到一个地址和端口

3. 侦听进来的连接

4. 接受连接

5. 读写数据

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

jieforest · 发表于 2012-11-1 22:26

绑定Socket

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

示例代码：

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 绑定到同一个端口之上。

jieforest · 发表于 2012-11-1 22:27

连接侦听

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

s.listen(10)
print 'Socket now listening'

复制代码

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

jieforest · 发表于 2012-11-3 08:48

接受连接

示例代码：

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])

复制代码

jieforest · 发表于 2012-11-3 08:48

输出

运行该程序将会显示：

$ python server.py
Socket created
Socket bind complete
Socket now listening

复制代码

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

jieforest · 发表于 2012-11-3 08:49

打开命令行窗口并输入：

$ 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.

复制代码

jieforest · 发表于 2012-11-3 08:49

本帖最后由 jieforest 于 2012-11-3 08:49 编辑

而服务器端窗口显示的是：

$ python server.py
Socket created
Socket bind complete
Socket now listening
Connected with 127.0.0.1:59954

复制代码

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

jieforest · 发表于 2012-11-3 08:50

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

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

sendall 函数可通过 Socket 给客户端发送数据：
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()
print 'Connected with ' + addr[0] + ':' + str(addr[1])
#now keep talking with the client
data = conn.recv(1024)
conn.sendall(data)
conn.close()
s.close()

复制代码

jieforest · 发表于 2012-11-4 14:12

继续运行上述代码，然后打开另外一个命令行窗口输入下面命令：

$ telnet localhost 8888
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
happy
happy
Connection closed by foreign host.

复制代码

jieforest · 发表于 2012-11-4 14:12

可看到客户端接收到来自服务器端的回应内容。

上面的例子还是一样，服务器端回应后就立即退出了。而一些真正的服务器像 www.oschina.net 是一直在运行的，时刻接受连接请求。

也就是说服务器端应该一直处于运行状态，否则就不能成为“服务”，因此我们要让服务器端一直运行，最简单的方法就是把 accept 方法放在一个循环内。

Python网络Socket编程

浏览过的版块