go-zero 实战（5）

引入Prometheus

用 Prometheus 监控应用

1. 用 docker 启动 Prometheus

编辑配置位置，我将 prometheus.yaml 和 targets.json 文件放在了 /opt/prometheus/conf目录下

prometheus.yaml

global:scrape_interval: 15s # 抓取间隔evaluation_interval: 15s # 评估间隔scrape_configs:- job_name: 'file_ds'file_sd_configs:- files:- 'targets.json'

由于 prometheus.yaml 文件中，用到了 targets.json 文件，因此，引入 targets.json文件

targets.json

[{"targets":["192.168.10.20:9081"],"labels": {"job": "user-api","app": "user-api","env": "test","instance": "192.168.10.20:8888"}    }
]

我的应用是启动在 宿主机的 8888 端口，因此，我这里写了宿主机的 ip 和端口。
上面的 9081 端口，可以随便写。但是要与应用中的配置一致，看后面配置。

docker run -d --name prometheus --dns=192.168.10.20 -p 9090:9090  -v /opt/prometheus/conf/prometheus.yaml:/etc/prometheus/prometheus.yml  -v /opt/prometheus/conf/targets.json:/etc/prometheus/targets.json quay.io/prometheus/prometheusdocker run -d --name prometheus --network host   -v /opt/prometheus/conf/prometheus.yaml:/etc/prometheus/prometheus.yml  -v /opt/prometheus/conf/targets.json:/etc/prometheus/targets.json quay.io/prometheus/prometheus

下面两条命令都可以启动 Prometheus。

2. 启动应用

修改应用的配置文件 userapi/etc/userapi-api.yaml 文件。

在这里插入图片描述
增加了 Prometheus 配置，端口号与 targets.json 文件中的 targets 条目标识的端口号保持一致。

3.测试

访问 http://192.168.10.20:9090/targets?search=
在这里插入图片描述
这样可以看到 Prometheus 监控了应用。

引入 jaeger

jaeger 是一个用于链路追踪的中间件。

1. docker 启动 jaeger

docker run -d -e COLLECTOR_ZIPKIN_HTTP_PORT=9411 -p 5775:5775/udp -p 6831:6831/udp -p 6832:6832/udp -p 5778:5778  -p 16686:16686 -p 14268:14268  -p 14269:14269   -p 9411:9411 jaegertracing/all-in-one:latest

这样启动的 jaeger，数据默认是放在内存中的。可以根据直接的需求，选择将数据放在 elasticsearch或其它存储中。

  • 其中 16686 是 ui 端口，直接访问 http://localhost:16686 便可以进入到 ui 界面
    在这里插入图片描述

2. 修改 userapi/etc/userapi-api.yaml 文件

在配置文件中加入如下配置：

Telemetry:Name: user-apiEndpoint: http://localhost:14268/api/tracesSampler: 1.0Batcher: jaeger

3. 测试

启动 userapi 应用，用postman 访问接口。
在这里插入图片描述
这样就可以在 jaeger 的 ui 上看到访问的接口。

分布式事务

分布式事务也是微服务架构中必不可少的一部分。go-zero 使用了dtm的方案来解决分布式事务问题。

1. 引入 DTM

官网链接

1. github clone 项目

项目地址：https://github.com/dtm-labs/dtm.git

2. 进入项目

创建 conf.yml 配置文件，加入如下配置：

MicroService: # gRPC/HTTP based microservice configDriver: 'dtm-driver-gozero' # name of the driver to handle register/discoverTarget: 'etcd://localhost:2379/dtmservice' # register dtm server to this urlEndPoint: 'localhost:36790'

3. 启动dtm

从源码处启动 dtm

go run main.go -c conf.yml

在这里插入图片描述

2. 创建表

在当前使用的微服务对应的数据中创建表。我们曾在 go-zero实战（2）中创建过zero-mall数据库。同样在该数据库创建 barrier表。

