网络编程：
网络通信三要素：IP地址（127.0.0.1：回环地址，保留地址，可用于简单的测试网卡是否有效，表示本机），端口号，传输协议
socket编程：
#family type
SOCK_STREAM:tcp
SOCK_DGRAM:udp
#family=AF_INET:服务器之间的通信IP v4
#family=AF_INET6:服务器之间的通信IP v6
#family=AF_UNIX：unix不同进程之间的通信
server下的方法：
bind()
listen()
accept()
send()
sendall()
recv()
close()
client下的方法：
connect()
send()
sendall()
recv()
close()
传送和接收的内容是byte类型，必须是一收一发，否则会导致发送的数据没有收到
在python中有两种类型，str和bytes
str：unicode编码的称为str类型
bytes：十六进制
由str到bytes叫编码
由bytes到str叫解码
简单的服务器和客户之间的通信：
server：服务端
import socket
sk=socket.socket() #sk是建立连接用的,sk是socket对象
print(sk)
address=('127.0.0.1',8000)
sk.bind(address) #参数必须是元祖,绑定
sk.listen(3) #参数为排队的个数
print('waiting....')
conn,addr=sk.accept()
print(conn)
# inp=input('>>>')
# conn.send(bytes(inp,'utf8'))
data=conn.recv(1024)
print(str(data,'utf8'))
conn.close()
client：客户端
import socket
sk=socket.socket()
address=('127.0.0.1',8000)
sk.connect(address)
# data=sk.recv(1024) #阻塞
# print(str(data,'utf8'))
data=sk.send(bytes('博客','utf8'))
# print(str(data,'utf8'))
sk.close()
不间断的通信：
server：服务器端
import socket
sk=socket.socket()
print(sk)
address=('127.0.0.1',8000)
sk.bind(address)
sk.listen(3)
print('waiting......')
while 1:
conn,addr=sk.accept()
print(addr)
while 1:
try:
data=conn.recv(1024)
except Exception :
break
print('........',str(data,'utf8'))
if not data:break
inp=input('>>>')
conn.send(bytes(inp,'utf8'))
sk.close()
client：客户端
import socket
sk=socket.socket()
print(sk)
address=('127.0.0.1',8000)
sk.connect(address)
while True:
inp=input('>>>')
if inp=='exit':
break
sk.send(bytes(inp,'utf8'))
data=sk.recv(1024)
print(str(data,'utf8'))
sk.close()
命令编程：
server：服务器端
import socket
import subprocess
sk=socket.socket()
print(sk)
address=('127.0.0.1',8000)
sk.bind(address)
sk.listen(3)
print('waiting......')
while 1:
conn,addr=sk.accept()
print(addr)
while 1:
try:
data=conn.recv(1024)
except Exception :
break
if not data:break
print('........',str(data,'utf8'))
obj=subprocess.Popen(str(data,'utf8'),shell=True,stdout=subprocess.PIPE)
cmd_result=obj.stdout.read() #cmd_result类型是bytes，Windows默认是gbk编码
result_len=bytes(str(len(cmd_result)),'utf8')
conn.sendall(result_len) #粘包现象
conn.recv(1024) #粘报包的解决办法，隔开
conn.sendall(cmd_result)
sk.close()
client：客户端
import socket
sk=socket.socket()
print(sk)
address=('127.0.0.1',8000)
sk.connect(address)
while True:
inp=input('>>>')
if inp=='exit':
break
sk.send(bytes(inp,'utf8'))
result_len=int(str(sk.recv(1024),'utf8'))
sk.sendall(bytes(str('ok'),'utf8'))
print(result_len)
data=bytes()
while len(data)!=result_len:
recv=sk.recv(1024) #不能超过8k,重复接收
data+=recv
print(str(data,'gbk'))
sk.close()
文件上传：
server：服务器端
import socket
import subprocess
import os
sk=socket.socket()
print(sk)
address=('127.0.0.1',8000)
sk.bind(address)
sk.listen(3)
print('waiting......')
BASE_DIR=os.path.dirname(os.path.abspath(__file__))
while 1:
conn,addr=sk.accept()
while 1:
data=conn.recv(1024)
cmd,filename,filesize=str(data,'utf8').split('|')
path=os.path.join(BASE_DIR,'file',filename)
filesize=int(filesize)
f=open(path,'wb')
has_recv=0
while has_recv!=filesize:
data=conn.recv(1024)
f.write(data)
has_recv+=len(data)
f.close()
sk.close()
client：客户端
import socket
import os
sk=socket.socket()
print(sk)
address=('127.0.0.1',8000)
sk.connect(address)
BASE_DIR=os.path.dirname(os.path.abspath(__file__))
while True:
inp=input('>>>').strip() #post|file.png
cmd,path=inp.split('|')
path=os.path.join(BASE_DIR,path)
filename=os.path.basename(path)
file_size=os.stat(path).st_size
file_info='post|%s|%s'%(filename,file_size)
sk.sendall(bytes(file_info,'utf8'))
f=open(path,'rb')
has_sent=0
while has_sent!=file_size:
data = f.read(1024)
sk.sendall(data)
has_sent+=len(data)
f.close()
print('上传成功')
sk.close()