番茄日志发布1.0.3版本-增加Kafka支持

日期：2021-06-09 栏目：程序人生浏览：次

番茄日志（TomatoLog）能做什么

可能你是第一次听说TomatoLog，没关系，我可以从头告诉你，通过了解番茄日志，希望能帮助有需要的朋友，番茄日志处理将大大降低你采集、分析、处理日志的过程。

介绍

番茄日志发布1.0.3版本-增加Kafka支持

TomatoLog 是一个基于 .NETCore 平台的日志处理组件,包含客户端、服务端，非常容易使用和部署。

多客户端实现

TomatoLog 的客户端和服务端目前都是基于 .NETCore 版本,客户端提供了三种日志流传输方式，目前实现了 Redis/RabbitMQ/Kafka流。如果希望使用非 .NETCore 平台的客户端，你可以自己开放其它第三方语言的客户端，通过实现 TomatoLog 传输协议，将数据传送到管道(Redis/RabbitMQ/Kafka)中即可。

强大的日志存储方式

TomatoLog 服务端还提供了三种存储日志的方式，分别是 File、MongoDB、Elasticsearch，存储方式可以通过配置文件指定。在 TomatoLog 服务端，我们还提供了一个Web 控制台，通过该控制台，可以对日志进行查询、搜索，对服务过滤器进行配置，警报配置、通知发送等等

灵活多样的日志报警配置

其中，可使用的警报通知方式有：SMS 和 Email 两种方式，但是，SMS 其本质是一个 Http 请求，通过 SMS 的配置，可以实现向所有提供了 Http 接口的网关发送通知。

我好累丫

为了开发支持Kafka，还得学习Kafka/Zookeeper，为了使用Kafka-Manager控制台，还学习Scala/sbt编译雅虎这个破项目，控制台我就起了四个，不说了，看图。

番茄日志发布1.0.3版本-增加Kafka支持

TomatoLog-1.0.3 版本

TomatoLogServer 服务器版本 1.0.3 ，主要增加了对Kafka的支持，服务端做了一些优化，在配置上，几乎没有改动，只需要在原来的基础上增加Kafka配置即可

"Kafka": { "Group": "TomatoLogServer", "BootstrapServers": "127.0.0.1:9092", "Topic": "TomatoLog" }

同时也增加了Kafka客户端的支持，当前版本为：1.0.3

Install-Package TomatoLog.Client.Kafka

使用方式和其它Redis/RabbitMQ客户端是没有任何区别的，主要看下面的 WriteLogAsync() 方法，只要做好了 TomatoLogClientKafka 的配置，剩下的，就是调用 Exception 的扩展方法 ex.AddTomatoLogAsync()

public class TomatoLogClientKafkaTest { [Fact] public async Task WriteLogAsync() { int i = 0; for (; i < 10; i++) { try { throw new Exception("Kafka throw exception"); } catch (Exception ex) { ex.Data["connection"] = "127.0.0.1"; await ex.AddTomatoLogAsync(1320); } } Assert.Equal(10, i); } ITomatoLogClient client; public TomatoLogClientKafkaTest() { var options = new EventKafkaOptions { Logger = null, LogLevel = Microsoft.Extensions.Logging.LogLevel.Information, ProjectLabel = "20272", ProjectName = "TomatoLog", SysOptions = new EventSysOptions { EventId = true, IP = true, IPList = true, MachineName = true, ProcessId = true, ProcessName = true, ThreadId = true, Timestamp = true, UserName = true }, Tags = null, Version = "1.0.1", BootstrapServers = "127.0.0.1:9092", Topic = "TomatoLog" }; client = new TomatoLogClientKafka(options); } } 番茄日志服务端控制台长什么样首页看日志列表

番茄日志发布1.0.3版本-增加Kafka支持