1.Rocketmq 5.0 任意时间定时消息（RIP-43） 原理详解 & 源码解析
2.认证计费一体化网关功能介绍
3.有没有免费的控源控源上网行为管理系统和软路由系统推荐。
4.PolarDB-X 源码解读（七）：私有协议连接的码免码一生（CN篇）
5.springbootcloud组件

Rocketmq 5.0 任意时间定时消息（RIP-43） 原理详解 & 源码解析

       延迟消息，又称定时消息，费流其核心在于消息到达消息队列服务端后不会立即投递，控源控源而是码免码在特定时间点投递给消费者。这种机制在当前互联网环境中有着广泛的费流pb重构源码需求，尤其在电商、控源控源网约车等场景中，码免码用户下单后可能不会立即付款，费流订单也不会一直处于开启状态，控源控源需要一定时间后进行回调，码免码以关闭订单。费流此时，控源控源使用分布式定时任务或消息队列发送延迟消息是码免码更轻量级的选择。

       延迟消息与定时消息在实现效果上相同，费流都是指消息在经过一段时间后才会被投递。在RocketMQ 4.x中，仅支持通过设定延迟等级来支持个固定延迟时间。然而，这种方案的局限性在于无法支持任意时间的定时，且最大定时时间仅为2小时，性能也难以满足需求。因此，许多公司开始自研任意时间定时消息，扩展最大定时时长。

       在RocketMQ 5.x中，开源了支持任意时间的定时消息。与4.x的延迟消息相比，5.x的定时消息在实现机制上完全不同，互不影响。在5.x客户端中，构造消息时提供了3个API来指定延迟时间或定时时间。

       任意时间定时消息的实现存在一些难点，例如任意的定时时间、定时消息的存储和老化、以及大量定时消息的极端情况等。为了解决这些问题，RIP-引入了TimerWheel和TimerLog两个存储文件，以实现任意时间的定时功能。TimerWheel是一个时间轮的抽象，表示投递时间，它保存了2天（默认）内的所有时间窗。TimerLog则是定时消息文件，保存定时消息的索引，以链表结构存储。通过这两个文件，可以有效地实现任意时间的定时功能。

       此外，RIP-还设计了定时任务划分和解耦的机制，将定时消息的保存和投递分为多个步骤，每个步骤都由一个服务线程来处理。通过使用生产-消费模式，实现了任务的解耦和流控，确保了系统的稳定性和性能。

       在源码解析方面，RIP-中引入了TimerWheel和TimerLog两个文件，以及TimerEnqueueGetService、TimerEnqueuePutService、TimerDequeueGetService、TimerDequeueGetMessageService、TimerDequeuePutMessageService等组件，实现了定时消息的保存和投递功能。

认证计费一体化网关功能介绍

       è®¤è¯è®¡è´¹ä¸€ä½“化网关功能介绍

       æ˜Ÿé”‹èˆªè®¤è¯è®¡è´¹ä¸€ä½“化网关为千兆以上网络环境提供的一款高性能、高可用性、功能丰富、并具有一定升级扩容空间的骨干网出口设备。帮助运营商很好的管理用户、网络，具体功能如下：

       1、出口汇聚功能

       å¯åœ¨å‡ºå£åˆ’分多钟vlan模式，汇聚拨号跟专线出口线路，汇聚线路最多可达数百条。

       2、智能多WAN负载均衡

        支持多线路负载均衡、线路备份，通过支持基于会话流的策略路由功能，使得策略路由与安全特性协同工作，从而实现接口级负载分担。当一条链路故障时，流量将切换到其它正常的链路中。有效解决了因为某一条线路中断而影响整个网络的情况。

       3、全局路由

        全局路由基于三层协议，简洁高效，准确度高，对设备资源占用小。

       4、多样认证、计费方式

       æ”¯æŒWeb登陆、pppoe、专用客户端、radius认证、pptp_***，支持微软系统自带的***及Android、iOS系统自带***拨入认证多种认证方式。对运营商，支持个人用户的按时长、流量、期限资费策略，阶梯式计费策略。支持多种预付费卡、充值卡等卡类业务；对高校用户，支持根据所在区域不同计费策略，访问国内国外不同流量资费；对集团客户的专线接入，支持基于流量计费，业务的实时计费、预付费。

       5、强大的动态NAT功能

       åœ°å€è½¬æ¢å¯æ ¹æ®è·¯ç”±æƒ…况实现动态转换，多出口时，尤其当路由设置是混合路由时，网关可根据访问地址不同，自动转换为相应合法ip。最大支持上千万的NAT并发连接数。

       6、流控功能

       ç½‘关设备能够根据用户流量排序，统计进出口流量情况，能监管任何一个设备或任意一个帐号的上下行流量，实时绘图，并保存一年以上网内所有ip的流量图。

       7、防火功能

       å¯¹å…¨ç½‘防火，对特定服务器防火Arp病毒防护，IP源地址验证，防止IP地址欺骗；可记录ssh、远程桌面等远程安全操作的访问，并根据危险等级，予以封锁。

       8、Dhcp功能

       æœ¬äº§å“å¸¦æœ‰å®Œå¤‡çš„dhcp功能。

       9、DNS定向解析功能

       1）登录时的定向跳转：在PPPOE用户拨号登陆后，或者IP用户连接网络后跳转到指定页面。

       2）实时重定向：有时紧急通知所有正在上网的用户，可以将用户正在访问的页面重定向到通知页面上去，可控制定向时间，比如秒。

       ã€å®‰å…¨å¤‡ä»½åŠŸèƒ½

       æ˜Ÿé”‹èˆªç½‘关支持多机负载热备。单机情况下系统自动备份，并可设置每天定时将备份信息发送至管理员邮箱。

       ã€è¿œç¨‹ç®¡ç†åŠŸèƒ½

       æ˜Ÿé”‹èˆªç½‘关支持动态域名解析，方便远程管理。Web管理页面兼容市场主流的浏览器。身处异地，甚至用手机也可以便捷管理网关。

       ã€å¼€æ”¾çš„第三方接口和特殊功能定制

       æ ¹æ®ç”¨æˆ·çš„需求，定制特殊功能。部分源代码可根据用户的需要功能公开，以便支持第三方系统。

