8.1 基于TCP协议的套接字通信
s.bind() 绑定(主机,端口号)到套接字s.listen() 开始TCP监听s.accept() 被动接受TCP客户的连接,(阻塞式)等待连接的到来
s.connect() 主动初始化TCP服务器连接s.connect_ex() connect()函数的扩展版本,出错时返回出错码,而不是抛出异常
[url=]
[/url]
s.recv() 接收TCP数据s.send() 发送TCP数据(send在待发送数据量大于己端缓存区剩余空间时,数据丢失,不会发完)s.sendall() 发送完整的TCP数据(本质就是循环调用send,sendall在待发送数据量大于己端缓存区剩余空间时,数据不丢失,循环调用send直到发完)s.recvfrom() 接收UDP数据s.sendto() 发送UDP数据s.getpeername() 连接到当前套接字的远端的地址s.getsockname() 当前套接字的地址s.getsockopt() 返回指定套接字的参数s.setsockopt() 设置指定套接字的参数s.close() 关闭套接字[url=][/url]
s.setblocking() 设置套接字的阻塞与非阻塞模式s.settimeout() 设置阻塞套接字操作的超时时间s.gettimeout() 得到阻塞套接字操作的超时时间
s.fileno() 套接字的文件描述符s.makefile() 创建一个与该套接字相关的文件
8.2 客户端与服务端操作( 基于TCP )
[url=][/url]
import socket #地址家族，基于网络 TCP协议phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 创建客户套接字phone.connect((‘127.0.0.1‘,8080))#服务端ip和端口 # 尝试连接服务器?phone.send(‘你好‘.encode(‘utf-8‘)) # 发消息b‘hello‘data=phone.recv(1024) #收消息?print(data.decode(‘utf-8‘))?phone.close() # 关闭客户套接字[url=][/url]
[url=][/url]
import socket?phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 创建服务器套接字phone.bind((‘127.0.0.1‘,8080) #地址绑定到套接字（0-65535） 0-1024给系统用的phone.listen(5) # 监听链接?print(‘start...‘)conn,client_addr=phone.accept() # 接受客户端链接print(‘连接来了：‘,conn,client_addr) #conn: 连接对象 client_addr: 客户端的ip和端口 ?# 收发消息msg=conn.recv(1024) #收消息，1024是一个最大的限制print(‘客户端的消息: ‘,msg)conn.send(msg+b‘SB‘)?# 挂电话conn.close() #关闭客户端套接字# 关机phone.close() #关闭服务器套接字(可选)[url=][/url]
8.21 加上通信循环与连接循环
[url=][/url]
import socket?phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM)phone.bind((‘127.0.0.1‘,8081))phone.listen(5)?print(‘start...‘)while True: # 连接循环 conn,client_addr=phone.accept() print(‘客户端 ‘,client_addr)? while True: # 通信循环 try: msg=conn.recv(1024) print(‘客户端的消息: ‘,msg) conn.send(msg+b‘SB‘) except ConnectionResetError: #只有在当前客户端停止向服务端发送信息时，下一个客户端才能发送 break conn.close()phone.close()[url=][/url]
[url=][/url]
import socket?phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 买电话phone.connect((‘127.0.0.1‘,8081)) # 尝试连接服务器 地址为服务端的ip和端口?while True: msg=input(‘>>>: ‘).strip() phone.send(msg.encode(‘utf-8‘)) # 发消息b‘hello‘ data=phone.recv(1024) #收消息 print(data.decode(‘utf-8‘))?phone.close()[url=][/url]
8.3 远程执行命令的程序
res=subprocess.Popen(cmd.decode(‘utf-8‘),shell=True,stderr=subprocess.PIPE,stdout=subprocess.PIPE)
[url=][/url]
from socket import *client=socket(AF_INET,SOCK_STREAM)client.connect((‘127.0.0.1‘,8080))?while True: cmd=input(‘>>>: ‘).strip() if not cmd: continue client.send(cmd.encode(‘utf-8‘)) res=client.recv(14744) print(res.decode(‘gbk‘))#subprocess返回byte类型，需要gbk解码client.close()[url=][/url]
[url=][/url]
from socket import *import subprocess?server=socket(AF_INET,SOCK_STREAM)server.bind((‘127.0.0.1‘,8080))server.listen(5)?while True: conn,client_addr=server.accept() #(连接对象，客户端的ip和端口) print(client_addr) while True: try: cmd=conn.recv(1024) obj=subprocess.Popen(cmd.decode(‘utf-8‘),#subprocess返回byte类型,可直接传输但需要gbk解码 shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE ) stdout=obj.stdout.read() stderr=obj.stderr.read() total=stdout + stderr# 发送真实的数据 conn.send(total) except ConnectionResetError: break conn.close()server.close()[url=][/url]
python 之 网络编程（基于TCP协议的套接字通信...
原文：https://www.cnblogs.com/heimaguangzhou/p/11775149.html