342-学习TARS整体框架

素颜马尾好姑娘i 2022-08-30 04:27 350阅读 0赞

## 1、什么是tars? ##

最早的话，是为了解决开发，运营，测试以后所有共性的问题。这些可以不用去管了，这样大大提供了研发的效率。下图显示的内容都已经先确定了，在我们开发的时候不用去管。我们只需要写业务逻辑。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70]

## 2、Tars的目标 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 1]  
运维人员不需要太懂业务，管理都是一样的。  
缺点是自成一体。

## 3、Tars设计思路 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 2]  
分为5层。最低的协议层：服务端与客户端的通信。二进制的。传输效率高。可扩展，自动生成，多语言。再者比如说C++的时间处理，是系统函数，对系统消耗大，内核态的切换。在本机上有时间localtime文件。倒数第二层的公共库的框架起到了缓存时间，打日志的作用，服务起来就是一个宏，随时打印日志，循环日志，也可以打远程日志。倒数第三层是RPC的通信框架，所有语言的通信框架的原理都是相似的，最早是C++,性能也是稳定的，框架的稳定性。在通信框架之上，有平台，完成这些服务的管理，最后有个运营，所有服务管理都可以在运营上看到。

## 4、这个微服务到底是什么？ ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 3]  
蓝色部分web，部署完看到的页面平台，都是通过web管理，左边的绿色节点是主控节点，它是DNS,提供DNS服务，名字服务。灰色部分是基于框架实现的共性的模块，管理服务的，收集服务的状态。web管理平台在和框架打交道的时候，基本上都是通过AdminRegistry，web发请求给AdminRegistry,AdminRegistry找到各个业务去发送请求。Notify用于收集异常信息，服务在启停的时候或者出现异常的时候会上报给Notify-Server,然后Notify-Server把异常写入DB，我们在web管理平台可以看到这些异常信息。stat服务，所有服务通信的时候，流量和耗时都会上报stat,然后stat写入DB，我们在管理平台就可以看到这些流量和耗时。Log-Server，打远程日志。Patch是发布平台，所有服务的发布都是通过Patch的，Patch-Server和web是在一台机器上的，共享一个目录。Config是配置，存储在DB，对外提供接口，ifconfig把配置从远程拉到本地。Property，业务特性上报。左边的node，每个机器都会安装一个node,即tarsnode，就是一个进程，我们要去监控它，它是用来管理本机上所有运行的业务服务，server1,2····n，每个服务就是一个独立的进程，独立的名字空间，（名字和绑定的端口）可以部署在多台机器，相互通信，互不知道对方的ip端口，只知道名字（在管理平台部署的时候配好的）。两个服务在通信的时候，框架帮忙把通信的体系健全了，从主控拿取名字，实现服务间通信。

## 5、服务的主要交互流程 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 4]  
服务的发布：绿色的web是管理平台，在管理平台提交安装包，发布包，nodejs的server就会上传到自己的路径下，在usr/local/patch,上传好了没有问题了，就会调动AdminRegistry这个主控服务，它会通知patch去发布服务，patch向node发动请求，node到patch上去拉到本机，把本机的服务停掉,把自己启动。客户端服务端通信，client可能是另外一个服务，petsvr服务端，通信的时候通过管理平台配置的唯一的名字，到主控上拿到IP端口，和petsvr建立通信，client和petsvr，每个服务都会建立一个长连接，是轮询的（建议TCP）。单向的方式是丢出去不用回包，一般我们是用异步，协程。nodejs是全异步的。petsvr在本机运行会给自己的node上报信号（处理僵死进程），node知道是僵死进程会杀掉，60秒的处理时间。如果主控挂了，其他业务没有任何影响，client拿到所有服务的ip列表的时候，会缓存在本地，本机和本地的文件都有，当client重启的时候，从主控拿不到ip列表的时候，它会去读本机的文件，建立连接。在管理平台，我们可以向服务发命令，通过发给主控，node，petsvr，一般配置用热加载，改了配置文件，不用重启，通过命令发给Node-serve。stat上报的来源是client客户端。

## 6、后台代码结构（C++） ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 5]  
C++底层有基本的类，库，有tars的协议解析库，Communicator是通用器，一个程序一个就好，线程调用的资源都是通用器管理的，资源消耗大，application是服务端，通用器和服务端都会引用公共服务类型库，jmem是共享内存写的库，最上面就是公共性服务。

