成都有什么好玩的地方 排行榜,郑州seo关键词推广,佛山网站建设模板建站,出口跨境电子商务1、套接字介绍 socket起源于Unix#xff0c;遵循“一切皆文件”出发点#xff0c;都可以用“打开open – 读写write/read – 关闭close”模式来操作。 在设计模式中#xff0c;Socket把复杂的TCP/IP协议族隐藏在Socket接口后面#xff0c;Socket去组织数据#xf…1、套接字介绍 socket起源于Unix遵循“一切皆文件”出发点都可以用“打开open – 读写write/read – 关闭close”模式来操作。 在设计模式中Socket把复杂的TCP/IP协议族隐藏在Socket接口后面Socket去组织数据以符合指定的协议。Socket是应用层与TCP/IP协议族通信的中间软件抽象层它是一组接口。 2、套接字服务过程TCP协议 3、一个简单服务器示例 ssocket.socket(socket.AF_INET,socket.SOCK_STREAM) · 协议族通常为AF_INET表示互联网协议族TCP/IP协议族。 · socket类型SOCK_STREAM流式套接字提供可靠的、面向连接的通信流:它使用TCP协议从而保证了数据传输的正确性和顺序性(TCP可靠的、重传、有连接的一般用于控制命令)。 3.1 server s.listen() 0成功-1失败 · 服务器端套接字一直处于监听状态不受客户端连接的影响。 · 接收到客户端套接字的连接请求就会响应客户端套接字的请求建立一个新的线程并把服务器端套接字的描述发送给客户端。 s.accept() · 返回新的socket用于完成和本次接受的客户端通信。从已完成连接的列表返回连接没有连接线程则进入阻塞睡眠状态。
import socket
import struct
import json
from tqdm import tqdmserversocket.socket(socket.AF_INET,socket.SOCK_STREAM)
serversocketaddr(127.0.0.1,12345)
server.bind(serversocketaddr)
server.listen(1024)clientsocket,addrserver.accept()
print(Connection from %s has been established! % clientsocket)# recv多条数据出现粘包现象可通过增加header解决规定内容长度获取指定内容
print(--------------BEGIN-----------------)
header_len_bytesclientsocket.recv(4) # 接收报头长度固定4字节
header_lenstruct.unpack(i,header_len_bytes)[0]
headerclientsocket.recv(header_len).decode()
headerjson.loads(header)
file_sizeheader[file_size]
file_dataclientsocket.recv(file_size)print([{}]{}.format(type(file_data),file_data))
print(--------------END-----------------,\n)
server.close() 3.2 client
import socket
import os.path
import json
import structclientsocket.socket(socket.AF_INET,socket.SOCK_STREAM)
serversocketaddr(127.0.0.1,12345)
client.connect(serversocketaddr)file_name/Users/test/client.png
file_sizeos.path.getsize(file_name)
with open(file_name,rb) as file:file_datafile.read()header {file_size: file_size,file_name: file_name}header_bytes json.dumps(header).encode()header_length struct.pack(i, len(header_bytes))client.send(header_length)client.send(header_bytes)# client.sendall(file_data)client.send(bEND)client.close()
3.3 data exchange
· 内容以字节码传输bytes · s.send() 发送内容只支持字节类型.多个数据包存在粘包情况需要处理。 · s.sendall() 发送数据直到所有的数据都发送完成或报错
3.4 RUN控制台
· 开始进程 /usr/local/bin/python3.7 server_file_name #python运行目录 运行文件 /usr/local/bin/python3.7 client_file_name
· 结束进程 sudo lsof -i :port # 终端查询当前端口的详情获取到PID kill -9 PID