create table if not exists barrier(id bigint(22) primary key auto_increment,trans_type varchar(45),gid varchar(128),branch_id varchar(128),op varchar(45),barrier_id varchar(45),reason varchar(45),create_time datetime default now(),update_time datetime default now(),key(create_time),key(update_time),unique key(gid, branch_id, op, barrier_id)
);

3. 创建积分服务

1. 在 zero_mall 数据库中 创建 user_score 表

create table user_score(id bigint(0) not null auto_increment,user_id bigint(0) not null,score int(0) not null,primary key(id) using btree
);

2. 创建 user_score.proto 文件

syntax = "proto3";package userscore;option go_package = "./score";message UserScoreRequest {int64 userId = 1;int32 score = 2;
}message UserScoreResponse {int64 userId = 1;int32 score = 2;
}service UserScore {rpc saveScore(UserScoreRequest) returns(UserScoreResponse);rpc saveScoreCallback(UserScoreRequest) returns(UserScoreResponse);
}

为了使用 dmt 实现的分布式事务，saveScore 方法，需要有一个相应的 Callback 方法。为了在发生异常回滚时，执行该方法。

3. 生成代码

goctl rpc protoc user_score.proto --go_out=./types --go-grpc_out=./types --zrpc_out=.

4. 整理代码

  1. 将 生成的 user_score.pb.go 文件和 user_score_grpc.pb.go 文件放入 rpc-common 工程的score目录下。
  2. 将 userscore.go 文件放入 rpc-common 工程的 userscore 目录下。
  3. 在user-score 创建 go.mod 文件，如下：
    module user-scorego 1.22.2
  4. 在 mall 工程下，执行如下命令：
    go work use user-score  # 加入 workspace
go mod tidy             # 下载依赖
  5. 在 user-score 创建 database 目录，并增加 sqlx.go 文件，参考 go-zero 实战（3）
  6. 将user 微服务 user/internal 目录下的 dao、repo、model三个目录复制一份到 user-score 微服务的 user-score/internal 目录下并做相应的命名修改。
  7. 修改 user-score/etc/userscore.yaml 文件
    Name: score.rpc
ListenOn: 127.0.0.1:8081
Etcd:Hosts:- 127.0.0.1:2379Key: score.rpc
Mysql:Datasource: root:thinker@tcp(127.0.0.1:3306)/zero_mall?charset=utf8mb4&parseTime=True&loc=Asia%2FShanghaiCacheRedis:- Host: 127.0.0.1:6379Pass: thinkerType: node
  8. 修改 user-score/internal/svc/servicecontext.go 文件，加入 UserScoreRepo
  9. 修改生成的 savescorelogic.go 和 savescorecallbacklogic.go 文件

到此，积分服务创建完成。

4. 在 userapi 中调用积分服务

1. 修改 userapi/etc/userapi-api.yaml 文件

加入 user-score 微服务的 rpc 配置

UserScoreRpc:Etcd:Hosts:- 127.0.0.1:2379Key: score.rpc

2. 修改 userapi/intrenal/config/config.go 文件

在这里加入 user-score 微服务的 rpc。
在这里插入图片描述

3. 在 userapi/internal/svc/servicecontext.go 文件为上一步增加的变量赋值

在这里插入图片描述

因为userapi 是作为 rpc 客户端，而 user-score 微服务是 rpc 服务端。并且这两个服务都会用到公共的部分，于是，将公共部分抽取到 rpc-common 下。这样，userapi 微服务不会用到 user-score 微服务下的代码。

4. 修改 userapi/internal/logic/userapilogic.go 文件

我们修改了 Register 接口，增加调用 user-score 微服务的代码。

到此，算是正常走通了。在 userapi 微服务下，注册功能实现时，同时调用了 user服务和 user-score 服务。

5. 测试

在这里插入图片描述

代码，这部分代码提交到了 score 分支。

6. 使用 DTM