有没有免费的上网行为管理系统和软路由系统推荐。

       路由系统、又称RouterOS，已经是一个非常开源的技术了。不管是在LINUX系统上的，还是在windows系统上的，都很很多这样的开源项目，技术简单，结构也非常单一。而随着时代发展，修改源码软件app后期又加上了***和基础的包过滤防火墙，也都是开源成熟的项目。大部分厂家也是在这些项目上修修改改，包装包装打造成一个商业产品销售给用户。（当然产品的商业价值和技术价值也没有啥可比性）。

       但是近十年来，随着上网行为管理需求的迅猛发展，从网页过滤到协议过滤，以及内网安全的需要。单纯的路由系统已经不能满足用户的需要，很多的路由器网关都开始带有上网行为管理和防火墙模块，第二代防火墙（Next

        Generation

       Firewall）的概念也应运而生。但是真正做到第二代防火墙的厂家不多，很多路由厂商也乱入，但是效果怎么样，各家都有一说。

       今天介绍的是国内外几款免费的上网行为管理系统、防火墙和路由系统。以免费的为主，因为是免费的，所以多少有缺憾，要么是功能，要么是授权数。待我慢慢道来。

       1. PFsense

       一个老牌的opensource的防火墙系统，官网地址大家自己找，软件免费，硬件收费。

       系统的特点是路由和防火墙功能比较强大，而且集成了入侵检测、漏洞扫描等模块，当然路由和限速这些基础功能都是妥妥的。缺点是上网行为管理功能比较薄弱，不能进行应用过滤和网址库过滤。众所周知，国外的软件，界面很复杂。照老外的说法，没个degree，都不好意思去配置。

       另外，PFsense还有收费培训和服务，也可以直接买他们的硬件，价格还算适中。产品也是开源的，源码都公开了。（语言好像已经有了中文版，但是不确定，我的信息来自他们官网）良心产品，靠服务和硬件生存，没有License限制，也没有功能限制。

       2. Routeros

       路由系统的先锋了，号称路由系统占有率第一位。出自东欧的小国家，所以价格很低廉，市场上充斥了很多破解版，其实正版价格已经很低廉了（可以低到忽略价格）。

       只是不是我们国家本土产品，可能服务跟不上。ROS系统几乎没有什么升级维护的工作，系统很稳定，只要上网方式没有什么革命性的更改，那就一直能用。

       ROS的路由功能大概是全世界研究的最彻底的了，缺点就是界面狂复杂，它的配置完全可以在大学开一门功课。在西方和东南亚非常受欢迎，各种技术讨论论坛也异常火爆。就是配置复杂的有点扯蛋了。

       总体来说，资金柱指标源码是个好产品，对于网吧、小区宽带这种宽带运营的网络用着蛮好。缺点是没有网页过滤、应用过滤这些上网行为管理的功能，只有基础防火墙模块。也可以限速，路由功能和***做的很稳定。网管一旦掌握，也是把利器。

       3. Sophos

       这个是个全球化的产品，大厂家，大品牌。家庭版本是免费的，支持用户。路由、***、防火墙模块，尤其是防御功能、网关杀毒这块做的很好，也有协议过滤模块和网址库过滤。软件和硬件都可以提供。优势还是在杀毒和防火墙。欧洲的安全老厂家，价格不用想，不在天上也在云端。

       4. Untangle

       十年以上的老产品了。重点是上网行为管理和防火墙、杀毒功能。家庭版本$一年，用户。（别指望家庭版本可以用在企业里，他们号称可以检测到是什么环境在用，一旦违规会停掉了，估计软件里面有什么检测工具啥的）。软件和硬件都可以提供。

       不过价格就算对于美国本土用户，也是非常昂贵的。硬件销售是硬件的价格加上软件价格，软件价格那是天上的价格，服务也一般。

       产品扎实，各种协议管理，网络安全，路由模式，防火墙模块，杀毒都有。除了价格以外（用户的软件License，一年近刀），对于企业选择全方位专业的上网行为管理网关和下一代防火墙，真的是个好选择。

       5. WFilter-NGF

       也是十年以上的老产品了，本土研发，走国际路线，国内市场推广能力不强，用户大部分在国外。专门研究网络监控和协议分析。专注上网行为管理功能，在Web过滤和协议过滤等上网行为管理的方面做的很扎实。产品的界面有点类似上面的untangle。缺点是没有网关杀毒和主动防御功能。服务不错，有问必答，还可以远程协助配置。软件和硬件方案都可以提供。他们的公司名字非常有趣，值得一提的是，WFilter还有windows的旁路上网行为管理软件。不想添加硬件的话，是上网行为管理的一个可选方案。价格中等吧，码支付pc源码性价比高。用户全功能免费，对于人以内的小企业来说，个人觉得是不二之选。

       5. 爱快路由系统

       本土产品，软件全免费，靠卖硬件挣钱。免费版本各种坊间传闻都有，就不一一表了。基本的路由功能都有，不过上网行为管理做的比较鸡肋。爱快的系统个人认为比较偏向做局域网无线部署方案。企业管理这块不怎么来事。但是好在系统是免费的，这个比较受欢迎。

       6. 国内还有维盟，海蜘蛛，和爱快也都是大同小异，还有一家pandbit，侧重流控的路由系统，就不一一介绍了，仁者见仁。

       总结一下，分为“路由系统”和“上网行为管理/防火墙系统”两大系列。如果只是要做路由，那么ROS从性能，稳定性上真的很不错的选择。如果是企业用上网行为管理和下一代防火墙；语言没有问题的话，可以看看untangle和sophos以及WFilter-NGF；追求中文版的话，那么WFilter-NGF一定是个最好的选择。

       还有一点要说一下：路由系统，比如ROS差不多是一个一次性软件了，买了就直接用了，几乎不需要升级和更新。但是上网行为管理的“协议过滤”和“网址库过滤”，都是需要升级服务的，这就是为什么很多上网行为管理软件按年收费，国内大品牌的上网行为管理设备后续还要每年收服务费的原因。如果选择上网行为管理产品，一定要考虑后续服务的质量和费用。

