1.面向对象编程

面向过程编程,过程是解决问题的步骤,一步一步规划好,先干嘛后干嘛

优点:编程简单,复杂的问题流程化

缺点:扩展性差

  1. def denglu:
  2. 输入密码账户
  3. name = input(">>>>>用户")
  4. passwd = input(">>>>>密码")
  5. return {"name:name,"pwd":pwd}
  6. def check(user_info):
  7. 检查正确与否
  8. is_valis = TRUE
  9. if len(user_info['name']) == 0:
  10. print('用户名并不能为空')
  11. is_valis = False
  12. if len(user_info['pwd']) < 6 :
  13. print('密码不能少于6位')
  14. valis = False
  15. return {'is_valis':valis,'user_info':user_info}
  16. def regeister(check_info):
  17. if check_info['is_valid']:
  18. with open('xxx.text','w',encoding='utf-8') as f:
  19. def main():
  20. user info = denglu()
  21. check info = check(user info)
  22. regeister (check info)
  23. if __name__ == '__main__'
  24. main
  25. ------------------------------------------------
  26. __开头和__结尾就是python内置的,在特定的时候触发

面向对象编程: 核心就是对象(python一切皆对象)

  1. 什么是对象:
  2. 特征与技能的结合
  3. 优点:可扩展性好
  4. 缺点:编程复杂
  5. 应用场景:客户需求经常变化,互联网应用,游戏,企业内部应用

1.1类:

一系列对象相似的特征与技能的结合

类的定义与实例化对象

先定义类根据类实例化对象

  1. class func():
  2. def __init__(selfname,age) # 初始化方法,实例化对象的时候会触发
  3. name = name
  4. age = age
  5. # 对象 = 类名() 会自动执行类中的__init__方法
  6. n1 = func() # 实例化一个对象

初识面向对象

  1. 定义类 在类中定义方法,在方法中实现具体的功能
  2. 实例化类并得到一个对象,通过对象去调用执行方法
  3. 类名首字母大写
  4. py3之后默认类都继承object
  5. 在类中编写的函数叫方法
  6. 每一个方法的第一个参数是self

对象和self

在每个类中都可以定制特殊的—init—初始化方法,在实例化类创建对象的时候自动执行

self 接收的是调用方法的当前对象,本质就是一个参数

对象,基于类实例化出来的一块内存,默认里面没有数据,经过—init—方法,可以在内存中初始化一些数据

  1. 根据类创建对象,也就是内存的一块区域
  2. 执行--init--方法,模块会将创建的那块区域的内存地址当参数传递给self

常见成员:

  1. 实例变量,属于对象,只能通过对象调用,__init__方法下的变量就是实例变量
  2. 类变量,在类中定义的变量
  3. 绑定方法 属于类 绑定给对象和绑定到类 可以用对象或类调用

1.2如何使用类

  1. class func:
  2. school = "lufei" # 数据属性 类变量
  3. def learn(self): # 函数属性
  4. print("learn")
  5. def eat(self): #函数属性
  6. print("eat")
  1. 查看类的名称空间 printfunc.__dict__
  2. 类定义完成后对类的属性的增删改查方法 就是操作func.__dict__这个字典
  3. 增加一个数据属性 func.county = 'china'
  4. 删除 del func.county
  5. func.school = 'luffycity'
  6. print(func.__dict__[school])
  7. 实例化出对象 obj = func() # 实例化出来的类有自己独立的存储空间

1.3 如何使用对象

—init—方法用来为对象定制对象自己独有的特征(在实例化对象的时候触发)

init方法实例化的步骤

  1. 1.先产生一个空对象
  2. 2.参数传值
  3. 3.根据init方法初始化
  1. class func:
  2. school = 'liu'
  3. def __init__(self,name,age) # self接收的是obj
  4. self.name = name
  5. self,age = age
  6. def learn(self):
  7. def eat(self):
  8. obj = func('utr',19)
  1. 对象的增删改查
  2. 增加 obj.class_name = 'python'
  3. 删除 del obj.age
  4. obj.name = "luffycity"
  5. obj.name

1.3.1属性查找与绑定方法

  1. 类中的数据属性也就是变量是所有对象共有的,指向的是一个内存地址
  2. 类中的函数属性 :是绑定给对象的,绑定到不到的对象是不同的,内存地址是不一样的
  3. 类调用自己的函数属性,(self)需要手动传值
  4. 类中的函数属性是绑定的对象使用的,哪个对象来调用,就将对象当作第一个参数传入
  5. 对象使用属性的时候,现在自己的空间寻找,没有去类的空间寻找,有继承就去父类寻找

1.3.2 一切皆对象

  1. 站在不同的角度,定义出来的类是不同的
  2. 现实当中的类并不等于代码当中的类,如现实中的公司类,在程序中需要拆分成部门类业务等

1.3.3面向对象可扩展性强

1.3.4 对象的嵌套

  1. class student(object):
  2. def __init__(self):
  3. self.name =name
  4. self.age =age
  5. def message =(self):
  6. data = '学生{},{}'.fornat(self.name,self.age)
  7. print(data)
  8. stud1 = student('123',18)
  9. stud2 = student('456',20)
  10. stud3 = student('789',22)
  11. class classes(object):
  12. def __init__(self,title):
  13. self.title = title
  14. self.student_list = []
  15. def add_student(self,stud_object):
  16. self.student_list.append(stud_object)
  17. def add_students(self,stu_object_list)
  18. for stu in stu_object_list:
  19. self.add_student(stu)
  20. def show_members(self):
  21. for item in self.student_list:
  22. print(item)
  23. c1 = classes('三年二班')
  24. c1.add_studnet(s1)
  25. c1.add_students([s2,s3])
  26. print(c1.title)
  27. print(c1.student_list)

1.4 类的继承与重用性

继承是什么是什么的关系

将类中公共的方法提取到基类中

查看继承了哪些父类 派生类.—bases— 元组形式

  1. class func1:
  2. pass
  3. class func2:
  4. pass
  5. class func3(func1): #func3继承func1的属性 func1是基类 func3叫派生类
  6. pass

1.4.1继承的属性查找

  1. 首先在自己的空间中寻找,没有则去对应的类中寻找,类中也没有去继承的基类中寻找(关注self是谁,不管找到哪遇到self就从先从自己空间中找起)

1.4.2派生

  1. 当派生类中有自己的属性,则首先使用自己的

1.4.3继承的实现原理

  1. 定义的类,python会计算出一个方法解析顺序(MRO)列表,这个MRO列表就是一个简单的所有基类的线性顺序列表 (查看线性列表,派生类.mro())也就是继承顺序的列表
  2. python2 区分
  3. 新式类:继承object的类,以及他的子类都是新式类
  4. 经典类: 没有继承object,以及他的子类都是叫经典类
  5. python3 只有新式类,默认继承object
  6. 深度优先:经典类
  7. 广度优先:新式类

1.4.4派生类重用基类的属性

super(自己的类,self).—init—(属性名) ## 顺着mro列表往后找,依赖继承关系 super(自己的类,self)得到一个对象然后调用基类中的方法

  1. class func:
  2. def __init__(self,name,age,igh)
  3. self.name = name
  4. self.age = age
  5. self.high = high
  6. def ease(self,food)
  7. print("{}的food".formt(self.name))
  8. class gurn(func):
  9. def att():
  10. super(gurn,self).ease('苹果')
  1. class A:
  2. def f1(self):
  3. print('from A')
  4. super().f1()
  5. class B:
  6. def f1(self):
  7. print('from B')
  8. class C(A,B):
  9. pass
  10. print(C.mro()) #
  11. # [<class '__main__.C'>,<class '__main__.A'>,<class '__main__.B'>]
  12. c =C()
  13. c.f1()
  14. 1. C中没有f1属性,根据继承去A中找
  15. 2. A中有f1属性先输出from A 然后执行super().f1()执行的是Bf1
  16. 3. 因为super是根据mro往后找也就是Bf1,因为是基于c产生的mro列表,现在Af1已经找完了mro列表中的下一个是B,所以是输出from B, (根据c产生的mro当前找到哪了继续往后找)

1.4.5抽象类与归一化

抽取相似的地方得到一个父类,子类中的属性必须实现父类中的规范

抽象出来的不定义具体的功能,只写规范

抽象类只能被继承,不能被实例化

子类中必须有抽象类的方法

使用abc第三方模块实现

  1. import abc
  2. class animal(metaclass= abc.ABCMeta):
  3. @abc.abstracmethod # 子类中必须有run方法
  4. def run(self)
  5. pass
  6. @abc.abstracmethod # 子类中必须有eat方法
  7. def eat(self):
  8. pass
  9. class Pig(animal):
  10. def run(self):
  11. class Dog:
  12. def zou(self):

1.4.6 mro列表 (继承关系) 与C3算法

  1. class c(object):
  2. pass
  3. class B(object):
  4. pass
  5. class A(B,C):
  6. print(A.mro()) 列表形式
  7. print(A.__mro__) 元组形式
  1. mro(A) = [A] + [B,C] #mroA= [ABC]
  2. mro(A)=[A] + merge( mro(B),mro(c),[B,C] )
  3. #A的继承关系 首先将[A]放进来 merge接收A左边的继承关系,然后是右边的继承关系,然后是所继承的父类[B,C]
  4. mro(A)=[A] + merge( [B,object],[C,object],[B,C] )
  5. # 第一个参数
  6. mro(A)=[A]+[B,C,object]
  7. mro(A) = [A,B,C,object]
  8. # merge 计算规则
  9. 将第一个参数的第一个值(此时为B),与其他参数的除第一个值以外的比较,判断是否在里面
  10. 如果不在将其提取出来,去掉原值,(就是将参数里面的所有的B剔除掉)
  11. 如果在里面跳过,进行下一个参数的第一个值开始比较,最后把剩下的提取出来

4.面向对象 - 图1

图中的继承关系使用C3算法计算过程
4.面向对象 - 图2

[^]: 从左到右,深度优先,大小钻石,留住顶端 ,可以更快的找到类的继承关系,钻石是指方形的继承

1.5多态与多态性

python默认支持多态(这种方式称之为鸭子类型)

(在继承的背景使用下有时候也叫多态性)

  1. 多态是指同一类物体有多种形态(如文件有文本文件和可执行文件)
  2. 多态性是值不考虑实例类型(对象类型)的情况下使用实例(对象)比如+ 支持文本相加,数字相加,+本身不用考虑加的是什么类型

增加了程序的灵活性 :使用者都是同一种形式去调用 func(n1)

增加了程序的可扩展性:通过继承创建一个新的类,使用者不用更改自己的代码还是用func(n1)调用

鸭子类型:看起来像就是

  1. def func(arg):
  2. v1 = arg.copy()
  3. print(v1)
  4. func('123')
  5. func([11,22,33,44])
  6. # 将字符串或者列表传给arg时候,arg可以接收任意类型的数据,只要参数有copy方法就可以
  7. # 这种形式就可以理解为多态
  8. # 序列类型,列表 元组 字符串
  9. l = list([1,2,3])
  10. t = tuple((a,b))
  11. s = str ('he')
  12. l.__len__()
  13. t.__len__()
  14. s.__len__()

1.6封装(私有方法)

将同一类的方法封装到一个类中

将数据封装到对象中,如—init—

封装相当隐藏 (在属性名字前面加__)对象无法直接调用 又叫成员修饰符

  1. class A:
  2. __X = 1 #在类的名称空间中为_A__X 查看名称空间 A.__dict__
  3. def __init__(self,name):
  4. self.__name = name # 会变形
  5. def __foo(self):
  6. pass
  7. A.__C = 2 # __C不会变形可以直接调用
  8. print(A.__C)
  9. """
  10. 特点
  11. 类的外部无法直接调用 (A.__X) 可以通过调用(A._A__X)
  12. 类内部可以直接调用 (A.__X)
  13. 子类无法覆盖父类__开头的属性(覆盖是指两个类中相同的属性名)
  14. 这种隐藏注意的问题
  15. 这种变形只在定义阶段发生一次,类定义阶段之后赋值则不会变形
  16. 在继承中,父类如果不想让子类覆盖自己的方法,可以将方法定义为私有方法也就是加__,子类不会继承父类的私有方法
  17. """

封装到底是要干什么

1.6.1封装数据属性干什么:明确的区分内外控制外部对隐藏属性的操作行为

  1. class People:
  2. def __init__(self,name,age)
  3. self.__name = name
  4. self.__age = age
  5. def tell_info(self):
  6. print('name{} age{}'.format(self.__name,self.__age))
  7. def set_info(self,name,age):
  8. if not isinstance(name,str):
  9. print('name必须是字符串')
  10. if not isinstance(age,int):
  11. print('age必须是数字')
  12. self.__name = name
  13. self.__age = age
  14. p = people('liu',18) # 外部无法直接调用p.__name
  15. p.tell_info() # 通过统一的接口调用
  16. p.set_info('123',45)

1.6.2 封装函数属性干什么:隔离复杂度

  1. class ATM:
  2. def __card(self):
  3. print('插卡')
  4. def __auth(self):
  5. print('password')
  6. def __input(self):
  7. pirnt('输入取款金额')
  8. def __print_bill('self'):
  9. print('打印账单')
  10. def __take_money(self):
  11. print("取款")
  12. def withdraw(self):
  13. self.__card
  14. self.__auth
  15. self.__input
  16. self.__print_bill
  17. self.__take_money
  18. a = ATM()
  19. a.withdraw()

1.6.3封装与扩展性

  1. class Room:
  2. def __init__(self,name,owner,height,weight,length)
  3. self.name = anme
  4. self.owner = owner
  5. self.__weight = weight
  6. self.__length = length
  7. def tell_area(self):
  8. retuen self.__weight * self.length
  9. a = Room('o','kiler',10,10,10)
  10. a.tell_area()

1.6.4 property 装饰器 (函数,特性)

在方法前面加上@property 对象在调用方法的时候不用加()了

  1. class People:
  2. def __init__(self, name, weight, height):
  3. self.name = name
  4. self.weight = weight
  5. self.height = height
  6. @property
  7. def Bmi(self):
  8. return self.weight / (self.height ** 2)
  9. a = People('kiler',70,1.74)
  10. a.Bmi
  1. class people:
  2. def __init__(self,name):
  3. self.__name = name
  4. @property #访问 是不能给name赋值的,因为name是一个方法
  5. def name(self):
  6. return (self.__name)
  7. @name.setter #修改
  8. def name(self,value) #现在是可以赋值的,前提是name被property装饰
  9. if not instance(val,str)
  10. print("名字必须是字符串")
  11. return
  12. self.__name = value
  13. @name.deleter #删除
  14. def name(self)
  15. print('不允许删除')
  16. p = People('liu')
  17. print(p.name)
  18. p.name = 'li' # 执行setter
  19. del p.name # 执行deleter

1.7绑定方法和非绑定方法(成员)

  1. 在类定义的方法分为两类
  2. 绑定方法 (绑定给谁就由谁来调用,将调用者当第一个参数自动传给self
  3. - 绑定到对象的方法:在类定义的时候没有被任何装饰器修饰的
  4. - 绑定到类的方法:在方法前面加@classmethod,则就是绑定给类的方法,类在调用的时候,将类当作第一个参数传给cls
  5. 非绑定方法 又叫静态方法
  6. 就是不与类或者对象绑定(类可以用对象也可以用,不会自动传值,需要手动传参)就是类中普通的函数
  7. 在方法前面加@staticmethod

1.7.1绑定方法和非绑定方法的使用

  1. 绑定到对象的方法
  2. class people:
  3. def__init__(slef,name,age,sex):
  4. self.name = name
  5. self.age = age
  6. self.sex = sex
  7. def tell_info(self): 绑定到对象的方法
  8. print("{},{},{}".format(self.name,self.age,self.sex))
  9. p = people('kiler',18,20)
  10. p.tell_info()
  11. 绑定给对象,应该由对象来调用,自动将对象本身当作第一个参数传入p.tell_info(p)
  1. import settings # settings包里面有name age sex
  2. class people:
  3. def __init__(self, name, age, sex):
  4. self.name = name
  5. self.age = age
  6. self.sex = sex
  7. def tell_info(slef): #绑定到对象的方法
  8. print("{},{},{}".format(slef.name, slef.age, slef.sex))
  9. @classmethod # 绑定给类的方法
  10. def from_setting(cls):
  11. obj = cls(
  12. settings.name,
  13. settings.age,
  14. settings.sex
  15. )
  16. print(obj.name)
  17. return obj #是一个对象
  18. # 绑定给类,由类调用,自动将类本身当作第一个参数传入p=people.from_setting(people)
  19. p = people.from_setting()
  20. p.tell_info()
  1. import time
  2. import hashlib
  3. import settings # settings包里面有name age sex
  4. class people:
  5. def __init__(self, name, age, sex):
  6. self.id = self.id()
  7. self.name = name
  8. self.age = age
  9. self.sex = sex
  10. def tell_info(self): #绑定到对象的方法
  11. print("{},{},{}".format(slef.name, slef.age, slef.sex))
  12. @classmethod #绑定给类的方法
  13. def from_setting(cls):
  14. obj = cls(
  15. settings.name,
  16. settings.age,
  17. settings.sex
  18. )
  19. print(obj.name)
  20. return obj #是一个对象
  21. @staticmethod #静态方法 非绑定方法
  22. def id():
  23. m = hashlib.md5(str(time.time()).encode('utf-8'))
  24. return m.hexdigest()
  25. # 绑定给类,由类调用,自动将类本身当作第一个参数传入
  26. p = people.from_setting()
  27. p.tell_info()
  28. p1 = people('12',12,12)
  29. print(p1.id())

1.7.2 属性@property

属性由绑定方法+特殊装饰器组合

在方法前面加上@property 对象在调用方法的时候不用加()了

  1. class People:
  2. def __init__(self,name,weight,height)
  3. self.name = name
  4. self.weight = weight
  5. self.height = height
  6. @property
  7. def Bmi(self):
  8. return self.weight/(self.height** 2)
  9. a = people('kiler',75,1.9)
  10. a.Bmi()
  11. a.bmi
  1. class people:
  2. def __init__(self,name):
  3. self.__name = name
  4. @property #访问 是不能给name赋值的,因为name是一个方法
  5. def name(self):
  6. return (self.__name)
  7. @name.setter #修改
  8. def name(self,value) #现在是可以赋值的,前提是name被setter装饰
  9. if not instance(val,str)
  10. print("名字必须是字符串")
  11. return
  12. self.__name = value
  13. @name.deleter #删除
  14. def name(self)
  15. print('不允许删除')
  16. obj = people('345')
  17. obj.name = "123" # 找到 @name.setter 并将123传递给value
  18. del obj.name()
  1. class c(object):
  2. def getx(self):
  3. pass
  4. def setx(self):
  5. pass
  6. def delx(self):
  7. pass
  8. x = property(getx,setx,delx,'i am x')
  9. obj = c()
  10. obj.x # 会执行property中的getx 方法
  11. obj.x = 123 # 会执行property中的setx 方法
  12. del obj.x # 会执行property中的delx 方法

1.8反射

通过字符串映射到对象属性(’以字符串的形式去对象中进行成员的操作’)

  1. class people:
  2. def __init__(self,name,age):
  3. self.name = name
  4. self.age = age
  5. def talk(self):
  6. print("{}<{}".formt(self.name,self.age))
  7. obj = people('kile',18)
  8. # 对象 属性名
  9. hasattr(obj,'name')#判断obj对象下有没有name属性返回TrueFalse obj.__dict__['name']
  10. getattr (obj,'talk',none) # 拿到obj下的talk方法 加括号就可以执行 如果obj没有name属性则返回none
  11. setattr(obj,'sex','male') #obj.sex = male
  12. delattr(obj,'age') # del boj.age

1.8.1 import_module + 反射

可以以字符串的形式导入模块 #只能导入模块

  1. #导入模块
  2. from importlib import import_module
  3. m = import_module('random')
  4. m = import_moudle('request.exceptions')
  5. v1 = m.randint(1,100)

使用import_module 和 getattr配合实现根据字符串的形式导入模块并获取成员

  1. from omportlib import import_module
  2. path = "openpyxl.utils.exceptions.InvalidFileException"
  3. module_path,class_name = path.rsplit("."maxsplit=1)
  4. module_object = import_module(module_path)
  5. cls = getattr(module_object,class_name)
  6. print(cls)

1.9内置方法

1.9.1 isinstance(obj,cls) 判断对象是否是某个类或其子类的实例

  1. class Foo(object):
  2. pass
  3. obj = Foo()
  4. isinstance(obj,Foo) # 判断obj是否是Foo类的实例 对于有继承关系实例出来的对象也是True

1.9.3 —item—系列 (模拟成字典去操作)

  1. class Foo:
  2. def __init__(self,name):
  3. self.name = name
  4. def __getitem__(self,item): #查看的时候触发
  5. print('get')
  6. return self.__dict__.get(item)
  7. def __setitem__(self,key,value): #设置值的时候触发
  8. print('set')
  9. self.__dict__[key]=value
  10. def __delitem__(self,key): #删除的时候触发
  11. print("del")
  12. del self.__dict__[key]
  13. obj = Foo()
  14. obj['name'] # obj.__dict__['name'] 触发getitem
  15. obj['sex'] =16 #触发setitem sex为key,16为value
  16. del obj['name']

1.9.4 —str— 打印对象的时候触发,

  1. class people:
  2. def __init__(self,anme,age):
  3. self.name = name
  4. self.age = age
  5. def __str__(self): # 在打印的时候触发
  6. print('str')
  7. return '{},{}'.format(self.name,aelf.age) # 必须返回字符串
  8. obj = people('si',18)
  9. print(obj) # 触发__str__

1.9.5 —del—

回收资源,在对象被删除的时候会自动先触发该方法

  1. class open:
  2. def __init__(self,filename):
  3. print('open file')
  4. self.name = filename
  5. def __del__(self):
  6. print('回收资源')
  7. f = open('setting.py')

1.9.6—new—构造方法,在init方法之前触发

  1. class foo:
  2. def __init__(self,name):
  3. print('第二步,初始化对象,在空对象中创建数据')
  4. def __new__(cls,*args,**Kwargs):
  5. print('第一步,先创建空对象并返回')
  6. return object.__new__(cls)
  7. obj = foo('123')

1.9.7—call—方法 对象加括号会执行该方法

  1. class foo:
  2. def __call__(self,*args,**kwargs):
  3. print('对象加括号会执行call方法')
  4. obj = foo('123')
  5. obj() #执行call方法

1.9.8—dict—方法,获取对象中的实例变量,以字典形式返回

  1. class foo:
  2. def __init__(self,anme,age):
  3. self.name = name # 实例变量
  4. self.age = age
  5. obj = foo('kil',18)
  6. print(obj.__dict__)

1.9.9 —enter— 和—exit—,让对象支持with语法(上下文管理)

  1. class Foo:
  2. def __enter__(self):
  3. self.连接 = 连接操作
  4. return self.连接
  5. def __exit__(self,exc_type,exc_val,exc_tb):
  6. self.连接关闭
  7. obj = Foo()
  8. #with 对象 as XX 在内部会执行--enter--方法,并将方法中的返回值给XX
  9. #当with缩进中的代码执行完毕后,自动执行--exit--方法
  10. with obj as f:
  11. 操作
  12. ...
  13. ...
  14. -------------------------------------------------
  15. #面试题
  16. class Comtext:
  17. def __enter__(self):
  18. return self #将当前对象返回给 ctx
  19. def __exit__(self,exc_type,exc_val,exc_tb):
  20. pass
  21. def do_something(self):
  22. print('内部执行')
  23. with Context() as ctx:
  24. print("内部执行")
  25. ctx.do_something() #当前对象可以执行do_something()方法

1.9.10 —add—方法,对象相加时触发

  1. class foo:
  2. def __add__(self,other) #outher接收的是v2这个对象
  3. return 99
  4. v1 = foo()
  5. v2 = foo()
  6. #对象+值,内部会执行 对象.--add--方法,并将+后面的值当作参数传递进去
  7. v3 = v1+v2
  8. print(v3) 99

1.9.11 —iter—

迭代器

  1. 定义:
  2. 1.类中定义了 --iter-- --next--两个方法
  3. 2.--iter--方法需要返回对象本身,即self
  4. 3.--next--方法,返回下一个数据,如果没有数据了需要抛出一个stopiteration
  5. 创建迭代器类型
  6. class IT
  7. def --init--(self):
  8. self.counter = 0
  9. def --iter--(self):
  10. return self
  11. def --next--(self):
  12. self.counter +=1
  13. if self.counter == 3:
  14. raise StopIteration()
  15. return self.counter
  16. 根据类实例化创建一个迭代器对象
  17. obj1 = IT()
  18. #v1 = obj1.--next--()
  19. #v2 = obj1.--next--()
  20. #v3 = obj1.--next--() #抛出异常
  21. v1 = next(obj1) # obj1.__next__()
  22. v2 = next(obj1)
  23. v3 = next(obj1)
  24. obj2 = IT()
  25. for item in obj2: #先执行迭代器对象的--iter--方法并获取返回值,一直反复执行next(对象),直到抛出异常
  26. print(item)
  27. 迭代器对象支持通过next取值,如果取值结束则自动抛出Stopiterarion
  28. for 循环内部在循环时,先执行--iter--,获取一个迭代器对象,然后一直执行next取值,有异常终止

可迭代对象

  1. #一个类中有--iter--方法且返回一个迭代器对象,根据这个类创建的对象叫可迭代对象
  2. class foo:
  3. def--iter--(slef):
  4. return 迭代器对象(生成器对象)
  5. obj = foo()
  6. #可迭代对象是可以使用for循环,在循环内部是先执行--iter--,获取迭代器对象,在内部指向这个迭代器对象的next功能,逐步取值
  7. for item in obj:
  8. print(item)
  9. ======================================================================
  10. # 基于可迭代对象和迭代器实现自定义range
  11. class Iter:
  12. def __iter__(self,name):
  13. self.num = num
  14. self.counter = -1
  15. def __iter__(self):
  16. return self
  17. def __next__(self):
  18. self.counter +=1
  19. if self.counter == self.num:
  20. raise StopIteration()
  21. return self.counter
  22. class Xrange:
  23. def __init__(self,max_num):
  24. self.max_num = max_num
  25. def __iter__(self):
  26. return Iter(self.max_num)
  27. obj = Xrange(100)
  28. for item in obj:
  29. print(item)
  30. #================================================
  31. #基于可迭代对象和生成器,自定义range
  32. class Xrange:
  33. def __init__(self,max_num):
  34. self.max_num - max_num
  35. def __iter__(self):
  36. counter = 0
  37. while counter < self.max_num:
  38. yiled counter
  39. counter +=1
  40. obj = Xrange(100)
  41. for item in obj:
  42. print(item)
  1. from collections.abc import Iterator,Iterable
  2. v1 = list([1,2,3]) #v1是可迭代对象因为列表中生命了__iter__方法并且返回一个迭代器对象
  3. print(instance(v1,Iterator)) 判断是否是迭代器
  4. print(instance(v1,Iterable)) 判断是否有__iter__且返回迭代器对象

1.9.12 classmethod ,staticmethod,property

1.9.13 callable ,是否可在后面加括号执行(True,False)内部有—call—方法

1.9.14 super 按照self当前类的mro继承关系向上找成员

  1. class Base(object):
  2. def message(self,num):
  3. print('base.message',num)
  4. class Foo(Base):
  5. def message(self,num):
  6. print("Foo.meaasge",num)
  7. super().message(num+10) #执行base里面的message
  8. obj = Foo()
  9. obj.message(1)

1.9.15 issubclass,判断是否是某个类的子孙类

  1. class Top(object):
  2. pass
  3. class Base(Top):
  4. pass
  5. class Foo(Base):
  6. Pass
  7. print(issubclass(Foo,Base)) True
  8. print(issubclass(Foo,Top)) True

1.10 元类介绍

产生类的类就是元类 ,type()

默认用class 定义的类,元类是type

  1. exec('字符串形式的的命令',‘全局作用域’,‘局部作用域’)
  2. # 为字符串形式的命令定制一个全局作用域(不指定默认用globals())和局部作用域名(不指定默认locals())
  3. # globals() 查看全局作用域中的值
  4. g = {'x' = 1,'m' = 2,}
  5. l = {}
  6. exec('''
  7. global x,m
  8. x = 10
  9. m = 100
  10. z = 3
  11. ''',g, l
  12. ) # 全局作用域是g局部作用域名是l
  13. #exec相当于一个函数执行过程中产生的局部变量放到l中,exec执行过程中产生的全局变量放到g中
  14. # g = {'x'=10,'m'=100} l={z:3}
  1. python一切皆是对象,对象怎么用
  2. 可以被引用 X = obj
  3. 可以当做函数的参数传入
  4. 可以当作函数的返回值
  5. 可以当作容器类的元素
  1. class Foo: #类也是对象,对象是实例化出来的 Foo = type()
  2. pass

1.10.1 定义类的两种方式

1.class定义的

2.type

  1. 定义类的要素:
  2. 类名 继承 类的名称空间
  3. type定义类
  4. class_name = 'chinese' # 类名
  5. class_base = (object,) # 继承
  6. class_body = """ # 类体代码
  7. country = 'china',
  8. def __init__(self,name,age):
  9. self.name = name
  10. self.age = age
  11. def talk (self):
  12. print("{}<{}".format(self.name,self.age))"""
  13. class_dic = dict{} # 类的名称空间
  14. exec=(class_body,globals(),class_dic) #使用exec生成名称空间
  15. chines1 = type(class_name,class_bases,class_dic) #type(类名,继承,名称空间)

自定义元类控制类的创建

自定义的元类只是修改部分方法,所以要继承元类

  1. class meta(type):
  2. def __init__(self, class_name, class_base, class_dic):
  3. if not class_name.istitle(): # 首字母大写
  4. raise TypeError('类型错误') # 抛出异常
  5. if "__doc__" not in class_dic or not class_dic['__doc__'].strip():
  6. raise TypeError("必须有注释")
  7. super(meta,self).__init__(class_name, class_base, class_dic)
  8. # __doc__是类空间的注释内容,如果类中有注释则类的名称空间就有__doc__
  9. class Chinese(object, metaclass=meta): # metaclass 指定元类,object是默认继承的
  10. # Chinese = meta(class_name,class_base,class_dic)
  11. """
  12. 注释
  13. """
  14. country = 'china'
  15. def __init__(self, name, age):
  16. self.name = name
  17. self.age = age
  18. def talk(self):
  19. print("{}<{}".format(self.name, self.age))

1.10.2 自定义元类控制类的实例化行为

  1. __call__ 方法 对象在被调用的时候触发 元类当中也有call方法
  2. class Foo:
  3. def __call__(self,*args,**kwargs):
  4. print(self)
  5. print(args)
  6. print(Kwargs)
  7. obj = Foo(1,2,3,a = 1) #Foo.__call__(Foo,1,2,3,a = 1)
  8. #调用类发生的事情
  9. 1.创建空对象
  10. obj = object.__new__(self):
  11. 2.初始化__init__
  12. self.__init__(obj,*args,**Kwargs):
  13. 3.返回值
  14. return obj
  1. class meta(type):
  2. def __init__(self, class_name, class_base, class_dic):
  3. if not class_name.istitle(): # 首字母大写
  4. raise TypeError('类型错误') # 抛出异常
  5. if "__doc__" not in class_dic or not class_dic['__doc__'].strip():
  6. raise TypeError("必须有注释")
  7. super(meta, self).__init__(class_name, class_base, class_dic)
  8. def __call__(self, *args, **kwargs):
  9. # 调用类发生的事情
  10. #1.创建空对象
  11. obj = object.__new__(self)
  12. #2.初始化__init__
  13. self.__init__(obj, *args, **kwargs)
  14. print(obj.__dict__)
  15. #3.返回值
  16. return obj
  17. # __doc__是类空间的注释内容,如果类中有注释则类的名称空间就有__doc__
  18. # __call__是对象被调用的时候触发的方法,控制对象的实例化
  19. class Chinese(object, metaclass=meta): # metaclass 指定元类,object是默认继承的
  20. """
  21. 注释
  22. """
  23. country = 'china'
  24. def __init__(self, name, age):
  25. self.name = name
  26. self.age = age
  27. kwq = Chinese('kil',18)

1.11 单例模式

单例模式就是对象的数据属性值都一样的时候不开辟新的内存空间用一个

  1. class Mysql:
  2. __instance = None
  3. def __init__(self):
  4. self.host = '127.0.0.1'
  5. self.port = 3306
  6. @classmethod
  7. def singleton(cls):
  8. if not cls.__instance:
  9. obj = cls()
  10. cls.__instance = obj
  11. return cls.__instance
  12. obj1 = Mysql.singleton()
  13. obj2 = Mysql.singleton()
  14. print(obj1)
  15. print(obj2)
  16. #obj1 和 obj2的数据属性都是一样的

1.12 异常处理

异常就是程序运行时发生错误的信号,程序出现错误,并且程序没有处理这个错误信息,就会抛出异常

并且程序运行随之终止

错误的种类,语法错误和逻辑错误

  1. try
  2. 要检测的代码
  3. except 错误类型 as e #e包含的是try里面检测到的错误
  4. print('错误')
  5. print('1')
  6. print('2')
  7. ---------------------------
  8. 检测的代码中有错误时,输出错误,不再往下执行

try ….except 多分支的使用方法

被检测的代码块抛出的异常有多种可能性,并且我们需要针对每一种异常类型都定制专门的处理逻辑

  1. try:
  2. print('1')
  3. name
  4. print('2')
  5. l = [1,2]
  6. l[1000]
  7. print('3')
  8. d = {}
  9. d[name]
  10. print('4')
  11. except NameError as e:
  12. print(e)
  13. except IndexError as e:
  14. print(e)
  15. except KeyError as e:
  16. print(e)

万能异常

被检测的代码块抛出的异常有多种可能性,对多有的异常类型定制一种公用的处理逻辑

  1. try
  2. print('1')
  3. name
  4. print('2')
  5. l = [1,2]
  6. l[1000]
  7. print('3')
  8. d = {}
  9. d[name]
  10. print('4')
  11. except Exception as e:
  12. print('统一的处理方法')
  13. else
  14. print('被检测的代码没有发生异常时执行')
  15. finally
  16. print('代码有无异常都执行,一般用于释放资源 ')
  17. #在try或者except中使用了return,finally中的代码还是会执行
  18. # 遇到return是return结果之前执行finally中的代码

自定义异常

  1. class MyException(Exception):
  2. def __init__(self,msg):
  3. super(Exception,self).__init__()
  4. self.msg=msg
  5. def __str__(self):
  6. return '{}'.format(self.msg)
  7. raise Exception('自定义异常') # 触发异常
  8. #raise会显示异常的追踪信息和类型,还会打印这个对象的操作,也就是触发对象下的str方法

断言 assert

  1. info = {}
  2. info['name'] = 'kil'
  3. info['age'] = 18
  4. """
  5. if "name" not in info:
  6. raise KeyError('没有name')
  7. if "age" not in info:
  8. raise KeyError('没有age')
  9. """
  10. if info['name'] == 'kil' and ('age') > 10:
  11. print('欢迎')
  12. assert ('name' in info) and ('age' in info) #功能等于两行if判断

1.13 socket

socket 是在传输层和应用层之间抽象出来的一组接口,把复杂的tcp/ip协议簇隐藏在socket接口后面,对用户来说直接调用socket的接口就可以,socket负责去组织数据以符合指定的协议

套接字工作流程

4.面向对象 - 图3

  1. 服务端先初始化socket,然后与端口绑定bind,对端口进行监听listen,调用accept阻塞,等待客户端连接,此时如果有客户端初始化socket,连接服务器connect,如果连接成功,此时就建立起连接,客户端发送数据请求,服务端接受请求并处理请求,然后把回应数据发送到客户端,最后关闭连接,一次交互结束

socket套接字方法

  1. family(socket家族)
  2. socket.AF_UNIX:用于本机进程间通讯,为了保证程序安全,两个独立的程序(进程)间是不能互相访问彼此的内存的,但为了实现进程间的通讯,可以通过创建一个本地的socket来完成
  3. socket.AF_INET:(还有AF_INET6被用于ipv6,还有一些其他的地址家族,不过,他们要么是只用于某个平台,要么就是已经被废弃,或者是很少被使用,或者是根本没有实现,所有地址家族中,AF_INET是使用最广泛的一个,python支持很多种地址家族,但是由于我们只关心网络编程,所以大部分时候我么只使用AF_INET)
  4. socket type类型
  5. socket.SOCK_STREAM #for tcp
  6. socket.SOCK_DGRAM #for udp
  7. socket.SOCK_RAW #原始套接字,普通的套接字无法处理ICMP、IGMP等网络报文,而SOCK_RAW可以;其次,SOCK_RAW也可以处理特殊的IPv4报文;此外,利用原始套接字,可以通过IP_HDRINCL套接字选项由用户构造IP头。
  8. socket.SOCK_RDM #是一种可靠的UDP形式,即保证交付数据报但不保证顺序。SOCK_RAM用来提供对原始协议的低级访问,在需要执行某些特殊操作时使用,如发送ICMP报文。SOCK_RAM通常仅限于高级用户或管理员运行的程序使用。
  9. proto=0 请忽略,特殊用途
  10. fileno=None 请忽略,特殊用途
  11. 服务端套接字函数
  12. s.bind() 绑定(主机,端口号)到套接字
  13. s.listen() 开始TCP监听
  14. s.accept() 被动接受TCP客户的连接,(阻塞式)等待连接的到来
  15. 客户端套接字函数
  16. s.connect() 主动初始化TCP服务器连接
  17. s.connect_ex() connect()函数的扩展版本,出错时返回出错码,而不是抛出异常
  18. 公共用途的套接字函数
  19. s.recv() 接收数据
  20. s.send() 发送数据(send在待发送数据量大于己端缓存区剩余空间时,数据丢失,不会发完,可后面通过实例解释)
  21. s.sendall() 发送完整的TCP数据(本质就是循环调用send,sendall在待发送数据量大于己端缓存区剩余空间时,数据不丢失,循环调用send直到发完)
  22. s.recvfrom() Receive data from the socket. The return value is a pair (bytes, address)
  23. s.getpeername() 连接到当前套接字的远端的地址
  24. s.close() 关闭套接字
  25. socket.setblocking(flag) #True or False,设置socket为非阻塞模式,以后讲io异步时会用
  26. socket.getaddrinfo(host, port, family=0, type=0, proto=0, flags=0) 返回远程主机的地址信息,例子 socket.getaddrinfo('luffycity.com',80)
  27. socket.getfqdn() 拿到本机的主机名
  28. socket.gethostbyname() 通过域名解析ip地址
  1. import socket
  2. phone = socket.socket(socket.AF_INET,socket.socket_STREAM) #选择协议
  3. phone.bind(('127.0.0.1',22)) #绑定端口0-65535,0-1024是给操作系统用的
  4. phone.listen(5) #最大连接数
  5. conn,client_addr = phone.accept() #等待连接 conn是连接对象 client_addr是客户端ip和端口
  6. data = conn.recv(1024) #最大接收1024byte 接受数据
  7. conn.sendall(data.upper()) #发送数据
  8. conn.close() #关闭连接
  9. phone.close()
  10. #======================================================
  11. 客户端
  12. import socket
  13. phone = socket.socket(socket.AF_INET,scoket.socket_STREAM) #选择协议
  14. phone.connect(('127.0.0.1',22)) #发起连接
  15. phone.send(' hello',encode('utf-8'))
  16. data = phone.recv(1024)
  17. phone.close

通信循环

  1. import socket
  2. phone = socket.socket(socket.AF_INET,soc ket.socket_STREAM) #选择协议
  3. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #重复使用端口
  4. phone.bind(('127.0.0.1',22)) #绑定端口0-65535,0-1024是给操作系统用的
  5. phone.listen(5) #最大连接数
  6. conn,client_addr = phone.accept() #等待连接
  7. while True #通信循环
  8. data = conn.recv(1024) #最大接收1024byte 接受数据
  9. conn.send(data.upper()) #发送数据
  10. conn.close() #关闭连接
  11. phone.close()
  1. #当客户端单方面中断连接后,(客户端会发送一个空)服务端会一直卡在接收过程,形成死循环
  2. import socket
  3. phone = socket.socket(socket.AF_INET,soc ket.socket_STREAM) #选择协议
  4. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #重复使用端口
  5. phone.bind(('127.0.0.1',22)) #绑定端口0-65535,0-1024是给操作系统用的
  6. phone.listen(5) #最大连接数
  7. conn,client_addr = phone.accept() #等待连接
  8. while True #通信循环
  9. data = conn.recv(1024) #最大接收1024byte 接受数据
  10. if not data:break # 适用linux系统,解决 客户端单方面中断连接后,服务端会一直卡在接收过程,形成死循环
  11. """
  12. 解决winodws下 客户端单方面中断连接后,服务端会一直卡在接收过程,形成死循环
  13. try:
  14. data = conn.recv(1024)
  15. conn.send(data.upper())
  16. except ConnectionResetError:
  17. break
  18. """
  19. conn.send(data.upper()) #发送数据
  20. conn.close() #关闭连接
  21. phone.close()
  22. -------------------------------------------------------------------
  23. import socket
  24. phone = socket.socket(socket.AF_INET,scoket.socket_STREAM) #选择协议
  25. phone.connect(('127.0.0.1',22)) #发起连接
  26. while True: #通信循环
  27. msg = input(">>>>").strip() #
  28. if not mag:continue #判断输入是否为空,要是空的话contiune
  29. phone.send(msg.encode('utf-8'))
  30. print('send')
  31. data = phone.recv(1024)
  32. print("recv")
  33. print(data.decode('utf-8'))
  34. phone.close

多客户端与多服务端

链接循环

  1. import socket
  2. phone = socket.socket(socket.AF_INET,socket.socket_STREAM)
  3. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) # 避免端口被占用
  4. phone.bind(('127.0.0.1',22))
  5. phone.listen(5)
  6. while True: #连接循环
  7. conn, client_addr = phone.accept()
  8. while True:# 通信循环
  9. data = conn.recv(1024)
  10. if not data: break
  11. conn.send(data.upper())
  12. conn.close()
  13. phone.close()

模拟ssh远程

  1. """
  2. dir :查看某个文件夹下的子文件名和子文件夹 ls
  3. ipconfig :查看ip信息 ifconfig
  4. tasklist :查看运行的进程 ps aux
  5. 执行系统命令
  6. import os
  7. os.system("dir C:\")
  8. 或者
  9. import subprocess
  10. obj = subprocess.Popen("dir C:\",shell = True,stdout=suprocess.PIPE,stderr= subprocess.PIPE)
  11. taskkill python 杀死python端口进程
  12. """
  13. import subprocess
  14. import socket
  15. phone = socket.socket(socket.AF_INET,socket.socket_STREAM)
  16. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
  17. phone.bind(('127.0.0.1',22))
  18. phone.listen(5)
  19. while True: #连接循环
  20. conn, client_addr = phone.accept()
  21. while True:
  22. data = conn.recv(1024) # 接收客户端的命令
  23. if not data: break
  24. # 执行命令并得到结果,正确结果放到stdout=suprocess.PIPE,错误放到stderr= subprocess.PIPE
  25. obj = subprocess.Popen(data,shell = True,stdout=suprocess.PIPE,stderr= subprocess.PIPE)
  26. stdout = obj.stdout.read()
  27. stderr=obj.stderr.read()
  28. conn.send(stdout+stderr)
  29. conn.close()
  30. phone.close()
  31. --------------------------------------------------------------------------
  32. import socket
  33. phone = socket.socket(socket.AF_INET,scoket.socket_STREAM)
  34. phone.connect(('127.0.0.1',22))
  35. while True:
  36. msg = input(">>>>").strip()
  37. if not mag:continue
  38. phone.send(msg.encode('utf-8'))
  39. data = phone.recv(1024) #接收的数据大于1024的时候,不会丢失,在下次执行命令的时候显示出来
  40. #粘包现象
  41. print(data.decode('utf-8'))
  42. phone.close

粘包原理

  1. sendrecv都不是直接接收对方的数据,是操作自己的操作系统内存
  2. 接收的长度小于数据包的长度,导致阻塞在管道中或者因为Nagle算法将多次间隔较小且数据量小的数据合并成一个大的数据块,然后进行封包进行发送一次
  3. recv 1.等待对方将数据发送到操作系统的缓冲区 2.recv从网卡缓冲区获取数据
  4. send 1.send将数据发送到自己网卡到写缓冲去 2.操作系统调用网卡将缓冲区数据发送给对方网卡到缓冲区
  5. --------------------------------------------------------------------------------
  6. tcp,是面向连接的面向流的,提供高可靠性,收发两端都要一一成对的socket,发送端为了将多个发往接收端的包,更有效的发往对方,使用了优化算法(Nagle算法),将多次间隔较小且数据量小的数据合并成一个大的数据块,然后进行封包,这样接收端就难于分辨出来,必须提供科学的拆包机制,即面向流的。通信是无消息保护边界的
  1. 解决粘包:
  2. 每次发送数据的时候,将消息划分为头部(固定四个字节的长度)和数据部分
  3. 发送数据:先发送数据的长度 再发送数据 或拼接起来发送
  4. 接收数据:先读4字节的长度,再根据长度获取数据
  5. struct 模块可以将数值转换为固定的四个字节 范围是-21474836482147483648
  6. struct.pack('i',199) # i表示是int类型
  7. struct.unpack('i',v1)
  1. import subprocess
  2. import socket
  3. import struct#打包模块
  4. phone = socket.socket(socket.AF_INET,socket.socket_STREAM)
  5. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
  6. phone.bind(('127.0.0.1',22))
  7. phone.listen(5)
  8. while True: #连接循环
  9. conn, client_addr = phone.accept()
  10. while True:
  11. data = conn.recv(1024) # 接收客户端的命令
  12. if not data: break
  13. # 执行命令并得到结果,正确结果放到stdout=suprocess.PIPE,错误放到stderr= subprocess.PIPE
  14. obj = subprocess.Popen(data,shell = True,stdout=suprocess.PIPE,stderr= subprocess.PIPE)
  15. stdout = obj.stdout.read()
  16. stderr=obj.stderr.read()
  17. total_size = (len(stdout)+str(stderr))##包的长度
  18. conn.send(str(total_size).encode('utf-8')) #发送包的长度
  19. #制作固定长度的报头
  20. head = struct.pack('i',total_size)
  21. #把报头发给客户端
  22. conn.send(head)
  23. #发送真实的数据
  24. conn.send(stdout+stderr)
  25. conn.close()
  26. phone.close()
  27. --------------------------------------------------------------------------
  28. import socket
  29. phone = socket.socket(socket.AF_INET,scoket.socket_STREAM)
  30. phone.connect(('127.0.0.1',22))
  31. while True:
  32. msg = input(">>>>").strip()
  33. if not mag:continue
  34. phone.send(msg.encode('utf-8'))
  35. #接收报头
  36. obj = phone.recv(4)
  37. #从报头中解析出真实数据的描述信息(数据的长度)
  38. total_size = struct.unpack('i',obj) #i是固定的,int类型 4个字节,unpack是解包,字节转换为数字
  39. #接收真实的数据
  40. recv_size = 0
  41. recv_data = b"
  42. while recv_size < total_size
  43. res = phone.recv(1024)
  44. recv_data += res
  45. recv_size +=len(res)
  46. print(recv_data.decode('utf-8'))
  47. phone.close
  1. 最终版
  2. import subprocess
  3. import socket
  4. import struct
  5. phone = socket.socket(socket.AF_INET,socket.socket_STREAM)
  6. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
  7. phone.bind(('127.0.0.1',22))
  8. phone.listen(5)
  9. while True: #连接循环
  10. conn, client_addr = phone.accept()
  11. while True:
  12. data = conn.recv(1024) # 接收客户端的命令
  13. if not data: break
  14. # 执行命令并得到结果,正确结果放到stdout=suprocess.PIPE,错误放到stderr= subprocess.PIPE
  15. obj = subprocess.Popen(data,shell = True,stdout=suprocess.PIPE,stderr= subprocess.PIPE)
  16. stdout = obj.stdout.read()
  17. stderr=obj.stderr.read()
  18. total_size = (len(stdout)+str(stderr))##包的长度
  19. conn.send(str(total_size).encode('utf-8')) #发送包的长度
  20. #制作固定长度的报头
  21. head_dic = {
  22. "file_name":"a.txt",
  23. 'md5':'Xdfdfdfdfd',
  24. 'total_size':len(stdot)+len(stderr)
  25. }
  26. header_json = ison.dumps(header_dic)
  27. header_byes = header_json.encode('utf-8')
  28. struct.pack("i",len(header_bytes))
  29. #发送报头长度
  30. conn.send(header_bytes)
  31. #把报头发给客户端
  32. conn.send(head_bytes)
  33. #发送真实的数据
  34. conn.send(stdout+stderr)
  35. conn.close()
  36. phone.close()
  37. --------------------------------------------------------------------------
  38. import socket
  39. phone = socket.socket(socket.AF_INET,scoket.socket_STREAM)
  40. phone.connect(('127.0.0.1',22))
  41. while True:
  42. msg = input(">>>>").strip()
  43. if not mag:continue
  44. phone.send(msg.encode('utf-8'))
  45. #接收报头长度
  46. obj = phone.recv(4)
  47. header_size = struct.unpack('i',obj)[0]
  48. #收报头
  49. header_bytes = phone.recv(header_size)
  50. #从报头中解析出真实的数据表述信息
  51. header_json = header_bytes.decode('utf-8')
  52. header_dic = json.loads(header_json)
  53. total_size = header_dic['total_size']
  54. #接收真实的数据
  55. recv_size = 0
  56. recv_data = b"
  57. while recv_size < total_size
  58. res = phone.recv(1024)
  59. recv_data += res
  60. recv_size +=len(res)
  61. print(recv_data.decode('utf-8'))
  62. phone.close

文件传输功能

  1. 文件传输功能
  2. import subprocess
  3. import socket
  4. import struct
  5. phone = socket.socket(socket.AF_INET,socket.socket_STREAM)
  6. phone.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
  7. phone.bind(('127.0.0.1',22))
  8. phone.listen(5)
  9. while True: #连接循环
  10. conn, client_addr = phone.accept()
  11. while True:
  12. data = conn.recv(1024) # 接收客户端的命令
  13. if not data: break
  14. cmds = data.decode('utf-8').split()
  15. filename = cmds[1]
  16. stdout = obj.stdout.read()
  17. stderr=obj.stderr.read()
  18. total_size = (len(stdout)+str(stderr))##包的长度
  19. conn.send(str(total_size).encode('utf-8')) #发送包的长度
  20. #制作固定长度的报头
  21. head_dic = {
  22. "file_name":"a.txt",
  23. 'md5':'Xdfdfdfdfd',
  24. 'file_size':os.oath.getsize(filename)
  25. }
  26. header_json = ison.dumps(header_dic)
  27. header_byes = header_json.encode('utf-8')
  28. struct.pack("i",len(header_bytes))
  29. #发送报头长度
  30. conn.send(header_bytes)
  31. #把报头发给客户端
  32. conn.send(head_bytes)
  33. #发送真实的数据
  34. with open(filename.'rb') as f:
  35. for line in f:
  36. conn.send(line)
  37. conn.close()
  38. phone.close()
  39. --------------------------------------------------------------------------
  40. import socket
  41. phone = socket.socket(socket.AF_INET,scoket.socket_STREAM)
  42. phone.connect(('127.0.0.1',22))
  43. while True:
  44. msg = input(">>>>").strip()
  45. if not mag:continue
  46. phone.send(msg.encode('utf-8'))
  47. #接收报头长度
  48. obj = phone.recv(4)
  49. header-size = struct.unpack('i',obj)[0]
  50. #收报头
  51. header_bytes = phone.recv(header_size)
  52. #从报头中解析出真实的数据表述信息
  53. header_json = header_bytes.decode('utf-8')
  54. header_dic = json.loads(header_json)
  55. file_size = header_dic['file_size']
  56. filename = header_dic['filname']
  57. #接收真实的数据
  58. with open(filename,'wb') as f:
  59. recv_size = 0
  60. while recv_size < file_size
  61. line = phone.recv(1024)
  62. f.write(line)
  63. recv_size +=len(line)
  64. phone.close

UDP 套接字

  1. 服务端
  2. from socket import *
  3. server = socket(AF_INET,SOCK_DGRAM)
  4. server.bind('127.0.0.1',8080) # udp是无连接的
  5. while True:
  6. res1 = server.recvfrom(1024)
  7. res2 = server.recvfrom(1024)
  8. server.close
  9. ------------------------------------------------
  10. 客户端
  11. from socket import *
  12. client = socket(AF_INET,SOCKET_DGRAM)
  13. client.sendto(b'hello',('127.0.0.1',8080))
  14. client.sendto(b'word',('127.0.0.1',8080))
  15. client.close()

socketserver模块实现并发

  1. import socketserver
  2. class Myserver(socketserver.BaseRequestHandler):
  3. def handle(self):
  4. # 并发的业务逻辑代码 self.request是客户端的套接字对象
  5. while True:
  6. client_data = self.request.recv(1024)
  7. if client_data.decode('utf8') == 'exit':
  8. print('断开连接')
  9. break
  10. print('接受数据', str(client_data, 'utf_8'))
  11. response = input('响应数据')
  12. self.request.sendall(bytes(response, 'utf8'))
  13. self.request.close()
  14. # 创建socket对象以及 bind() listen()
  15. server = socketserver.ThreadingTCPServer(('127.0.0.1', 8080), Myserver)
  16. # accept() 等待用户连接
  17. server.serve_forever()

非阻塞和Io多路复用

  1. import select # IO多路复用
  2. import socket
  3. server=socket.socket(socket.AF_INET,socket.socl_STREAM)
  4. server.setblocking(False) # 非阻塞
  5. server.bind('127.0.0.1',8090)
  6. server.listen(5)
  7. inputs = [server,] #socket 对象列表,最多只能放1024个socket对象
  8. while True:
  9. '''
  10. select.select(),把socket对象当作第一个参数传进去,0.05就是在select里面用
  11. 0.05的时间检测socket对象列表是否有人发连接或数据,如果没有人发起连接 r = [],
  12. 当有人发起连接,r = [发生变化的那个连接],且r只存放当前有变化的连接
  13. w存放成功的连接
  14. e检测异常情况,是否有异常
  15. '''
  16. #io多路复用
  17. r,w,e = select.select(inputs,[],[],0.5)
  18. foe sock in r:
  19. if sock == server:
  20. conn,addr = sock.accept() #接收新连接# conn是客户端连接也会放到inputs列表 addr是地址
  21. print('有连接')
  22. #将客户端发起的连接放进inputs列表
  23. inputs.append(conn)
  24. else:
  25. data = sock.recv(1024)
  26. if data:
  27. print('收到消息',data)
  28. else:
  29. #关闭连接
  30. inputs.remove(sock)
  1. import socket
  2. import select
  3. import uuid
  4. import os
  5. client_list = [] # socket对象列表
  6. for i in range(5):
  7. client = socket.socket()
  8. client.setblocking(False)
  9. try:
  10. # 连接百度,虽然有异常BlockingIOError,但向还是正常发送连接的请求
  11. client.connect(('47.98.134.86', 80))
  12. except BlockingIOError as e:
  13. pass
  14. client_list.append(client)
  15. recv_list = [] # 放已连接成功,且已经把下载图片的请求发过去的socket
  16. while True:
  17. # w = [第一个socket对象,]
  18. # r = [socket对象,]
  19. r, w, e = select.select(recv_list, client_list, [], 0.1)
  20. for sock in w:
  21. # 连接成功,发送数据
  22. # 下载图片的请求
  23. sock.sendall(b"GET /nginx-logo.png HTTP/1.1\r\nHost:47.98.134.86\r\n\r\n")
  24. recv_list.append(sock) #放如r中检测是否有返回数据
  25. client_list.remove(sock) # w中检测的是连接成功的对象,无法检测有变化的连接
  26. for sock in r:
  27. # 数据发送成功后,接收的返回值(图片)并写入到本地文件中
  28. data = sock.recv(8196)
  29. content = data.split(b'\r\n\r\n')[-1]
  30. random_file_name = "{}.png".format(str(uuid.uuid4()))
  31. with open(os.path.join("images", random_file_name), mode='wb') as f:
  32. f.write(content)
  33. recv_list.remove(sock)
  34. if not recv_list and not client_list:
  35. break
  1. """
  2. 基于IO多路复用 + 非阻塞的特性,无论编写socket的服务器和客户端都可以提升性能。
  3. IO多路复用,检测socket对象是否有变化,(连接是否成功,是否有数据到来)
  4. 非阻塞:socket的connect recv过程不再需要等待
  5. IO多路复用只能用来监听IO对象是否发生变化,常见的有文件是否可以读写,电脑终端设备的输入和输出
  6. """

os.sep 根据系统判断是/还是\