CentOS中Golang日志如何实现远程传输

在CentOS系统中，实现Golang日志的远程传输可以通过多种方式来完成。以下是一些常见的方法：

方法一：使用Syslog

1. 安装Syslog服务：

   sudo yum install rsyslog
   sudo systemctl start rsyslog
   sudo systemctl enable rsyslog
   

2. 配置Golang应用发送日志到Syslog： 在你的Golang应用中，可以使用log/syslog包来发送日志到Syslog。

   package main
   
   import (
       "log/syslog"
       "os"
   )
   
   func main() {
       syslog.Openlog("myapp", syslog.LOG_PID|syslog.LOG_CONS, syslog.LOG_USER)
       defer syslog.Closelog()
   
       syslog.Syslog(syslog.LOG_INFO, "This is an info message")
       syslog.Syslog(syslog.LOG_ERR, "This is an error message")
   }
   

3. 配置rsyslog接收远程日志： 编辑/etc/rsyslog.conf或/etc/rsyslog.d/50-default.conf文件，添加以下内容：

   module(load="imudp")
   input(type="imudp" port="514")
   
   if $programname == 'myapp' then @remote_server_ip:514
   & stop
   

   替换remote_server_ip为你的远程日志服务器的IP地址。

4. 重启rsyslog服务：

   sudo systemctl restart rsyslog
   

方法二：使用Logstash

1. 安装Logstash：

   sudo yum install logstash
   sudo systemctl start logstash
   sudo systemctl enable logstash
   

2. 配置Logstash接收日志： 编辑/etc/logstash/conf.d/golang.conf文件，添加以下内容：

   input {
       tcp {
           port => 5000
           codec => json_lines
       }
   }
   
   output {
       elasticsearch {
           hosts => ["localhost:9200"]
           index => "golang-logs-%{+YYYY.MM.dd}"
       }
   }
   

3. 修改Golang应用发送日志到TCP端口： 使用net包将日志发送到Logstash的TCP端口。

   package main
   
   import (
       "fmt"
       "log"
       "net"
   )
   
   func main() {
       conn, err := net.Dial("tcp", "localhost:5000")
       if err != nil {
           log.Fatal(err)
       }
       defer conn.Close()
   
       fmt.Fprintf(conn, "{\"level\":\"info\",\"message\":\"This is an info message\"}\n")
       fmt.Fprintf(conn, "{\"level\":\"error\",\"message\":\"This is an error message\"}\n")
   }
   

4. 重启Logstash服务：

   sudo systemctl restart logstash
   

方法三：使用Fluentd

1. 安装Fluentd：

   sudo yum install fluentd
   sudo systemctl start fluentd
   sudo systemctl enable fluentd
   

2. 配置Fluentd接收日志： 编辑/etc/fluent.conf文件，添加以下内容：

   <source>
       @type forward
       port 24224
       bind 0.0.0.0
   </source>
   
   <match **>
       @type elasticsearch
       host localhost
       port 9200
       logstash_format true
       flush_interval 10s
   </match>
   

3. 修改Golang应用发送日志到Fluentd： 使用fluent-logger-golang库将日志发送到Fluentd。

   package main
   
   import (
       "github.com/fluent/fluent-logger-golang/fluent"
       "log"
   )
   
   func main() {
       logger, err := fluent.New(fluent.Config{FluentHost: "localhost", FluentPort: 24224})
       if err != nil {
           log.Fatalf("failed to create fluent logger: %v", err)
       }
       defer logger.Close()
   
       if err := logger.Post("myapp.tag", map[string]string{"level": "info", "message": "This is an info message"}); err != nil {
           log.Fatalf("failed to post log: %v", err)
       }
   
       if err := logger.Post("myapp.tag", map[string]string{"level": "error", "message": "This is an error message"}); err != nil {
           log.Fatalf("failed to post log: %v", err)
       }
   }
   

4. 重启Fluentd服务：

   sudo systemctl restart fluentd
   

通过以上方法，你可以在CentOS系统中实现Golang日志的远程传输。选择哪种方法取决于你的具体需求和环境。