Socket又称"套接字",应用程序通常通过"套接字"向网络发出请求或者应答网络请求,使主机间或者一台计算机上的进程间可以通讯。
常用模块:
- socket 模块
语法格式:
socket.socket([family[, type[, proto]]])
family
: 地址族,可以使AF_UNIX
或者AF_INET
type
: 套接字类型,可以根据是面向连接的还是非连接分为SOCK_STREAM或SOCK_DGRAM
protocol
: 协议编号,一般不填[默认为0]
地址族 | 描述 |
---|---|
socket.AF_UNIX | 只能够用于单一的Unix系统进程间通信 |
socket.AF_INET | 服务器之间网络通信 |
socket.INET6 | IPV6 |
套接字类型 | 描述 |
---|---|
socket.SOCK_STREAM | 流式socket , 用于TCP |
socket.SOCK_DGRAM | 数据报式socket , 用于UDP |
socket.SOCK_RAW | 原始套接字,用于处理普通套接字无法处理的ICMP、IGMP等网络报文;也可以处理特殊的IPv4报文或通过IP_HDRINCL套接字选项 由用户构造IP头 |
socket.SOCK_SEQPACKET | 可靠的连续数据包服务 |
socket函数(客户端) | 描述 |
---|---|
s.connect(address) | 绑定地址address到套接字,一般address的格式为元组(host,port),如果连接出错,返回socket.error错误 |
s.connect_ex(adddress) | connect()函数的扩展版本,出错时返回出错码,而不是抛出异常 |
socket函数(服务器端) | 描述 |
---|---|
s.bind() | 绑定地址(host,port)到套接字, 在AF_INET下,以元组(host,port)的形式表示地址。 |
s.listen() | 开始监听TCP传入连接。backlog指定在拒绝连接之前,操作系统可以挂起的最大连接数量。该值至少为1,大部分应用程序设为5就可以了。 |
s.accept() | 接受TCP连接并返回(conn,address),其中conn是新的套接字对象,可以用来接收和发送数据。address是连接客户端的地址。 |
常用公共socket函数 | 描述 |
---|---|
s.recv(bufsize[,flag]) | 接受TCP套接字的数据。数据以字符串形式返回,bufsize指定要接收的最大数据量。flag提供有关消息的其他信息,通常可以忽略。 |
s.send(bytes[, flags]) | 发送TCP数据。将bytes中的数据发送到连接的套接字。返回值是要发送的字节数量(python3) |
s.sendall(bytes[,flag]) | 完整发送TCP数据。将bytes中的数据发送到连接的套接字,但在返回之前会尝试发送所有数据。成功返回None,失败则抛出异常。(python3) |
s.recvfrom(bufsize[.flag]) | 接受UDP套接字的数据。与recv()类似,但返回值是(data,address)。其中data是包含接收数据的字符串,address是发送数据的套接字地址。(python3) |
s.sendto(bytes[,flag],address) | 发送UDP数据。将数据发送到套接字,address是形式为(ipaddr,port)的元组,指定远程地址。 |
s.close() | 关闭套接字 |
s.getpeername() | 返回连接套接字的远程地址 |
s.getsockname() | 返回套接字自己的地址 |
s.settimeout(timeout) | 设置套接字操作的超时期,timeout是一个浮点数,单位是秒 |
s.makefile() | 创建一个与该套接字相关连的文件 |
- 创建TCP socket
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
- 创建TCP客户端
#text.py VSCode
import socket
host = '127.0.0.1'
port = 9999
add = (host,port)
text = "hello world!"
sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
sock.connect(add)
sock.sendall(text.encode())#编码
data = sock.recv(1024).decode()#解码
print(data)
sock.close()
- 创建TCP服务器
#texe_sever.py VSCode
import socket
import threading
server_ip = "0.0.0.0"
server_port = 9999
server_option = (server_ip,server_port)
server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind(server_option)
server.listen(3)
print("[*]监听 %s:%d" % server_option)
def hand(client_socket):
request = client_socket.recv(1024).decode()#解码
print("[*]收到: %s" % request)
text = "[*]ACK!"
client_socket.send(text.encode())#编码
client_socket.close()
while True:
client,addr = server.accept()
print("[*]授权链接: %s:%d" % (addr[0],addr[1]))
print(addr)
print(client)
client_h = threading.Thread(target=hand,args=(client,))
client_h.start()
运行:
> text_sever.py
[*]监听 0.0.0.0:9999
> text.py
#text_sever.py
[*]监听 0.0.0.0:9999
[*]授权链接: 127.0.0.1:60071
[*]收到: hello world!
>text.py
[*]ACK!
Python 3中套接字编程中遇到TypeError: 'str' does not support the buffer interface的解决办法