PolarDB-X 源码解读（七）：私有协议连接的一生（CN篇）

       通过前文的介绍，大家基本了解了一条SQL在polardbx-sql中的解析和执行流程。由于polardbx-sql是无状态的计算节点，真正数据需要从存储节点传输到计算节点，这部分工作由私有协议完成。本文将详细介绍从发送请求到存储节点，接收返回数据的完整流程，重点在于私有协议连接的生命周期和关键代码解析。

       概述

       为了提高数据节点本地计算能力，同时减少网络数据传输量，计算节点会尽可能下推计算内容。一个逻辑表可能需要多个物理分片，因此计算节点与存储节点的请求会话数量会随着分片数增加而增加。传统MySQL协议+连接池架构已不能满足PolarDB-X的需求，因此私有协议在这一需求场景下应运而生。

       如图所示，私有协议采用连接与会话分离的RPC协议设计理念，支持多个会话在同一个TCP通道中并行运行，具备流控机制、全双工响应式工作模式和高吞吐、可扩展等特性。

       更多关于私有协议解决上述问题的设计详情，可以参考《PolarDB-X私有协议设计》一文。本文主要从代码层面详细描述私有协议的工作流程。

       我们将从计算节点和存储节点两个角度完整解析私有协议连接的生命周期。篇幅限制，本文仅关注计算节点上私有协议的处理，存储节点部分将在后续文章中详细说明。

       计算节点

       计算节点作为私有协议的客户端，负责发送下推请求，并接收返回的hadoop底层源码python数据。

       网络层框架

       PolarDB-X私有协议网络层采用定制化Reactor框架实现，基于Java的NIO，改进自polardbx-sql中的Reactor框架。网络层初始化时，设置CPU核心数的2倍（上限为）作为NIOProcessor，每个Reactor使用独立的堆外内存池作为收发包缓冲，总缓冲内存大小限制为堆内存大小的%。

       NIO接收的包直接调用注册的处理函数，发送数据仅写入send buf，网络写入由单独线程完成。线程优先写入TCP send buf，当无法写入时，注册OP_WRITE事件等待可写后再写入剩余内容。

       数据包的编码和解码在NIOClient中实现。为实现最佳性能，解包流程直接在堆外内存上进行，使用protobuf对流直接解析，将结果放入堆内。堆外内存被切分为KB chunk，每个Reactor独占一个chunk，连续解析和复用，最大化接收、解析效率。对于特大包，额外构造堆内大buffer接收和解析，回退标志在定时任务中重置，连续s无超大包时释放堆内内存，恢复高性能堆外KB buffer接收。

       请求发送集成在NIOClient中，writer优先尝试写入发送缓冲队列尾部的buffer，不足时新申请buffer填充并追加到队尾。buffer来自预分配的堆外缓冲池，超过chunk大小时分配堆内buf进行序列化。

       同时，NIOClient负责TCP连接的建立和断开资源释放，作为独立的底层网络资源管理实现。

       连接及会话

       网络层之后，我们聚焦连接与会话分离的具体实现。通过剥离连接及收发包的具体实现，连接和会话的管理变得更加清晰简洁。

       首先，一个TCP连接的逻辑抽象结构在XClient中实现，为避免误解，取名为client与JDBC中的Connection区别。该类管理TCP连接和并行运行的会话，负责TCP完整生命周期的管理、认证鉴权，并维护公共信息。其中，workingSessionMap记录了连接上并行运行的所有会话映射关系，可快速通过会话ID找到对应的会话抽象结构XSession。

       XSession提供了所有会话相关的请求函数和信息存储，包括执行计划请求、SQL查询请求、SQL更新请求、TSO请求、会话变量处理、数据包处理及异步唤醒等。

       连接池及全局单例管理器

       为了提高性能，TCP连接和会话的复用必不可少。由于连接和会话的解绑，连接池不仅缓存了到计算节点的TCP连接，也缓存了到计算节点的会话。

       XClientPool管理到一个存储节点的连接池，通过IP，端口，用户名三元组唯一确定目标存储节点，同时存储该节点的全部TCP连接（XClient）和建立的会话（XSession）。

       XClientPool实现存储节点会话获取，对应JDBC接口中的getConnection，同时实现连接和会话生命周期管理、连接探活、会话预分配等功能。实现单个存储节点连接池后，XConnectionManager维护目标存储节点三元组到实例连接池的映射，管理定时任务线程池，实现定时探活、会话&连接最长生命控制以及连接池预热等功能。

       JDBC兼容层

       新的SQL协议层对上层使用者要求较高，为了提高开发效率，私有协议提供兼容JDBC的使用方法，实现从JDBC平滑切换至私有协议，并支持协议热切换。

       JDBC兼容层代码目录在compatible目录下，Connection继承在XConnection文件中。提供包括DataSource、Connection、Statement、PreparedStatement、ResultSet、ResultSetMetaData在内的大部分常用接口函数实现，不支持的函数会明确抛出异常避免误用。

       整体关系

       至此，私有协议计算节点端的大部分结构已说明完成。给出一个整体的关系图。

       私有协议连接的一生（CN视角）

       了解了私有协议各层实现后，我们以发到存储节点的请求为例，完整梳理执行流程。绕开计算节点复杂流程，直接运行代码示例（注：需将com.alibaba.polardbx.rpc.XConfig#GALAXY_X_PROTOCOL设置为true）。

       直接运行playground看到预期的select 1的结果。接下来，我们深入跟踪说明。

       数据源初始化

       要使用私有协议，需要初始化对应存储节点的XDataSource。构造过程中，XDataSource会到XConnectionManager注册新的实例连接池，已存在的连接池引用计数加一。

       获取Connection

       当需要执行查询时，首先获取会话。无论是显式开启事务还是使用auto commit事务，会话都是执行请求的最小上下文。通过XDataSource的getConnection方法获取到对应存储节点的会话。XDataSource根据存储的IP，端口，用户名三元组查找到XConnectionManager中的连接池，在最高并发检查后，会话获取逻辑在XClientPool实现。首先尝试在空闲会话池中拿会话，通过重置检查和初始化后返回给调用者。大部分场景下，ConcurrentLinkedQueue提供较好的并发性能。

       在代码场景下，数据源刚新建，后台定时任务未运行，流程进入连接创建流程。会有一把大锁锁住连接池，在TCP连接未达上限且没有超时的情况下，快速新建一个XClient占坑。若超限，则进入busy waiting循环。真正的TCP connect（waitChannel）在锁外被调用，首先client以阻塞模式带超时方式connect，然后切换为非阻塞模式，round robin策略注册到NIOProcesser上，返回时，TCP连接已建立。

       为了兼顾安全和性能，连接鉴权在TCP建连后只用做一次，会话创建不需要鉴权。鉴权在initClient中完成，发送SESS_AUTHENTICATE_START_VALUE包，后续校验由回调完成。认证采用标准的MySQL认证流程，server端返回challenge值，库名、用户名和加盐hash后的密码返回给MySQL即可完成认证。

       至此，到存储节点的TCP连接已建立，创建会话是一个异步流程。在创建新XClient时，XConnection已new好，通过下断点跟进去可看到newXSession流程，分配session id，设置状态为init，将XSession绑定到XConnection上。

       最后，XConnection经过初始化（重置auto commit状态）、重置默认DB、默认字符集（lazy操作）和统计信息记录，返回给用户使用。

       发送查询请求

       拿到初始化好的兼容JDBC的Connection，为了简化流程，直接调用XConnection中的execQuery。XConnection的execQuery包装了XSession的execQuery，执行前执行了设置流式模式。

       首先记录调用信息进行统计，进入关键的initForRequest流程。XSession初始化流程lazy，仅分配session id，设置状态为Init，真正创建session时发送SESS_NEW给server，绑定新session和session id。如果session已复用，则状态为Ready。

       执行字符集更改的lazy操作，session可能在其他请求中切换字符集，根据目标字符集和当前字符集对比，决定是否发送额外的字符集更改请求。

       经过一系列变量设置、lazy DB设置和protobuf包构造，请求发送到存储节点执行。发送后，同步生成XResult负责结果解析，同时XResult按照请求顺序依次拉链表，确保结果与请求一一对应。

       请求流水线结构如下图所示，处理完成前序请求后，才能解析后续结果。

       接收结果集

       请求已发送到存储节点执行，拿到XResult，通过XResult收集查询结果集。XResult与发送请求一一对应，存储节点处理也是在会话上排队进行，不会影响流水线上其他请求的返回，保证流水线正常工作。

       首先，查看结果集处理的状态机，主要状态包括获取元数据、获取数据行、获取额外信息等，顺序固定，根据请求类型，部分环节可能被省略。报错处理贯穿整个状态机，任何报错信息都会导致状态机进入错误处理环节。

       对于非流式数据读取，请求结束时主动调用finishBlockMode将所有数据读出并缓存到rows中。对于流式执行的情况，结果集状态机消费数据包队列由XResult的next函数推动，内部函数internalFetchOneObject递归调用前序XResult，消费前序请求结果，从数据包队列中消费并推动状态机流转。

       对于查询，首先收到RESULTSET_COLUMN_META_DATA包，表示返回数据列定义，一个包表示一列。元数据包后，收到包含数据行的RESULTSET_ROW包，一个包对应一行。数据行传输完成后，server端发送RESULTSET_FETCH_DONE标示数据发送完成。请求结束前，NOTICE包用于告知客户端rows affected等信息。最后，SQL_STMT_EXECUTE_OK包标示请求结束。

       至此，完整请求处理完成，控制台应显示查询结果。

       总结

       本文详细描述了私有协议连接流程中的关键点和关键数据结构，相信通过本文描述，大家掌握了私有协议连接流程的基本点，在调试和修改使用中能够更加得心应手。虽然本文篇幅较长，但实际使用中涉及更多高级特性的使用，如多请求流水线、流控、执行计划传输、chunk结果集传输等。通过本文，我们对私有协议连接流程有了深入理解，为在实际场景中应用提供坚实基础。

