go语言并发实战——日志收集系统(八) go语言操作etcd以及利用watch实现对键值的监控

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: go语言并发实战——日志收集系统(八) go语言操作etcd以及利用watch实现对键值的监控

有关包的安装

我们要实现go语言对第三方包的操作需要我们下载第三方包go.etcd.io,下载命令:

go get go.etcd.io/etcd/client/v3 

ectd的put与get操作

相关函数说明与示例

我们想实现对etcd进行简单的操作的步骤还是比较简单的,在我上一篇文章中,我们基于命令行实现了客户端对服务端的的put/get操作,步骤主要是以下两步:

而现在我们想实现go语言操作etcd完成get/put操作其实主要也是和商户步骤基本一致:

  • 初始化客户端连接服务端:
cli, err := clientv3.New(clientv3.Config{
    Endpoints:   []string{"127.0.0.1:2379"}, //服务端通信端口
    DialTimeout: 5 * time.Second,            //连接超时时间
  })
  if err != nil {
    fmt.Println("init client failed,err:%v", err)
    return
  }
  fmt.Println("init client success!")
  defer cli.Close()
  • 执行相关操作
    Get函数与Put函数的函数签名为:
Put(ctx context.Context, key, val string, opts ...OpOption) (*PutResponse, error)
Get(ctx context.Context, key string, opts ...OpOption) (*GetResponse, error)

我们可以发现它们的参数中存在Context上下文,如果不清楚的话可以参考博主之前的博文:

go语言并发编程(五) ——Context

所以我们可以这样实现get/put操作:

  • put操作:
//put
  ctx, cancel := context.WithTimeout(context.Background(), time.Second)
  _, err = cli.Put(ctx, "me", "fengxu")
  cancel()
  if err != nil {
    fmt.Println("put failed,err:%v", err)
    return
  }
  • get操作:
//get
  ctx, cancel = context.WithTimeout(context.Background(), time.Second)
  res, err := cli.Get(ctx, "me")
  cancel()
  if err != nil {
    fmt.Println("get failed,err:%v", err)
    return
  }
  for _, ev := range res.Kvs {
    fmt.Printf("%s:%s\n", ev.Key, ev.Value)
  }

完整代码以及结果示例

  • 完整代码:
package main
import (
  "context"
  "fmt"
  clientv3 "go.etcd.io/etcd/client/v3"
  "time"
)
func main() {
  cli, err := clientv3.New(clientv3.Config{
    Endpoints:   []string{"127.0.0.1:2379"}, //服务端通信端口
    DialTimeout: 5 * time.Second,            //连接超时时间
  })
  if err != nil {
    fmt.Println("init client failed,err:%v", err)
    return
  }
  fmt.Println("init client success!")
  defer cli.Close()
  //put
  ctx, cancel := context.WithTimeout(context.Background(), time.Second)
  _, err = cli.Put(ctx, "me", "fengxu")
  cancel()
  if err != nil {
    fmt.Println("put failed,err:%v", err)
    return
  }
  //get
  ctx, cancel = context.WithTimeout(context.Background(), time.Second)
  res, err := cli.Get(ctx, "me")
  cancel()
  if err != nil {
    fmt.Println("get failed,err:%v", err)
    return
  }
  for _, ev := range res.Kvs {
    fmt.Printf("%s:%s\n", ev.Key, ev.Value)
  }
}

我们打开服务端,运行代码结果为:

etcd的watch操作

watch操作的作用

在etcd中,watch操作可以让我们实时完成对键值操作的实时监控。

watch操作函数的实现

rch := cli.Watch(context.Background(), "me")
  for wresp := range rch {
    for _, ev := range wresp.Events {
      fmt.Printf("Type:%s Key:%s Value:%s\n", ev.Type, ev.Kv.Key, ev.Kv.Value)
    }
  }

完整代码及示例

代码:

