今日内容：socket网络编程
1.OSI七层协议
2.基于tcp协议的套接字通信
3.模拟ssh远程执行命令
4.tcp的粘包问题及解决方案
5.基于udp协议的套接字通信
6.socketserver
目标：开发一个C/S架构的软件
C/S:客户端----》server
B/S:浏览器----》server
server端：
1.位置必须固定/绑定一个固定的地址
2.对外一直提供服务，稳定运行
3.支持并发（让多个客户端感觉时被同时服务）
网络：
物理连接介质+互联网协议
ip+port可以标识全世界范围内独一无二的应用软件（基于网络通信协议）
任何的数据报应该分为报头+数据部分。其中报头是用来描述数据的，报头的长度是固定的
#client
import socket
#1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #tcp 流式=>SOCK_STREAM
#2.拨号
phone.connect(('127.0.0.1',8080)) #ip和端口应该是服务的IP和端口
#3.发收消息
while True:
msg=input('Please input send msg:').strip()
phone.send(msg.encode('utf-8')) #必须是bytes类型 data=phone.recv(1024)
print('服务端消息',data)
#Server
import socket
#1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #tcp 流式=>SOCK_STREAM
#2.插SIM卡
phone.bind(('127.0.0.1',8080)) #ip 应该是服务端该软件运行机器的IP地址，port(最好1024-65535)
#3.开机
phone.listen(5) #半连接池限制的是同一时刻的请求数
print('服务端启动。。。')
#4.等待电话连接的请求
conn,client_addr=phone.accept() #（套接字对象，存放客户端IP和端口的元组）
print('====>')
print(conn,client_addr)
#5.收发消息
while True:
data=conn.recv(1024) #1024单位是bytes, 代表最大接收1024 bytes
print('收到消息',data)
conn.send(data.upper())
#6.挂电话
conn.close()
#conn.send()
#7关机
phone.close()
输出：
服务端启动。。。
#异常是程序发生错误的信号，一旦程序出错
try:
l=[1,2,3]
#if 100< len(l):
l[100]
print('aa')
except IndexError:
print('索引超出范围')
print('other code')
输出：
索引超出范围
other code
#client优化
import socket
#1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #tcp 流式=>SOCK_STREAM
#2.拨号
phone.connect(('127.0.0.1',8080)) #ip和端口应该是服务的IP和端口
#3.发收消息
while True:
msg=input('Please input send msg:').strip()
phone.send(msg.encode('utf-8')) #必须是bytes类型 data=phone.recv(1024)
print('服务端消息',data)
#server 优化
import socket
#1.买手机
phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #tcp 流式=>SOCK_STREAM
#2.插SIM卡
phone.bind(('127.0.0.1',8080)) #ip 应该是服务端该软件运行机器的IP地址，port(最好1024-65535)
#3.开机
phone.listen(5) #半连接池限制的是同一时刻的请求数
print('服务端启动。。。')
#4.等待电话连接的请求
conn,client_addr=phone.accept() #（套接字对象，存放客户端IP和端口的元组）
print('====>')
print(conn,client_addr)
#5.收发消息
while True:
try:
data=conn.recv(1024) #1024单位是bytes, 代表最大接收1024 bytes
if len(data) == 0:break # for linux/MAC
print('收到消息',data)
conn.send(data.upper())
except ConnectionResetError: # for windows
break
#6.挂电话
conn.close()
#conn.send()
#7关机
phone.close()
import os
res=os.system('dir')
print('结果',res)
输出：
结果 0
import subprocess
import time
obj=subprocess.Popen('dir',shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
#print (obj)
stdout=obj.stdout.read() print(stdout.decode('gbk'))
stdout=obj.stdout.read()
time.sleep(0.1)
输出：
驱动器 C 中的卷是 OS
卷的序列号是 E0C1-2532
C:\Users\andy 的目录
2018/08/26 17:40 <DIR> .
2018/08/26 17:40 <DIR> ..
2018/03/20 22:28 <DIR> .anaconda
2017/07/29 20:27 <DIR> .android
2018/05/25 22:20 <DIR> .astropy
2018/03/21 00:17 <DIR> .conda
2018/05/05 21:53 43 .condarc
2018/08/26 09:37 <DIR> .ipynb_checkpoints
2018/03/20 22:27 <DIR> .ipython
2018/05/06 17:59 <DIR> .jupyter
2018/05/25 22:15 <DIR> .PyCharm2016.2
2018/08/16 23:10 <DIR> 3D Objects
2018/08/05 14:44 43 a.txt
2018/03/20 22:15 <DIR> Anaconda2
2018/05/06 16:12 <DIR> Anaconda3
2018/05/05 21:53 <DIR> AnacondaProjects
2018/08/05 15:21 63 b.json
2018/08/05 15:21 63 c.json
2018/08/16 23:10 <DIR> Contacts
2018/07/29 22:32 23,933 Day06.ipynb
import struct
#可以将整形打包成固定长度的bytes类型，可以基于网络传输
res=struct.pack('i',21215)
print(res,len(res)) res1=struct.unpack('i',res)
print(res1[0])
输出：
b'\xdfR\x00\x00' 4
21215