义乌网站建设方式,hao爱做网站,演示网站,漫画app软件定制开发微服务#xff08;rpc#xff09; 微服务必备的模块生产者消费者管理平台流量控制集群情况下如何做到流量监控 负载均衡服务发现和治理序列化传输序列化和反序列化 微服务是一种架构风格#xff0c;将一个应用程序拆分为一组小型、独立的服务#xff0c;每个服务都可以独立… 微服务rpc 微服务必备的模块生产者消费者管理平台流量控制集群情况下如何做到流量监控 负载均衡服务发现和治理序列化传输序列化和反序列化 微服务是一种架构风格将一个应用程序拆分为一组小型、独立的服务每个服务都可以独立开发、部署和扩展。每个服务都有自己的业务逻辑和数据存储并通过轻量级的通信机制来进行互相通信。 微服务必备的模块
生产者
生产者的实现原理参考了Tomcat
消费者
消费者的实现原理参考了mybatis
管理平台
消费者和生产者在管理平台上注册信息便于管理。每一个信息都要加上详细说明。管理平台中还应该有调用关系说明谁调用了谁。
流量控制
当超过限制的流量访问微服务时会造成瘫痪此时造成的损失应由生产者承担。当设置流量控制后超过流量的访问将会被禁止。
流量控制由消费者去做当消费者发送请求后自己进行计数当发现流量达到一定程度时消费者自己就会进行拦截
集群情况下如何做到流量监控
假设有两台消费者访问四台生产者一分钟不能超过一万次的流量那么如何安排两台消费者的访问流量
负载均衡
不是用nigx做的微服务属于内网调用不对外网公布。内网之间的调用没有那么复杂例如不会使用http协议。会使用自定义协议在这种条件下Tomcat和nigx不能够正常使用。dobbo使用的就是自定义协议
服务发现和治理
当生产者的服务器发生变化时宕机或者有新服务器增加
服务器增加生产者和消费者就会自动向管理平台注册信息为了区分不同的生产者和消费者所以在申请时会在平台上自动生成唯一的标记同时标记会被存放放到指定的位置上当生产者和消费者在次发送请求时管理平台就可以根据标记来区分不同的生产消费者
服务器宕机每台服务器都会定时向管理平台发送信息让管理平台确认自己的运行状态是否正常当连续多次不在管理平台发送信息时管理平台就可以及时发现服务器不能正常使用并及时进行销毁
当服务器发生变动后管理平台会向所有调用变动生产者的消费者发送通知以确保消费者可以及时了解生产者的消息。
由于存在延迟当一台服务器多次不在向管理平台发送心跳期间若有大量消费者的请求涌入会造成损失。所以当消费者在第一次得不到生产者的回应后会尝试第二次访问当再次得不到回应时消费者会及时将生产者IP进行上报并及时切换其他生产者进行请求。当管理平台接收到消费者的故障请求时就会向其他消费者发送通知告知生产者故障
当消费者首次调用生产者IP时会询问管理平台生产者的IP并以hashmap的方式存入缓存中存储到缓存中下次直接进行访问也正是因为这样使得得知生产者故障的IP较晚。当消费者得知生产者故障时会及时更新自己的缓存
序列化传输
通常情况下序列化和反序列化会用到反射机制而序列化传输使用的是probuffer全程没用使用到任何反射机制极大提高了效率。
springcloud性能比较慢但是许多核心模块都是现成的不需要自己进行开发
dobbo传输性能特别快核心为生产者和消费者其他模块内容需要自己去手写一份。
序列化和反序列化
序列化就是把对象转成流的形式反序列化就是把流转为对象。序列化和反序列是毫秒级别的操作之所以慢是因为应用到了反射反射需要将内存都遍历一遍导致速递很慢。
在序列化传输中序列化和反序列化追求的都是无反射。
我们定义两个类那么这两个类进行传输时需要通过反射来遍历一遍类中的内容那么如何做到无反射呢。
首先我们在WW类中加入注解标记他为需要特殊处理的类给类中字段加入注解标记顺位和最大长度。那么这个类就进行了进化生成了伴生类但是在使用时是不会受到任何影响的。
我们如果要发送一个XX对象消费者会有一个负责发送的send方法里面包含了参数的url类型等数据。也就是说通过多态直接调用send中的data就可以完成发送。只有在启动生成伴生类时使用了反射其他时候就不在使用反射。
反射类继承了多态消费者调用send方法通过socket进行发送生产者就会接收到同时创建一个对象来储存接收到的信息生产者对数据进行处理后返回给消费者。 这使得整个过程不存在反射极大提高了速度。
附上原图 缺陷 字符串的存储我们需要自己写一个常量池 在嵌套的情况下我们需要知道嵌套的类有多大所以不建议嵌套原生的类最好是嵌套同样带注解的类。 缺陷 字符串的存储我们需要自己写一个常量池 在嵌套的情况下我们需要知道嵌套的类有多大所以不建议嵌套原生的类最好是嵌套同样带注解的类。