springbootcloud组件

       .SpringBoot和SpringCloud的关系

       很多人新手对于SpringBoot和SpringCloud的关系说不清楚、理解不清楚，本文抽出点时间来进行分享下自己的理解，以帮助大家更好的理解两者之间的关系。

       其设计目的之初是用来简化Spring应用的初始搭建以及开发过程。很多东西都是配置好的，约定大于配置，使用注解替代了很多xml臃肿的配置，极大的简化了项目配置的消耗，提供了高效的编程脚手架。

       Cloud相当于利用了SpringBoot的开发便利性巧妙地简化了分布式系统基础设施的开发，像是服务注册发现、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用SpringBoot的开发风格做到一键启动和部署，SpringCloud并没有重复的造轮子，把各家公司成熟，经得起考验的服务框架组合起来，通过SpringBoot屏蔽调复杂的配置和实现原理，留给开发者一套简单易懂、容易部署、容易维护的分布式开发工具包。

       其中的关系是：

       Spring-》SpingBoot-》SpringCloud

       Cloud的核心组件：

       感觉这个话题能写好多的东西，像是SpingCloud和Dubbbo的微服务选型等等再进行对比、比较优缺点，本篇就简单的进行了总结和介绍，希望能帮助到有困惑的朋友吧，后面有时间在写一些文章进行拓展和补充。

