我的编程空间,编程开发者的网络收藏夹
学习永远不晚

GoLang实现日志收集器流程讲解

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

GoLang实现日志收集器流程讲解

Go自己动手实现日志收集

看日志是开发者平时排查BUG所必须的掌握的技能,但是日志是如何来的呢?通过平时开发者自己打日志,经过日志包进行处理,打印日志到控制台还是记录日志到文件中!

下面咱就来学一下日志是如何记录下来的

1. 日志器的接口

​ 以下日志器定义了各类日志器的行为,通过RegisterWriter注册实现了日志器的子类日志器,然后通过Log方法来进行循环调用注册进来的日志收集器的write写日志方法。

// 声明日志写入器接口
type LogWriter interface {
	Write(data interface{}) error
}
// 日志器
type Logger struct {
	// 这个日志器用到的日志写入器
	writerList []LogWriter
}
// 注册一个日志写入器
func (l *Logger) RegisterWriter(writer LogWriter) {
	l.writerList = append(l.writerList, writer)
}
// 将一个data类型的数据写入日志
func (l *Logger) Log(data interface{}) {
	// 遍历所有注册的写入器
	for _, writer := range l.writerList {
		// 将日志输出到每一个写入器中
		writer.Write(data)
	}
}
// 创建日志器的实例
func NewLogger() *Logger {
	return &Logger{}
}

2. 命令写入日志器

​ 这个日志器实现了日志器的接口行为write,可以进行日志的写入,其写入手法是通过Os包来写入到命令行(控制台)中!

// 命令行写入器
type consoleWriter struct {
}
// 实现LogWriter的Write()方法
func (f *consoleWriter) Write(data interface{}) error {
	// 将数据序列化为字符串
	str := fmt.Sprintf("%v\n", data)
	// 将数据以字节数组写入命令行中
	_, err := os.Stdout.Write([]byte(str))
	return err
}
// 创建命令行写入器实例
func NewConsoleWriter() *consoleWriter {
	return &consoleWriter{}
}

3. 文件写入日志器

这也是实现了日志器的一个实现类,文件日志器,一种常见的将日志写入文件记录的日志收集器。使用前需要先SetFile设置好日志文件名,最后将日志作为字节写入到文件中。

// 声明文件写入器
type fileWriter struct {
	file *os.File
}
// 设置文件写入器写入的文件名
func (f *fileWriter) SetFile(filename string) (err error) {
	// 如果文件已经打开, 关闭前一个文件
	if f.file != nil {
		f.file.Close()
	}
	// 创建一个文件并保存文件句柄
	f.file, err = os.Create(filename)
	// 如果创建的过程出现错误, 则返回错误
	return err
}
// 实现LogWriter的Write()方法
func (f *fileWriter) Write(data interface{}) error {
	// 日志文件可能没有创建成功
	if f.file == nil {
		// 日志文件没有准备好
		return errors.New("file not created")
	}
	// 将数据序列化为字符串
	str := fmt.Sprintf("%v\n", data)
	// 将数据以字节数组写入文件中
	_, err := f.file.Write([]byte(str))
	return err
}
// 创建文件写入器实例
func NewFileWriter() *fileWriter {
	return &fileWriter{}
}

4. Demo演示

通过New的方式创建日志器,进行注册到日志器集合中,下面演示了两种日志器如何使用!!!

// 创建日志器
func createLogger() *Logger {
	// 创建日志器
	l := NewLogger()
	// 创建命令行写入器
	cw := cmdwriter.NewConsoleWriter()
	// 注册命令行写入器到日志器中,cw实现了LogWriter接口,故可作为RegisterWriter函数的参数,类型为Logwriter
	l.RegisterWriter(cw)
	// 创建文件写入器
	fw := filerwriter.NewFileWriter()
	// 设置文件名
	if err := fw.SetFile("log.log"); err != nil {
		fmt.Println(err)
	}
	// 注册文件写入器到日志器中,fw实现了LogWriter接口
	l.RegisterWriter(fw)
	return l
}
func main() {
	// 准备日志器
	l := createLogger()
	// 写一个日志
	l.Log("hello")
}

5. 总结和提高

一个好的日志器功能是可扩展的,上述例子仅只是可以扩展不同种类的日志收集器。

在官方的logger中是可以进行选择写入级别的,可以定义一个枚举,在对应的枚举写入级别下,进行对应的权限写入,可以改造write方法,而不只是简单的写入就完事了。

到此这篇关于GoLang实现日志收集器流程讲解的文章就介绍到这了,更多相关Go日志收集内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

GoLang实现日志收集器流程讲解

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

GoLang实现日志收集器流程讲解