在上面的注册功能里，从userapi 远程调用了 user 和 user-score 两个服务。试想，如果有一个微服务调用错误，显然不会影响到另一个。我们引入分布式事务，就为了解决在注册成功后，用户能够增加积分。如果积分增加失败的情况下，也要保证注册不成功。

1. 在项目中导入 dtm

分别在 /mall/userapi、/mall/user、/mall/user-score 下执行命令：

go get github.com/dtm-labs/dtm

2. 项目中加入dtm 驱动

  1. 修改 userapi/internal/logic/userapilogic.go 文件
    加入驱动

    	_ "github.com/dtm-labs/dtmdriver-gozero"// 这里的地址在文章 分布式事务 1.2 这个步骤，修改配置文件时候，指定的地址// 先上看 1.2 步骤可以找到var dtmServer = "etcd://localhost:2379/dtmservice"

3. 修改 userapi/internal/userapilogic.go 文件

修改 Register 方法的逻辑，引入 dtm

func (l *UserLogic) Register(req *types.Request) (resp *types.Response, err error) {gid := dtmgrpc.MustGenGid(dtmServer)sagaGrpc := dtmgrpc.NewSagaGrpc(dtmServer, gid)userServer, err := l.svcCtx.Config.UserRpc.BuildTarget()if err != nil {return nil, err}userScoreServer, err := l.svcCtx.Config.UserScoreRpc.BuildTarget()if err != nil {return nil, err}userReq := &user.UserRequest{Id:     req.Id,Name:   req.Name,Gender: req.Gender,}// call save methodsagaGrpc.Add(userServer+"/user.User/save", userServer+"/user.User/saveCallback", userReq)// 这个地方，应该是传入一个User，因为远程调用拿不到返回值。暂且先写死，为了测试效果。userScoreReq := &score.UserScoreRequest{UserId: req.Id,Score:  10,}sagaGrpc.Add(userScoreServer+"/userscore.UserScore/saveScore", userScoreServer+"/userscore.UserScore/saveScoreCallback", userScoreReq)sagaGrpc.WaitResult = trueerr = sagaGrpc.Submit()if err != nil {fmt.Println("---------------------------")fmt.Println(err)return nil, err}//fmt.Sprintf("register add score %d \n", userScore.Score)return &types.Response{Message: "success",Data:    "",}, nil
}

核心代码，就是将原来直接的rpc 调用，委托给 dtm 调用。

4. 修改服务端

  1. 修改 user-score/internal/logic/savescorelogic.go 文件
    引入 dtm
  2. 修改 user/internal/logic/userlogic.go 文件

5. 测试

在这里插入图片描述

指定id，插入用于，测试成功。

6. 测试事务

现在模拟 user-score 服务的逻辑出现了问题。检查事务是否生效。

在这里插入图片描述
我们用 postman测试后，发现， user 表中插入了新的数据，但是积分表中是没有新数据的。那是否事务没有生效呢？
在这里插入图片描述
当从后台打印的日志可以看出，saveCallback 方法被调用。

这里需要明白一点。

userapi/internal/logic/userapilogic.go 代码逻辑如下：

在这里插入图片描述
代码提交到了 dtm 分支。代码

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/14623.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【代码随想录 二叉树】二叉树前序、中序、后序遍历的迭代遍历

【代码随想录 二叉树】二叉树前序、中序、后序遍历的迭代遍历

文章目录 1. 二叉树前序遍历（迭代法）2. 二叉树后序遍历（迭代法）3. 二叉树中序遍历（迭代法） 1. 二叉树前序遍历（迭代法） 题目连接 🍎因为处理顺序和访问顺序是一致的。所…
阅读更多...
前端工程化-babel、corejs、postcss

前端工程化-babel、corejs、postcss

