Day10
上节回顾：
socket
1 导入模块
2 创建socket
3
字节
send sendall
10字节 = send("alex123123deqasdsa")
sendall: #会源源不断的发送完
while True:
10字节 = send("alex123123deqasdsa")
10字节 = send("alex123123deqasdsa")
10字节 = send("alex123123deqasdsa")
recv(2048) #最多接收2048字节
粘包：ack
socketserver
1 自定义类
2 继承类
3 handle方法
4 socketserver == 调用自定义类
5 运行 forever
上节作业
1 socket 发送字符串
2 socket发送文件
客户端：
文件大小
发消息
服务器端：
接收消息（根据文件大小）
客户端：
json ->用户 密码
字符串
服务端：
用户验证
接受，subprocess > win > gbk编码的字节
上传文件（大小）
发消息
作业问题：
断点续传
文件：
a 追加
w 清空写
文件指针：
seek(num)
小知识点：
作用域：
python中无块级作用域
java/c# 不可
python/javascript 可以
if 1==1：
name = "alex"
print(name)
if 1 == 1 :
name = "alex"
print(name)
def func():
name1 = "alex"
func()
print(name1)
name = "alex"
def f1():
print(name)
def f2():
name = "eric"
return f1
ret = f2()
ret()
python以函数作为一个作用域
python 作用域链，由内向外找。，直到找不到报错。
对于作用域来说，在函数为执行之前，作用域和作用域链都已经确定了
li = [lambda :x for x in range(10)]
print(li)
#函数在没有执行前 ，内部代码不执行。
li = [lambda :x for x in range(10)]
print(li)
print(li[0]())
#函数在没有执行前 ，内部代码不执行。
9
li = [x for x in range(10)] print(li) li = [lambda :x for x in range(10)] print(li) print(li[0]()) # #函数在没有执行前 ，内部代码不执行。
li = []
for i in range(10):
def f1():
return i
li.append(f1)
li[0]()
py27多继承 py35多继承
py35都继承object 27中的新式类
socketserver源码***
****支持并发处理socket****
IO多路复用：
概述：
select,poll,epoll
select 个数限制 1024
poll 无个数限制 不能跨平台
epoll 谁变化了 主动告诉epoll
监听socket对象内部是否变化了？
什么时候变化？连接或收发消息
服务器端的socket对象发生变化？就有新链接来了
sk:有新连接来了。。。
conn：要收"发"消息了
IO多路复用 == 监听socket对象内部是否变化了？
win--select
rlist,w,e = select.select([sk,],[],[],1) 1是超时时间 1s
#rlist中socket对象列表
#sk有变化 rlist=[sk,]
#sk无变化 rlist= []
for r in rlist:
conn, address = r.accept()
conn,sendall(byte("hello"))
实现读写分离
1 #!/usr/bin/env python 2 # -*- coding: UTF-8 -*- 3 # Author: Aaron Shen 4 5 import socket 6 import select 7 8 sk = socket.socket() 9 sk.bind(("127.0.0.1", 9999)) 10 sk.listen(5) 11 12 inputs = [sk, ] 13 outputs = [] 14 message = {} 15 16 while True: 17 rlist, wlist, e, = select.select(inputs, outputs, [], 1) 18 print(len(inputs), len(rlist), len(wlist), len(outputs)) 19 20 for r in rlist: 21 if r == sk: 22 23 print(r) 24 conn,addr = r.accept() 25 inputs.append(conn) 26 message[conn] = [] 27 conn.sendall(bytes("hello",encoding="utf-8")) 28 29 else: 30 # r.recv(1024) 31 print("==========") 32 try: 33 ret = r.recv(1024) 34 if not ret: 35 raise Exception ("断开连接") 36 else: 37 outputs.append(r) 38 message[r].append(ret) 39 except Exception as e: 40 inputs.remove(r) 41 del message[r] 42 43 for w in wlist: 44 msg = message[w].pop() 45 rspe = msg + bytes("response", encoding="utf-8") 46 w.sendall(rspe) 47 outputs.remove(w)
1 #!/usr/bin/env python 2 # -*- coding: UTF-8 -*- 3 # Author: Aaron Shen 4 5 import socket 6 sk = socket.socket() 7 sk.connect(("127.0.0.1",9999)) 8 9 date = sk.recv(1024) 10 print(date) 11 12 while True: 13 inp = input(">>>") 14 sk.sendall(bytes(inp,encoding="utf-8")) 15 print(sk.recv(1024)) 16 17 sk.close()
多线程，多进程，协程
概述：
Alex甄嬛西游传
1 一个应用程序，可以有多进程和多线程，默认是单进程，单线程
2 默认：单进程，单线程。
3 单进程，多线程
多线程： IO操作 -- 不占用cpu 可以提高并发
多线程提高并发
计算性操作，需要占用cpu ，无法提高并发
多进程提高并发
4 GIL 全局解释器锁
====
多线程，多进程 提供并发
IO密集型：多线程
计算密集型 多进程提高并发
PS IO操作 不占用cpu GIL 全局解释器
如何创建线程
def f1(arg):
print(arg)
#for i in range(10):
import threading
t = threading.Thread(target=f1, args=(123, )) #子线程
t.setDaemon(True) #true 表示主线程不等此子线程 默认是False
t.start() #不代表当前线程会被立即执行。
t.join(2) #主线程停止，等待子线程执行完在执行
#参数2 表示主线程最多等待2秒
f1(111)
print("end")
def f1(arg):
print(arg)
#for i in range(10):
import threading
t = threading.Thread(target=f1, args=(123, )) #子线程
t.setDaemon(True) #true 表示主线程不等此子线程
t.start() #不代表当前线程会被立即执行。
t.join(2) #主线程停止，等待子线程执行完在执行
#参数2 表示主线程最多等待2秒
f1(111)
print("end")