这篇文章主要介绍了GoLang实现日志收集器流程,看日志是开发者平时排查BUG所必须的掌握的技能,但是日志冗杂,所以写个小工具来收集这些日志帮助我们排查BUG,感兴趣想要详细了解可以参考下文
2023-05-20

Golang与RabbitMQ实现分布式日志收集与分析系统

要使用Golang和RabbitMQ来实现分布式日志收集与分析系统,可以按照以下步骤进行:1. 安装RabbitMQ:首先需要在系统中安装RabbitMQ。可以根据官方文档下载和安装RabbitMQ服务器。2. 创建消息队列:使用Golan
2023-10-08

Golang分布式注册中心实现流程讲解

这篇文章主要介绍了Golang分布式注册中心实现流程,注册中心可以用于服务发现,服务注册,配置管理等方面,在分布式系统中,服务的发现和注册是非常重要的组成部分,需要的朋友可以参考下
2023-05-19

Golang与RabbitMQ实现分布式日志收集和分析的细节和技巧

在Golang中使用RabbitMQ实现分布式日志收集和分析的细节和技巧如下:1. 安装RabbitMQ:首先,需要安装和配置RabbitMQ服务器。可以从RabbitMQ官方网站下载并安装RabbitMQ。安装完成后,可以使用默认的gue
2023-10-08

Golang与RabbitMQ实现分布式日志收集和分析的细节、技巧和最佳实践

要使用Golang和RabbitMQ实现分布式日志收集和分析,以下是一些细节、技巧和最佳实践:1. 安装和配置RabbitMQ:首先,确保已经安装并正确配置了RabbitMQ消息代理。您可以从RabbitMQ官方网站下载并安装RabbitM
2023-10-20

Vue渲染器设计实现流程详细讲解

在浏览器平台上,用它来渲染其中的真实DOM元素。渲染器不仅能够渲染真实的DOM元素,它还是框架跨平台能力的关键。所以在设计渲染器的时候一定要考虑好自定义的能力
2023-01-03

记一次利用GrayLog实现采集与备份云服务器Web访问日志的实现过程

AWS云服务器通过rsyslog服务采集本地的nginx日志,并发送上一步中到映射到公网的Syslog UDP端口上,也就是发送GrayLog。

JavagRPC拦截器简单实现分布式日志链路追踪器过程详解

有请求的发送、处理,当然就会有拦截器的需求,例如在服务端通过拦截器统一进行请求认证等操作,这些就需要拦截器来完成,今天松哥先和小伙伴们来聊一聊gRPC中拦截器的基本用法,后面我再整一篇文章和小伙伴们做一个基于拦截器实现的JWT认证的gRPC
2023-03-01

Java微服务Filter过滤器集成Sentinel实现网关限流过程详解

这篇文章主要介绍了Java微服务Filter过滤器集成Sentinel实现网关限流过程,首先Sentinel规则的存储默认是存储在内存的,应用重启之后规则会丢失。因此我们通过配置中心Nacos保存规则,然后通过定时拉取Nacos数据来获取规则配置,可以做到动态实时的刷新规则
2023-02-10

编程热搜

  • Python 学习之路 - Python
    一、安装Python34Windows在Python官网(https://www.python.org/downloads/)下载安装包并安装。Python的默认安装路径是:C:\Python34配置环境变量:【右键计算机】--》【属性】-
    Python 学习之路 - Python
  • chatgpt的中文全称是什么
    chatgpt的中文全称是生成型预训练变换模型。ChatGPT是什么ChatGPT是美国人工智能研究实验室OpenAI开发的一种全新聊天机器人模型,它能够通过学习和理解人类的语言来进行对话,还能根据聊天的上下文进行互动,并协助人类完成一系列
    chatgpt的中文全称是什么
  • C/C++中extern函数使用详解
  • C/C++可变参数的使用
    可变参数的使用方法远远不止以下几种,不过在C,C++中使用可变参数时要小心,在使用printf()等函数时传入的参数个数一定不能比前面的格式化字符串中的’%’符号个数少,否则会产生访问越界,运气不好的话还会导致程序崩溃
    C/C++可变参数的使用
  • css样式文件该放在哪里
  • php中数组下标必须是连续的吗
  • Python 3 教程
    Python 3 教程 Python 的 3.0 版本,常被称为 Python 3000,或简称 Py3k。相对于 Python 的早期版本,这是一个较大的升级。为了不带入过多的累赘,Python 3.0 在设计的时候没有考虑向下兼容。 Python
    Python 3 教程
  • Python pip包管理
    一、前言    在Python中, 安装第三方模块是通过 setuptools 这个工具完成的。 Python有两个封装了 setuptools的包管理工具: easy_install  和  pip , 目前官方推荐使用 pip。    
    Python pip包管理
  • ubuntu如何重新编译内核
  • 改善Java代码之慎用java动态编译

目录