SpringCloud微服务体系的组成

       NetflixEureka是SpringCloud服务注册发现的基础组件

       Eureka提供RESTful风格(HTTP协议)的服务注册与发现

       Eureka采用C/S架构,SpringCloud内置客户端

       启用应用,访问

       Eureka客户端开发要点

       maven依赖spring-cloud-starter-netflix-eureka-clientapplication.yml

       配置eureka.client.service-url.defaultZone

       入口类增加@EnableEurekaClient

       先启动注册中心,在启动客户端,访问localhost:查看eureka注册中心,看到客户端注册

       Eureka名词概念

       Register-服务注册,向Eureka进行注册登记

       Renew-服务续约,秒/次心跳包健康检查.秒未收到剔除服务

       FetchRegistries-获取服务注册列表,获取其他微服务地址

       Cancel-服务下线,某个微服务通知注册中心暂停服务

       Eviction-服务剔除,秒未续约,从服务注册表进行剔除

       Eureka自我保护机制

       Eureka在运行期去统计心跳失败率在分钟之内是否低于%

       如果低于%，会将这些实例保护起来，让这些实例不会被剔除

       关闭自我保护:eureka.服务实例.

       enable-self-preservation:false

       PS:如非网络特别不稳定,建议关闭

       Eureka高可用配置步骤

       服务提供者defaultZone指向其他的Eureka

       客户端添加所有Eureka服务实例URL

       Actuator自动为微服务创建一系列的用于监控的端点

       Actuator在SpringBoot自带，SpringCloud进行扩展

       pom.xml依赖spring-boot-starter-actuator

       RestTemplate+@LoadBalanced显式调用

       OpenFeign隐藏微服务间通信细节

       Ribbon是RestTemplate与OpenFeign的通信基础

       Feign是一个开源声明式WebService客户端，用于简化服务通信

       Feign采用“接口+注解”方式开发，屏蔽了网络通信的细节

       OpenFeign是SpringCloud对Feign的增强，支持SpringMVC注解

       1.新建SpringbootWeb项目，applicationname为product-service

       在pom.xml中引入依赖

       spring-cloud-starter-alibaba-nacos-discovery作用为向Nacosserver注册服务。

       spring-cloud-starter-openfeign作用为实现服务调用。

       2.修改application.yml配置文件

       3.在启动类上添加@EnableDiscoveryClient、@EnableFeignClients注解

       4.编写OrderClientInterface

       注：/api/v1/order/test会在下面order-service声明。

       OrderClient.java

       5.编写Controller和service

       ProductController.java

       ProductService.java

       1.OpenFeign开启通信日志

       基于SpringBoot的logback输出,默认debug级别

       设置项：feign.client.config.微服务id.loggerLevel

       微服务id：default代表全局默认配置

       2.通信日志输出格式

       NONE:不输出任何通信日志

       BASIC:只包含URL、请求方法、状态码、执行时间

       HEADERS：在BASIC基础上，额外包含请求与响应头

       FULL：包含请求与响应内容最完整的信息

       3.OpenFeign日志配置项

       LoggerLevel开启通信日志

       ConnectionTimeout与ReadTimeout

       利用flix-hystrix-dashboard

       监控微服务利用@EnableHystrixDashboard开启仪表盘

       9.Hystrix熔断设置

       产生熔断的条件:

       当一个RollingWindow(滑动窗口）的时间内（默认：秒），最近次调用请求，请求错误率超过%，则触发熔断5秒，期间快速失败。

       TIPS:如秒内未累计到次，则不会触发熔断

       Hystrix熔断设置项:

       统一访问出入口,微服务对前台透明

       安全、过滤、流控等API管理功能

       易于监控、方便管理

       NetflixZuul

       SpringCloudGateway

       Zuul是Netflix开源的一个API网关,核心实现是Servlet

       SpringCloud内置Zuul1.x

       Zuul1.x核心实现是Servlet，采用同步方式通信

       Zuul2.x基于NettyServer，提供异步通信

       认证和安全

       性能监测

       动态路由

       负载卸载

       静态资源处理

       压力测试

       SpringCloudGateway，是Spring“亲儿子”

       SpringCloudGateway旨在为微服务架构提供一种简单而有效的统一的API路由管理方式

       Gateway基于Spring5.0与SpringWebFlux开发，采用Reactor响应式设计

       1.使用三部曲

       依赖spring-cloud-starter-netflix-zuul

       入口增加@EnableZuulProxy

       application.yml增加微服务映射

       2.微服务映射

       SpringCloudZuul内置Hystrix

       服务降级实现接口：FallbackProvider

       1.微服务网关流量控制

       微服务网关是应用入口，必须对入口流量进行控制

       RateLimit是SpringCloudZuul的限流组件

       RateLimit采用“令牌桶”算法实现限流

       2.什么是令牌桶

       1.Zuul的执行过程

       2.Http请求生命周期

       1.需要实现ZuulFilter接口

       shouldFilter()-是否启用该过滤器

       filterOrder()-设置过滤器执行次序

       filterType()-过滤器类型:pre|routing|post

       run()-过滤逻辑

       2.Zuul内置过滤器

       3.Zuul+JWT跨域身份验证

       1.SpringCloudConfig

       2.携程Apollo

       3.阿里巴巴Nacos

       1.依赖"spring-cloud-starter-config"

       2.删除application.yml,新建bootstrap.yml

       3.配置"配置中心"服务地址与环境信息

       1、微服务依赖"spring-boot-starter-actuator";

       2、动态刷新类上增加@RefreshScope注解

       3、通过/actuator/refresh刷新配置

       1、通过加入重试机制、提高应用启动的可靠性;

       2、重试触发条件1:配置中心无法与仓库正常通信

       3、重试触发条件2:微服务无法配置中心正常通信

       SpringCloud整体构架设计（一）

       SpringClound整体核心架构只有一点：Rest服务，也就是说在整个SpringCloud配置过程之中，所有的配置处理都是围绕着Rest完成的，在这个Rest处理之中，一定要有两个端：服务的提供者（Provider）、服务的消费者（Consumer），所以对于整个SpringCloud基础的结构就如下所示：

       既然SpringCloud的核心是Restful结构，那么如果要想更好的去使用Rest这些微服务还需要考虑如下几个问题。

       1、所有的微服务地址一定会非常的多，所以为了统一管理这些地址信息，也为了可以及时的告诉用户哪些服务不可用，所以应该准备一个分布式的注册中心，并且该注册中心应该支持有HA机制，为了高速并且方便进行所有服务的注册操作，在SpringCloud里面提供有一个Eureka的注册中心。

       对于整个的WEB端的构架（SpringBoot实现）可以轻松方便的进行WEB程序的编写，而后利用Nginx或Apache实现负载均衡处理，但是你WEB端出现了负载均衡，那么业务端呢？应该也提供有多个业务端进行负载均衡。那么这个时候就需要将所有需要参与到负载均衡的业务端在Eureka之中进行注册。

       在进行客户端使用Rest架构调用的时候，往往都需要一个调用地址，即使现在使用了Eureka作为注册中心，那么它也需要有一个明确的调用地址，可是所有的操作如果都利用调用地址的方式来处理，程序的开发者最方便应用的工具是接口，所以现在就希望可以将所有的Rest服务的内容以接口的方式出现调用，所以它又提供了一个Feign技术，利用此技术可以伪造接口实现。

       在进行整体的微架构设计的时候由于牵扯的问题还是属于RPC，所以必须考虑熔断处理机制，实际上所有的熔断就好比生活之中使用保险丝一样，有了保险丝在一些设备出现了故障之后依然可以保护家庭的电器可以正常使用，如果说现在有若干的微服务，并且这些微服务之间可以相互调用，例如A微服务调用了B微服务，B微服务调用了C微服务。

       如果在实际的项目设计过程之中没有处理好熔断机制，那么就会产生雪崩效应，所以为了防止这样的问题出现，SpringCloud里面提供有一个Hystrix熔断处理机制，以保证某一个微服务即使出现了问题之后依然可以正常使用。

       通过Zuul的代理用户只需要知道指定的路由的路径就可以访问指定的微服务的信息，这样更好的提现了java中的“key=value”的设计思想，而且所有的微服务通过zuul进行代理之后也更加合理的进行名称隐藏。

       在SpringBoot学习的时候一直强调过一个问题：在SpringBoot里面强调的是一个“零配置”的概念，本质在于不需要配置任何的配置文件，但是事实上这一点并没有完全的实现，因为在整个在整体的实际里面，依然会提供有application.yml配置文件，那么如果在微服务的创建之中，那么一定会有成百上千个微服务的信息出现，于是这些配置文件的管理就成为了问题。例如：现在你突然有一天你的主机要进行机房的变更，所有的服务的IP地址都可能发生改变，这样对于程序的维护是非常不方便的，为了解决这样的问题，在SpringCloud设计的时候提供有一个SpringCloudConfig的程序组件，利用这个组件就可以直接基于GIT或者SVN来进行配置文件的管理。

       在整体设计上SpringCloud更好的实现了RPC的架构设计，而且使用Rest作为通讯的基础，这一点是他的成功之处，由于大量的使用了netflix公司的产品技术，所以这些技术也有可靠的保证。

Spring全家桶笔记：Spring+SpringBoot+SpringCloud+SpringMVC

       最近我整理了一下一线架构师的Spring全家桶笔记：Spring+SpringBoot+SpringCloud+SpringMVC，分享给大家一起学习一下~文末免费获取哦

       Spring是一个轻量级控制反转(IoC)和面向切面(AOP)的容器框架。Spring框架是由于软件开发的复杂性而创建的。Spring使用的是基本的JavaBean来完成以前只可能由EJB完成的事情。然而，Spring的用途不仅仅限于服务器端的开发。从简单性、可测试性和松耦合性角度而言，绝大部分Java应用都可以从Spring中受益。

       1.1Spring面试必备题+解析

       1.2Spring学习笔记

       （1）Spring源码深入解析

       （2）Spring实战

       1.3Spring学习思维脑图

       SpringBoot是由Pivotal团队提供的全新框架，其设计目的是用来简化新Spring应用的初始搭建以及开发过程。该框架使用了特定的方式来进行配置，从而使开发人员不再需要定义样板化的配置。通过这种方式，SpringBoot致力于在蓬勃发展的快速应用开发领域(rapidapplicationdevelopment)成为领导者。

       2.1SpringBoot面试必备题+解析

       2.2SpringBoot学习笔记

       （1）SpringBoot实践

       （2）SpringBoot揭秘快速构建微服务体系

       2.3SpringBoot学习思维脑图

       springcloud是微服务架构的集大成者，将一系列优秀的组件进行了整合。基于springboot构建，对我们熟悉spring的程序员来说，上手比较容易。通过一些简单的注解，我们就可以快速的在应用中配置一下常用模块并构建庞大的分布式系统。

       3.1SpringCloud面试必备题+解析

       3.2SpringCloud学习笔记

       （1）SpringCloud参考指南

       SpringMVC是一种基于Java的实现MVC设计模式的请求驱动类型的轻量级Web框架，使用了MVC架构模式的思想，将web层进行职责解耦，基于请求驱动指的就是使用请求-响应模型，框架的目的就是帮助我们简化开发

       4.1SpringMVC面试必备题+解析

       4.2SpringMVC学习笔记

       （1）看透SpringMVC源代码分析与实践

       （2）精通SpringMVC

       最后分享一下一份JAVA核心知识点整理（PDF）

SpringBoot和SpringCloud的区别

       1、springcloud是基于springboot的一种框架，包括eureka、ribbon、feign、zuul、hystrix等

       2、SpringBoot可以离开SpringCloud独立使用开发项目,但是SpringCloud离不开SpringBoot

       3、Springboot是Spring的一套快速配置脚手架，可以基于springboot快速开发单个微服务；SpringCloud是一个基于SpringBoot实现的云应用开发工具；

       4、Springboot专注于快速、方便集成的单个个体，SpringCloud是关注全局的服务治理框架；

       5、springboot使用了默认大于配置的理念，很多集成方案已经帮你选择好了，能不配置就不配置，SpringCloud很大的一部分是基于Springboot来实现。

       6、Springboot可以离开SpringCloud独立使用开发项目，但是SpringCloud离不开Springboot，属于依赖的关系。

       Spring-SpringBootSpringCloud这样的关系