WebService就是一个应用程序向外界暴露出一个能经过Web进行调用的API,也就是说能用编程的方法经过 Web 来调用这个应用程序。咱们把调用这个WebService的应用程序叫作客户端,而把提供这个WebService的应用程序叫作服务端python
RPC 全称 Remote Procedure Call
—— 远程过程调用。在学校学编程,咱们写一个函数都是在本地调用就好了。可是在互联网公司,服务都是部署在不一样服务器上的分布式系统,如何调用呢? RPC 技术简单说就是为了解决远程调用服务的一种技术,使得调用者像调用本地服务同样方便透明。 下图是客户端调用远端服务的过程:web
client
发起服务调用请求。client stub
能够理解成一个代理,会将调用方法、参数按照必定格式进行封装,经过服务提供的地址,发起网络请求。server stub
接受来自socket
的消息 。server stub
将消息进行解包、告诉服务端调用的哪一个服务,参数是什么 。server stub
。sever stub
把结果进行打包交给socket
。socket
经过网络传输消息 。client slub
从socket
拿到消息。client stub
解 包消息将结果返回给client
。一个RPC框架就是把步骤2到9都封装起来。一种软件架构风格、设计风格,而不是标准,只是提供了一组设计原则和约束条件,规定如何编写以及如何设置返回值、状态码等信息数据库
# -–-–API与用户的通讯协议: https -–-–-– # -–-–-–-–-– 域名 -–-–-–-–-–-–-–-–-–-– # 应该尽可能将API部署在专用域名之下。 https://api.example.com #若是肯定API很简单,不会有进一步扩展,能够考虑放在主域名下 https://example.org/api #----------- 版 本 ------------------ # 应该将API的版本号放入URL。 https://api.example.com/v1/ #另外一种作法是,将版本号放在HTTP头信息中,但不如放入URL方便和直观 # ------------ 路径 ------------------ #视网络上任何东西都是资源,均使用名词表示(可复数) https://api.example.com/v1/zoos https://api.example.com/v1/animals https://api.example.com/v1/employees # --------- method ------------------- GET :从服务器取出资源(一项或多项) POST:在服务器新建一个资源 PUT:在服务器更新资源(客户端提供改变后的完整资源) PATCH:在服务器更新资源(客户端提供改变的属性) DELETE :从服务器删除资源 # ---------- 过滤 ---------------------- # 经过在url上传参的形式传递搜索条件 https://api.example.com/v1/zoos?limit=10:指定返回记录的数量 https://api.example.com/v1/zoos?offset=10:指定返回记录的开始位置 https://api.example.com/v1/zoos?page=2&per_page=100:指定第几页,以及每页的记录 https://api.example.com/v1/zoos?sortby=name&order=asc:指定返回结果按照哪一个属性排序,以及排序顺序 https://api.example.com/v1/zoos?animal_type_id=1:指定筛选条 #---------- 状态码 ------------ 200 OK:客户端请求成功,通常用于GET和POST请求 400 Bad Request:客户端请求有语法错误,不能被服务器所理解。 301 Moved Permanently:永久移动,请求的资源已被永久移动到新url,返回信息会包含新的url,浏览器会自动 定向到新url 401 Unauthorized:请求未经受权,这个状态代码必须和WWW-Authenticate报头域一块儿使用。 403 Forbidden:服务器收到请求,可是拒绝提供服务。 404 Not Found:请求资源不存在,举个例子:输入了错误的URL。 500 Internal Server Error:服务器发生不可预期的错误。 502 Bad Gateway: 充当网关或代理的服务器,从远端接收到一个无效的请求 503 Server Unavailable:服务器当前不能处理客户端的请求,一段时间后可能恢复正常 # ------错误处理 --------------- 状态码是4xx时,应返回错误信息,error当作key。 { error: "Invalid API key" } #------ 返回结果 -------------- GET /collection:返回资源对象的列表(数组) GET /collection/resource:返回单个资源对象 POST /collection:返回新生成的资源对象 PUT /collection/resource:返回完整的资源对象 PATCH /collection/resource:返回完整的资源对象 DELETE /collection/resource:返回一个空文档
一个接口经过1次相同的访问,再对该接口进行N次相同的访问时,对资源不造影响就认为接口具备幂等性 GET, # 第一次获取结果、第二次也是获取结果对资源都不会形成影响,幂等。 POST, # 第一次新增数据,第二次也会再次新增,非幂等。 PUT, # 第一次更新数据,第二次不会再次更新,幂等。 PATCH,# 第一次更新数据,第二次不会再次更新,非幂等。 DELTE,# 第一次删除数据,第二次不在再删除,幂等。
# 在编写接口时能够不使用django rest framework框架, # 不使用:也能够作,能够用django的CBV来实现,开发者编写的代码会更多一些。 # 使用:内部帮助咱们提供了不少方便的组件,咱们经过配置就能够完成相应操做 如:'序列化'能够作用户请求数据校验 + queryset对象的序列化称为json '解析器'获取用户请求数据request.data,会自动根据content-type请求头的不能对数据进行解析 '分页'将从数据库获取到的数据在页面进行分页显示。 # 还有其余组件: '认证'、'权限'、'访问频率控制
序列化、视图、认证、权限、限制django
分页、版本控制、过滤器、解析器、渲染器编程
# ---- 继承APIView -------- # APIView继承于View ,可是重写了父类View中的dispatch(),将get、post、put的数据放入request。data中, 将请求的参数放入request.query_params
# ----继承GenericAPIView---- # 每个接口都是生成一个序列化对象,实例化,调用data方法,对其进行封装 class GenericAPIView(views.APIView): queryset = None serializer_class = None # python mixin(混合类):不能单独使用,和其它类搭配起来使用(利用了Python支持多继承) class PublisherList(GenericView,ListMixin,CreateMixin): queryset = models.Publisher.objects.all() serializer_class = PublisherSerializer # -----继承GenericViewSet ---------- # GenericViewSet(ViewSetMixin, generics.GenericAPIView): # ViewSetMixin重写了as.view()方法,实现了根据请求的方法执行具体的类方法 # 路由注册的时候,利用actions参数,实现路由的定向分发 而不是简单的 反射 url(r'authors/$', views.AuthorViewSet.as_view(actions={ 'get': 'list', 'post': 'create' })), # 做者列表 url(r'authors/(?P<pk>\d+)/$', views.AuthorViewSet.as_view( actions={ 'get': 'retrieve', 'put': 'update', 'delete': 'destroy' })), # -----继承ModelViewSet ------ class ModelViewSet(mixins.CreateModelMixin, mixins.RetrieveModelMixin, mixins.UpdateModelMixin, mixins.DestroyModelMixin, mixins.ListModelMixin, GenericViewSet) #将不一样的请求链接到不一样的方法
序列化过程:ORM对象-->JSON格式数据 反序列化: JSON格式数据-->ORM对象
serializers.serializerjson
序列化过程: # (get请求)定义一个serializer类,继承serializers.Serializer,定义字段告诉REST框架,哪些字段(field),须要被序列化/反序列化 # 使用serializer类,将查询结果集QuerySet传入,并标明 many=True,表示序列化多个 获得序列化的结果对象ser_obj,ser_obj.data即为获得的json格式的数据 反序列化过程: 1.如果post请求提交数据 request.data即为提交的json格式的数据, 使用serializer类对 数据进行反序列化 -->ser_obj对象 对ser_obj对象进行is_vaild()校验,此处能够自定义校验规则,具体参照上述表格 ser_obj.save()须要重写serializer.create方法 2.如果put请求: 根据pk去查询具体的那本书籍对象obj 获取用户发送过来的数据而且更新对象, 赋值给instance的obj对象, partial=True的意识容许作局部更新 ser_obj = Serializer(instance=obj, data=request.data, partial=True) 对ser_obj对象进行is_vaild()校验,此处能够自定义校验规则,具体参照上述表格 ser_obj.save() 须要重写serializer.update方法
serializers.ModelSerializerapi
#序列化过程 - 不用定义字段 class Meta: model = models.Book fields = "__all__" # depth = 1 # 全部有关系的字段都变成 read_only # exclude = [] # 排除某个字段 extra_kwargs = { # 每一个字段的一些额外参数 'publisher': {'write_only': True}, 'authors': {'write_only': True}, 'category': {'write_only': True}, } #反序列化的过程: #.save() 直接一键更新或建立,已经封装了这两个方法 #另外:SerializerMethodField 会自动去找 get_字段名 的方法执行 class BookModelSerializer(serializers.ModelSerializer): # SerializerMethodField 会自动去找 get_字段名 的方法执行 category_info = serializers.SerializerMethodField(read_only=True) publisher_info = serializers.SerializerMethodField(read_only=True) authors_info = serializers.SerializerMethodField(read_only=True) def get_category_info(self, book_obj): return book_obj.get_category_display() def get_publisher_info(self, book_obj): return PublisherSerializer(book_obj.publisher).data def get_authors_info(self, book_obj): return AuthorSerializer(book_obj.authors.all(), many=True).data class Meta: model = models.Book fields = "__all__" # depth = 1 # 全部有关系的字段都变成 read_only # exclude = [] # 排除某个字段 extra_kwargs = { # 每一个字段的一些额外参数 'publisher': {'write_only': True}, 'authors': {'write_only': True}, 'category': {'write_only': True}, }
# 1.认证、权限和限制是在执行请求以前作的,路由-->as.view()-->APIView中的dispatch()方法中的 initial 方法 self.initial(request, *args, **kwargs) # 2.在initial函数中 # Ensure that the incoming request is permitted self.perform_authentication(request) # 认证 self.check_permissions(request) # 权限 self.check_throttles(request) # 限制 # 3.执行perform_authentication方法,其中request.user是一个@property的函数 # 4.在user方法中经过 self._authenticate()函数,去执行_authenticate()方法,将当前请求的用户交给定义的在 authentication_classes=[]中的类的 authenticate进行身份验证 # 5.实现 BaseAuthentication中的authenticate方法,返回元组,元组的第一个元素赋值给 request.user 第二个元素复制给了request.auth(token) # 6.如果authenticate方法 抛错后,捕获到报错(raise),此时执行的 _not_authenticated 方法的,return 结果:user &auth 都赋值为None
# 1.认证、权限和限制是在执行请求以前作的,路由-->as.view()-->APIView中的dispatch()方法中的initial方法 self.initial(request, *args, **kwargs) # 2.在initial函数中 # Ensure that the incoming request is permitted self.perform_authentication(request) # 认证 self.check_permissions(request) # 权限 self.check_throttles(request) # 限制 # 3.执行 check_permissions方法,从当前 permission_classes 列表中,执行 has_permission()方法,判断有没有权限 # 4.实现BasePermission中的has_permission()方法 class MyPermission(BasePermission): message = '只有VIP才能访问' def has_permission(self, request, view): #经过上面的认证源码得知:当不输入token参数或者未登陆,则 user ,auth 均为None,当auth存在则此时 的user不为None if not request.auth: return False #当有Vip才有权限访问 #if request.user当前通过认证的用户对象 if request.user.vip: return True else: #若是不是Vip就拒绝的范围 return False # 5.若是存在验证不经过,那么就执行self.permission_denied,而后这个异常在dispatch函数中被捕捉,当作结果传递给response
# 1.如果未注册用户,因此不可能通过认证,则此时user,auth 均为None # 2.自定义allow_request方法 #拿到当前的请求的ip做为访问记录的key #把当前的请求的访问记录拿出来保存到一个变量中 #循环访问历史,把超过10 秒钟的请求事件去掉 #在视图或者全局中进行配置
throttle.py数组
# 使用内置限制类 from rest_framework.throttling import SimpleRateThrottle class VisitThrottle(SimpleRateThrottle): scope = "xxx" def get_cache_key(self, request, view): return self.get_ident(request)
settings.py浏览器
# 在settings文件中进行配置 "DEFAULT_THROTTLE_CLASSES": {["BAR.XXX.VisitThrottle", ], "DEFAULT_THROTTLE_RATES": { "xxx": "1/s", }