赞
踩
socket由一些对象组成,这些对象提供网络应用程序的跨平台标准。
13.2.1 认识socket模块
socket又称“套接字”,应用程序通常通过“套接字”向网络发出请求或应答网络请求,使主机间或一台计算机上的进程间可以通信。socket模块提供了标准的网络接口,可以访问底层操作系统socket接口的全部方法。
Python使用socket()函数创建套接字。其语法格式如下:
socket.socket([family[, type[, protocol]]])
各个参数的含义如下:
(1)family:套接字中的网络协议,包括AF_UNIX(UNIX网域协议)和AF_INET(IPv4网域协议,如TCP与UDP)。
(2)type:套接字类型,包括SOCK_STREAM(使用在TCP中)、SOCK_DGRAM(使用在UDP中)、SOCK_RAW(使用在IP中)和SOCK_SEQPACKET(列表连接模式)。
(3)protocol:只使用在family等于AF_INET或type等于SOCK_RAW的时候。protocol是一个常数,用于辨识所使用的协议种类。默认值是0,表示适用于所有socket类型。
每一个socket对象都有下面的方法:
(1)accept():接收一个新连接,并且返回两个数值(conn、address)。conn是一个新的socket对象,用于在该连接上传输数据;address是此socket使用的地址。
(2)bind(address):将socket连接到address地址,地址的格式为(hostname, port)。
(3)close():关闭此socket。
(4)connect(address):连接到一个远程的socket,其地址为address。
(5)makefile([mode [, bufsize]]):创建一个与socket有关的文件对象,参数mode和bufsize与内置函数open()相同。
(6)getpeername():返回socket所连接的地址,地址的格式为(ipaddr, port)。
(7)getsockname():返回socket本身的地址,地址的格式为(ipaddr, port)。
(8)listen(backlog):打开连接监听,参数backlog为最大可等候的连接数目。
(9)recv(bufsize [, flags]):从socket接收数据,返回值是字符串数据。参数bufszie表示最大的可接收数据量;参数flags用来指定数据的相关信息,默认值为0。
(10)recvfrom(bufsize [, flags]):从socket接收数据。返回值是成对的(string, address),其中,string代表接收的字符串数据,address则是socket传输数据的地址。参数bufszie表示最大的可接收数据量;参数flags用来指定数据的相关信息,默认值为0。
(11)send(string [, flags]):将数据以字符串类型传输到socket。参数flags与recv()方法相同。
(12)sendto(string [, flags], address):将数据传输到远程的socket。参数flags与recv()方法相同,参数address是该socket的地址。
(13)shutdown(how):关闭联机的一端或两端。若how等于0,则关闭接收端;若how等于1,则关闭传输端;若how等于2,则同时关闭接收端与传输端。
13.2.2 创建socket连接
下面使用socket模块的socket函数创建一个socket对象。socket对象可以通过调用其他函数设置一个socket服务。通过调用 bind(hostname, port) 函数指定服务的端口(port),然后调用socket对象的accept方法,该方法等待客户端的连接并返回connection对象,表示已连接到客户端。
【例13.1】创建服务器端的socket服务(源代码\ch13\13.1.py)。
- # 导入 socket、sys 模块
-
- import socket
-
- import sys
-
- # 创建 socket 对象
-
- serversocket = socket.socket(
-
- socket.AF_INET, socket.SOCK_STREAM)
-
- # 获取本地主机名
-
- host = socket.gethostname()
-
- port = 9999
-
- # 绑定端口
-
- serversocket.bind((host, port))
-
- # 设置最大连接数,超过后排队
-
- serversocket.listen(5)
-
- while True:
-
- # 建立客户端连接
-
- clientsocket,addr = serversocket.accept()
-
- print("连接地址: %s" % str(addr))
-
- msg='折花逢驿使,寄与陇头人。江南无所有,聊赠一枝春。'+ "\r\n"
-
- clientsocket.send(msg.encode('utf-8'))
-
- clientsocket.close()
保存并运行程序,即可在服务器端启动socket服务。
下面的示例创建一个客户端,并连接以上创建的服务,端口号为12345。
【例13.2】创建客户端的连接(源代码\ch13\13.2.py)。
- # 导入 socket、sys 模块
-
- import socket
-
- import sys
-
- # 创建 socket 对象
-
- s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-
- # 获取本地主机名
-
- host = socket.gethostname()
-
- # 设置端口
-
- port = 9999
-
- # 连接服务,指定主机和端口
-
- s.connect((host, port))
-
- # 接收小于 1024 字节的数据
-
- msg = s.recv(1024)
-
- s.close()
-
- print (msg.decode('utf-8'))
保存并运行程序,输出结果如下:
折花逢驿使,寄与陇头人。江南无所有,聊赠一枝春。
此时在服务器端显示的结果如下:
连接地址:(’192.168.108’,65141)
注意:第一次运行13.1.py和13.2.py两个文件时,可能会弹出以下错误信息:
ConnectionRefusedError: [WinError 10061] 由于目标计算机积极拒绝,无法连接。
解决方法是关闭上述运行的13.1.py和13.2.py两个文件,然后重新运行这两个文件即可。
-------------------------------------------
本文节选自《Python编程从零开始学(视频教学版)》
本次内容发布,获得作者和出版社授权。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。