出处：前端工程化-babel、corejs、postcss | 刘维_个人博客_编程秘籍_开发技巧_入门到精通_生活感悟 (ldlw.site) 一. babel和corejs的作用到底是什么 脑子里面的想法 es6 -> es5 es6里面其实有两种东西 语法 新特性 转的语法 const a 1 const b &#xf…
阅读更多...
Shader GLSL 3D旋转函数

Shader GLSL 3D旋转函数

mat4 rotationMatrix(vec3 axis, float angle) {axis = normalize(axis);float s = sin(angle);float c = cos(angle)
阅读更多...
类和对象的基本概念

类和对象的基本概念

类和对象的基本概念 C和C中struct区别类的封装封装访问权限总结struct和class的区别 将成员变量设置为private C和C中struct区别 C语言struct只有变量C语言struct 既有变量，也有函数 类的封装 封装 把变量（属性）和函数（操作&a…
阅读更多...
交换机部分综合实验

交换机部分综合实验

实验要求 1.内网IP地址使用172.16.0.0/16 2.sw1和sW2之间互为备份; 3.VRRP/mstp/vlan/eth-trunk均使用; 4.所有pc均通过DHcP获取Ip地址; 5.ISP只配置IP地址; 6.所有电脑可以正常访问IsP路由器环回 实验拓扑 实验思路 1.给交换机创建vlan，并将接口划入vlan 2.在SW1和…
阅读更多...
Unity Render Streaming 云渲染 外网访问

Unity Render Streaming 云渲染 外网访问

初版： 日期：2024.5.20 前言：临时思路整理，后期会详细补充 环境： 1. 阿里云服务器 需要安装好nodejs 、npm 2. windows电脑，需安装好 nodejs 、npm 3.Unity 2021.3.15f1 4.Unity Render Streaming …
阅读更多...
31.GDB介绍及简单使用

31.GDB介绍及简单使用

文章目录 基本用法查看汇编代码Text User Interface(TUI)refernece 欢迎访问个人网络日志🌹🌹知行空间🌹🌹 GDB 是 GNU Debugger的缩写，是GNU软件系统中的标准调试器， 很多类UNIX系统都可以使用GDB&#xf…
阅读更多...
【论文解读】Overview of the Scalable Video Coding Extension of the H.264/AVC Standard

【论文解读】Overview of the Scalable Video Coding Extension of the H.264/AVC Standard

介绍 该篇论文是一篇关于H.264/AVC标准可扩展视频编码（SVC）扩展的综述论文，由Heiko Schwarz、Detlev Marpe和Thomas Wiegand撰写，发表在《IEEE Transactions on Circuits and Systems for Video Technology》2007年9月第17卷第9期上。 论文解读 摘要： H.264/AVC视频编…
阅读更多...
乡村振兴的农业供给侧结构性改革：优化农业产业结构，提升农产品质量，满足市场需求，实现美丽乡村产业振兴

乡村振兴的农业供给侧结构性改革：优化农业产业结构，提升农产品质量，满足市场需求，实现美丽乡村产业振兴

一、引言 乡村振兴战略是我国当前及未来一段时间内的重大战略部署，旨在推动农业农村现代化，实现城乡融合发展。在乡村振兴战略中，农业供给侧结构性改革是核心任务之一。通过优化农业产业结构、提升农产品质量、满足市场需求，不仅…
阅读更多...
韩国云主机远程故障怎么排查?

韩国云主机远程故障怎么排查?

韩国云主机远程故障可能是由于多种原因引起的，包括网络问题、服务器故障、安全设置、客户端问题等。下面是针对韩国云主机远程故障的排查步骤和解决方法： 检查网络连接 1.使用 ping 命令 在本地计算机上使用 ping 命令检查与云主机之间的网络连接。如果无…
阅读更多...
AI巨头争相与Reddit合作：为何一个古老的论坛成为AI训练的“宝藏”？

AI巨头争相与Reddit合作：为何一个古老的论坛成为AI训练的“宝藏”？

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗？订阅我们的简报，深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同，从行业内部的深度分析和实用指南中受益。不要错过这个机会，成为AI领…
阅读更多...
debian nginx upsync consul 实现动态负载

debian nginx upsync consul 实现动态负载

1. consul 安装 wget -O- https://apt.releases.hashicorp.com/gpg | sudo gpg --dearmor -o /usr/share/keyrings/hashicorp-archive-keyring.gpg echo "deb [signed-by/usr/share/keyrings/hashicorp-archive-keyring.gpg] https://apt.releases.hashicorp.com $(lsb_r…
阅读更多...
MariaDB 给指定列值自动加密（持久数据加触发器）

MariaDB 给指定列值自动加密（持久数据加触发器）

文章目录 代码插入时，自动加密更新时，自动加密查看触发器数据操作示例update数据取出解密取 注意一次尝试，看加密后数据长度 参考链接： 一篇非常好的讲解触发器的文章：示例、原理MySQL/MariaDB触发器。 用触发器自动加…
阅读更多...
前端工程化07-常见的包管理工具npm、yarn、cnpm、npx、pnpm

前端工程化07-常见的包管理工具npm、yarn、cnpm、npx、pnpm

8、包管理工具 8.1、包管理工具概述 npm包管理工具、在安装node的时候这个东西就已经安装过了，通过npm去管理包的时候这个时候回有一个配置文件叫做package.json,他是以json的方式来书写对应的一个配置文件，这个配置文件是可以添加特别多的一些字段的&…
阅读更多...
input输入多行文本，保存为.dot文件和对应的.txt文件

input输入多行文本，保存为.dot文件和对应的.txt文件

需求 不管是上面的dot还是这个dot 变成 input输入文本按“# ꧂ ꧁”结束保存在dot文本文件夹下，用txt保存每个文件文件名： 编号. 第二行有字文字 时间戳 代码 首先，我会创建一个Python脚本，它将接受用户的输入，直到…
阅读更多...
案例题（第二版）

案例题（第二版）

案例题目 信息系统架构设计 基本概念 信息系统架构（ISA）是对某一特定内容里的信息进行统筹、规划、设计、安排等一系列的有机处理的活动。特点如下 架构是对系统的抽象，它通过描述元素、元素的外部可见属性及元素之间的关系来反映这种抽象…
阅读更多...
css属性之间总是有换行

css属性之间总是有换行

问题 在create-next-app创建项目的时候,只要我没有选择eslint的时候，就不会在保存的时候每个属性之间有换行，但是创建项目的时候选择eslint，保存的时候就会在每条属性间有换行 回答 当你使用 create-next-app 创建项目并选择使用 ESLint 时…
阅读更多...
k8s 1.28.10 浏览器访问6443查看api，需要证书

k8s 1.28.10 浏览器访问6443查看api，需要证书

添加证书 使用client-certificate-data和client-key-data生成一个p12文件 1.生成client-certificate-data grep client-certificate-data ~/.kube/config | head -n 1 | awk {print $2} | base64 -d >> kubecfg.crt2.生成client-key-data grep client-key-data ~/.kub…
阅读更多...
万象生图，一个windows文生图的软件

万象生图，一个windows文生图的软件

网址 https://support.qq.com/products/637894/?id155553 支持文生图，支持提示词本地翻译，支持提示词权重语法，支持样例和风格 支持图处理，包括去除背景和图像放大 支持各种快速生图模型，如LCM、TCD、Lightning、…
阅读更多...
为什么self-attention要除以一个根号dk

为什么self-attention要除以一个根号dk

简单说法是为了让方差到1，推公式也好推。但是没几个人说为什么方差要到1. 如果不除以根号dk，显然QK有可能很大，这就让softmax更有能力得到接近one-hot的结果。这本应是好的，但是从实践来看，我们并不要求一定要输出one-…
阅读更多...
最新文章

Copyright @ 2022~2023