## 7、tars协议 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 6]  
协议是所有服务通信的依据，tag标识字段，占4位（后面4位），前4位表示类型，一个字节，optional是可选的意思，表示可以多加信息，服务端先增加，客户端发现没有，会增加一个缺省值。

## 8、代码自动生成 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 7]  
定义了协议结构体和接口，生成C++客户端和服务端的代码，服务端有基类，继承，客户端把生成的代码直接引用，通信。

## 9、远程调用 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 8]

## 10、开发步骤 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 9]  
所有服务开发模式都是一样的，1、定义接口文件，通过类，脚本创建成新的空的服务，把相关接口和类实现好，发布到管理平台，配置好服务的发布的节点，名字，发出去，就运行起来了。客户端拿到接口文件生成代理类，合到本地代码，通用器拿到这个代理，同步异步调用服务。这个服务可以在本机运行。配置文件分为服务配置文件和框架配置文件。服务配置文件是自己写的放在配置中心。框架配置文件是告诉你这个服务要开哪个端口。

## 11、轻量化 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 10]  
服务接口层可以自定义的。所有服务独立运行，不依赖于主控。

## 12、客户端与服务端结构（多线程模型） ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 11]  
server还有一个和本机node通信（127.0.0.1）的端口。通过网络，admin（默认一个线程）。

## 13、服务模型(C++) ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 12]  
C++通过ET，边缘触发。但是会漏事件。

## 14、容错——(服务器挂掉不影响业务) ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 13]  
通过名字去拿端口调用服务。每个svr都有一个连接，所有消息都是轮询。也有hash模式，指定一个用户永远发到一个机器上面。主控定期从DB刷新。容错容灾不完全依赖于主控。所有的连接如果断了，IP地址还没从主控消除掉，client会定期重试，尝试建立连接。

## 15、超时切换——(降低网络影响) ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 14]  
服务端和客户端通信的时候，有超时的情况，尽管连接没有断，数据包超时了，也会切换。

## 16、染色——(察看某个用户所有的信息) ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 15]  
通过对请求，触发后面的所有的日志集群在一台机器上。

## 17、过载（对框架队列的保护） ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 16]  
服务端接收队列达到某个阀值后——  
**拒绝新请求  
监测每条消息在队列中的时间，已超时的消息不做业务逻辑处理  
超时时长由客户端控制**

## 18、问题定位 ##

主要目录  
框架服务目录: /usr/local/app/tars/xxx  
业务服务: /usr/local/app/tars/tarsnode/data/  
服务日志: /usr/local /app/tars/app\_log/xxx/xxxserver/\*.log  
Web日志: /usr/local/app/web/log  
通过start启停。  
教程文档: https://tarscloud.github.io/TarsDocs/  
https://github.com/TarsCloud/Tars

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70]: /images/20220829/8dc23be3a711438591ffdfa103cfea48.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 1]: /images/20220829/fbbc2ecacc994422bb496b23809ea81f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 2]: /images/20220829/8c4aff1953544437bdd7b2ae3c52b177.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 3]: /images/20220829/540cbe3eef954eabbc5cb37e88518f91.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 4]: /images/20220829/258df50d3aba4afc98287d53174f072e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 5]: /images/20220829/8725b7f932f24e3aad2170333f5cd416.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 6]: /images/20220829/e7fa2bcae05e4403a43dab9aa3ec3d6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 7]: /images/20220829/2f11244da84f4b89b0445d628406ca9a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 8]: /images/20220829/21a4e8dbecc94852a3beec0c4d1de5a0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 9]: /images/20220829/bd318ea3affb4992a7f91f3ac4cbfddf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 10]: /images/20220829/2e399e17792347cbae41c9660f642a32.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 11]: /images/20220829/4008455bab1e4fde9412e347a2f85bae.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 12]: /images/20220829/4295f82b1601450795933b8500ecef9b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 13]: /images/20220829/832d03c68379441997f729fcbfdc1914.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 14]: /images/20220829/1ed1beb1903647b2ae6fa88c2c445f0a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 15]: /images/20220829/c69934cd97004e5ea63c0d3de7bb42c9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 16]: /images/20220829/ebaeadf7a62146a4b0a3305fe36edc91.png