Python 的 Socket 编程教程 联系客服

发布时间 : 星期六 文章Python 的 Socket 编程教程更新完毕开始阅读43be19e0551810a6f52486bf

Python 的 Socket 编程教程

Felix Shang

QQ :279379936 QQ群:249086255

这是用来快速学习 Python Socket 套接字编程的指南和教程。Python 的 Socket 编程跟 C 语言很像。

Python 官方关于 Socket 的函数请看 http://docs.python.org/library/socket.html

基本上,Socket 是任何一种计算机网络通讯中最基础的内容。例如当你在浏览器地址栏中输入 www.oschina.net 时,你会打开一个套接字,然后连接到 www.oschina.net 并读取响应的页面然后然后显示出来。而其他一些聊天客户端如 gtalk 和 skype 也是类似。任何网络通讯都是通过 Socket 来完成的。

本教程假设你已经有一些基本的 Python 编程的知识。 让我们开始 Socket 编程吧。

创建 Socket

首先要做的就是创建一个 Socket,socket 的 socket 函数可以实现,代码如下: #Socket client example in python import socket #for sockets

#create an AF_INET, STREAM socket (TCP)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

print 'Socket Created'

函数 socket.socket 创建了一个 Socket,并返回 Socket 的描述符可用于其他 Socket 相关的函数。

上述代码使用了下面两个属性来创建 Socket:

地址簇 : AF_INET (IPv4)

类型: SOCK_STREAM (使用 TCP 传输控制协议)

错误处理

如果 socket 函数失败了,python 将抛出一个名为 socket.error 的异常,这个异常必须予以处理:

#handling errors in python socket programs import socket #for sockets import sys #for exit try:

#create an AF_INET, STREAM socket (TCP)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) except socket.error, msg:

print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1] sys.exit(); print 'Socket Created'

好了,假设你已经成功创建了 Socket,下一步该做什么呢?接下来我们将使用这个 Socket 来连接到服务器。 注意

与 SOCK_STREAM 相对应的其他类型是 SOCK_DGRAM 用于 UDP 通讯协议,UDP 通讯是非连接 Socket,在这篇文章中我们只讨论 SOCK_STREAM ,或者叫 TCP 。

连接到服务器

连接到服务器需要服务器地址和端口号,这里使用的是 www.oschina.net 和 80 端口。

首先获取远程主机的 IP 地址

连接到远程主机之前,我们需要知道它的 IP 地址,在 Python 中,获取 IP 地址是很简单的:

import socket #for sockets import sys #for exit try:

#create an AF_INET, STREAM socket (TCP)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

except socket.error, msg:

print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1] sys.exit(); print 'Socket Created' host = 'www.oschina.net'

try:

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

#could not resolve

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

print 'Ip address of ' + host + ' is ' + remote_ip

我们已经有 IP 地址了,接下来需要指定要连接的端口。

代码:

import socket #for sockets import sys #for exit

try:

#create an AF_INET, STREAM socket (TCP)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) except socket.error, msg:

print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1] sys.exit();

print 'Socket Created' host = 'www.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()

print 'Ip address of ' + host + ' is ' + remote_ip

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

print 'Socket Connected to ' + host + ' on ip ' + remote_ip 现在运行程序

$ python client.py Socket Created

Ip address of www.oschina.net is 61.145.122.155

Socket Connected to www.oschina.net on ip 61.145.122.155

这段程序创建了一个 Socket 并进行连接,试试使用其他一些不存在的端口(如81)会是怎样?这个逻辑相当于构建了一个端口扫描器。

已经连接上了,接下来就是往服务器上发送数据。

免费提示

使用 SOCK_STREAM/TCP 套接字才有“连接”的概念。连接意味着可靠的数据流通讯机制,可以同时有多个数据流。可以想象成一个数据互不干扰的管道。另外一个重要的提示是:数据包的发送和接收是有顺序的。

其他一些 Socket 如 UDP、ICMP 和 ARP 没有“连接”的概念,它们是无连接通讯,意味着你可从任何人或者给任何人发送和接收数据包。

发送数据

sendall 函数用于简单的发送数据,我们来向 oschina 发送一些数据:

import socket #for sockets

import sys #for exit

try:

#create an AF_INET, STREAM socket (TCP)

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) except socket.error, msg:

print 'Failed to create socket. Error code: ' + str(msg[0]) + ' , Error message : ' + msg[1] sys.exit();

print 'Socket Created' host = 'www.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()

print 'Ip address of ' + host + ' is ' + remote_ip #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'

上述例子中,首先连接到目标服务器,然后发送字符串数据 \/ HTTP/1.1\\r\\n\\r\\n\,这是一个 HTTP 协议的命令,用来获取网站首页的内容。

接下来需要读取服务器返回的数据。

接收数据

recv 函数用于从 socket 接收数据:

#Socket client example in python import socket #for sockets import sys #for exit

#create an INET, STREAMing socket try:

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)