package main
import (
  "context"
  "fmt"
  clientv3 "go.etcd.io/etcd/client/v3"
  "time"
)
func main() {
  cli, err := clientv3.New(clientv3.Config{
    Endpoints:   []string{"127.0.0.1:2379"}, //服务端通信端口
    DialTimeout: 5 * time.Second,            //连接超时时间
  })
  if err != nil {
    fmt.Println("init client failed,err:%v", err)
    return
  }
  fmt.Println("init client success!")
  defer cli.Close()
  rch := cli.Watch(context.Background(), "me")
  for wresp := range rch {
    for _, ev := range wresp.Events {
      fmt.Printf("Type:%s Key:%s Value:%s\n", ev.Type, ev.Kv.Key, ev.Kv.Value)
    }
  }
}

我们运行该程序,尝试在命令行打开客户端对键值对进行操作:

运行结果为:

这样我们就成功实现了watch操作了!

结语

我们有关go简单操作etcd到此为止了,后面就是介绍如何在日志收集服务中使用了,我们下篇见!

相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
相关文章
|
1月前
|
运维 Prometheus 监控
监控与日志分析:运维的双剑合璧
【6月更文挑战第21天】监控与日志分析在IT运维中至关重要。监控守护系统健康,通过性能指标、服务状态和安全事件预警确保稳定性;日志分析则用于问题追踪,通过错误、访问和安全日志定位故障。监控工具如Prometheus与日志分析工具如ELK堆栈协同工作,统一平台、合理告警、定期分析和团队协作是高效运维的关键。这两者的结合助力运维人员迅速响应和解决问题,维护系统稳定。
|
17天前
|
Python
Python编程实战:利用闭包与装饰器优化日志记录功能
【7月更文挑战第7天】Python的闭包和装饰器简化了日志记录。通过定义如`log_decorator`的装饰器,可以在不修改原函数代码的情况下添加日志功能。当@log_decorator用于`add(x, y)`函数时,调用时自动记录日志。进一步,`timestamp_log_decorator`展示了如何创建特定功能的装饰器,如添加时间戳。这些技术减少了代码冗余,提高了代码的可维护性。
19 1
|
19天前
|
Prometheus 监控 Cloud Native
Java中的日志管理与监控技术选型
Java中的日志管理与监控技术选型
|
24天前
|
存储 Prometheus 监控
Java后端服务的监控与日志管理
Java后端服务的监控与日志管理
|
1月前
|
监控 Go
go语言并发实战——日志收集系统(十一)基于etcd来监视配置文件的变化
go语言并发实战——日志收集系统(十一)基于etcd来监视配置文件的变化
|
1月前
|
监控 Go
go语言并发实战——日志收集系统(十) 重构tailfile模块实现同时监控多个日志文件
go语言并发实战——日志收集系统(十) 重构tailfile模块实现同时监控多个日志文件
|
27天前
|
存储 关系型数据库 MySQL
|
12天前
|
监控
查看服务器/IIS日志、log、访问信息基本方法
除了手动查看,你也可以使用日志分析工具,如Log Parser、AWStats等,这些工具可以帮助你更方便地分析日志数据。
8 1
|
20天前
|
Java 测试技术 Apache
《手把手教你》系列基础篇(八十六)-java+ selenium自动化测试-框架设计基础-Log4j实现日志输出(详解教程)
【7月更文挑战第4天】Apache Log4j 是一个广泛使用的 Java 日志框架,它允许开发者控制日志信息的输出目的地、格式和级别。Log4j 包含三个主要组件:Loggers(记录器)负责生成日志信息,Appenders(输出源)确定日志输出的位置(如控制台、文件、数据库等),而 Layouts(布局)则控制日志信息的格式。通过配置 Log4j,可以灵活地定制日志记录行为。
33 4
|
21天前
|
运维 Java Apache
Java中的日志框架:Log4j与SLF4J详解
Java中的日志框架:Log4j与SLF4J详解