string中的数据发送到连接的套接字,但在返回之前会尝试发送所有数据。
参数:同send函数
返回值 : 成功返回None,失败则抛出异常。
d)close函数
格式:s.close()
功能:关闭套接字
e)recvfrom函数
格式:s.recvfrom(bufsize[.flag])
功能:与recv()类似,区别是返回值不同
返回值:返回一个数组(data,address),其中data是包含接收数据的字符串,address是发送数据的套接字地址。
f)sendto函数
格式:s.sendto(string[,flag],address)
功能:将数据发送到套接字
参数:
string : 要发送的字符串数据
flag : 提供有关消息的其他信息,通常可以忽略
address是形式为(ipaddr,port)的元组,指定远程地址
返回值:返回值是要发送的字节数量
备注:该函数主要用于UDP协议。
g)settimeout函数
格式:s.settimeout(timeout)
功能:设置套接字操作的超时期
参数:timeout是一个浮点数,单位是秒。值为None表示没有超时期。一般,超时期应该在刚创建套接字时设置,因为它们可能用于连接的操作(如 client 连接最多等待5s )
h)getpeername函数
格式:s.getpeername()
功能:获取连接套接字的远程地址
返回值:返回值通常是元组(ipaddr,port)。
i)getsockname函数
格式:s.getsockname()
功能:获取套接字自己的地址
返回值:通常是一个元组(ipaddr,port)
socket中常用的函数就上面这些了。先用上面这些函数尝试TCP协议下的socket通信。
服务器端代码如下:
客户端代码:
注意:上述两代码块必须放在两不同的文件中,且必须先运行服务器代码,然后在开启客户端。开启服务器后,首先输出“正在等待客户端连接……”,然后进程会阻塞在accept函数中,下面的代码不会被执行,知道有客户端连接过来。开启客户端后,服务器端会先收到客户端发来的信息,然后客户端也会受到服务器发来的信息。
上面的例子中,服务器和客户端都是收发了一条信息后socket关闭,如果要保持连接进行长时间通信呢?那么,我们可以把收发函数放入一个“while True”循环中:
服务器端代码:
import socket
BUF_SIZE = 1024 #设置缓冲区大小
server_addr = ('127.0.0.1', 8089) #IP和端口构成表示地址
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) #生成一个新的socket对象
server.bind(server_addr) #绑定地址
print("socket与地址绑定完成……")
server.listen(5) #监听, 最大监听数为5
print("socket监听开始……")
client, client_addr = server.accept() #接收TCP连接, 并返回新的套接字和地址, 阻塞函数
print("报告:有客户端请求连接,正在连接……")
print('客户端地址为:{}'.format( client_addr))
while True :
mes_from_client = client.recv(BUF_SIZE) #从客户端接收数据
mes = mes_from_client.decode('utf-8')
print('客户端说:{}'.format(mes))
mes = input('回复客户端的信息>')
mes_to_client = mes.encode('utf-8')
client.sendall(mes_to_client) #发送数据到客户端
server.close()
客户端代码:
import socket
BUF_SIZE = 1024 #设置缓冲区的大小
server_addr = ('127.0.0.1', 8089) #IP和端口构成的服务器地址
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM) #返回新的socket对象
client.connect(server_addr) #连接服务器
while True:
mes = input("发送给服务器的信息> ")
mes_to_server = mes.encode('utf-8')
client.sendall(mes_to_server) #发送数据到服务器
mes_from_server = client.recv(BUF_SIZE) #从服务器端接收数据
mes = mes_from_server.decode('utf-8')
print(mes)
client.close()
运行上述代码后,客户端和服务器可以长时间维持通信。不过,使用socket时一定要注意,有发才有收,收发必相等,否则,就回出现异常。如果需要求换其他客户端与当前服务器进行通信,必须先断开当前客户端的连接。
再来尝试UDP协议下socket通信:
服务器端代码:
客户端代码:
如果需要不停收发消息,代码更改如下:
服务器端代码:
import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind(('127.0.0.1' , 8090))
while True:
msg , addr = sk.recvfrom(1024) # 此处会阻塞
print('Linux公社收到{}发来的信息,内容是:{}'.format(addr , msg.decode('utf-8')))
mes_to_server = input('>>>').encode('utf-8')#发送的数据必须是byte类型
sk.sendto(mes_to_server,addr)
sk.close()
客户端代码:
import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
ip_port = ('127.0.0.1' , 8090)
while True:
mes_to_server = input('>>>').encode('utf-8')#发送的数据必须是byte类型
sk.sendto(mes_to_server , ip_port)
ret , addr = sk.recvfrom(1024)
print