如何在golang中使用truncate日志文件

本篇文章給大家分享的是有關(guān)如何在golang中使用truncate日志文件，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

方法1：拷貝文件，然后把前半部分刪除，保留新的后半部分

$ wc -l logfile
$ tail -n {LINENUM}/2 logfile > logfile2
$ mv logfile2 logfile

缺點是需要額外的臨時磁盤空間(logfile2)，保留新拷貝的文件

方法2：把日志文件讀入內(nèi)存，截去前半部分，把后半部分重新寫會文件。

缺點也是要創(chuàng)建一個臨時文件，或者把整個文件內(nèi)容一次性讀入內(nèi)存。

下面是一個實現(xiàn)創(chuàng)建臨時文件的例子：

(如果采用整個文件讀入內(nèi)存，那么可以重復覆蓋使用原來的讀入文件，不用創(chuàng)建臨時文件)：

package main

import (
 "bufio"
 "log"
 "io"
 "os"
)

func ReadLine(r *bufio.Reader, w *bufio.Writer) error {
 for i := 0; ; i++ {
  line, err := r.ReadString('\n')
  if i >= 12554364/2 { // this number is hard-codes just for example use
   if _,err := w.WriteString(line); err != nil {
    log.Fatal(err)
   }
  }

  if err != nil {
   if err == io.EOF {
    return nil
   }
   return err
  }
 }
 return nil
}

func main() {
 fin, err := os.Open("data.in")
 if err != nil {
  log.Fatal(err)
 }
 defer fin.Close()

 fout, err := os.Create("data.dat")
 if err != nil {
  log.Fatal(err)
 }
 defer fout.Close()

 reader := bufio.NewReader(fin)
 writer := bufio.NewWriter(fout)
 if err := ReadLine(reader, writer); err != nil {
  log.Fatal(err)
 }
 writer.Flush()
}

運行：

對于1G大小的日志文件，在我的Linux上執(zhí)行時間大約是：

$ go build && time ./main
real 0m6.972s
user 0m4.668s
sys  0m2.055s

方法3：也是利用文件，把文件mmap映射到內(nèi)存，然后使用copy函數(shù)覆蓋內(nèi)存。

缺點是，mmap操作日志文件不能過大。

下面是一個實現(xiàn)的代碼例子：

package main

import (
 "fmt"
 "log"
 "os"
 "syscall"
)

// Truncate file to half size, with line aligned.
func truncateText(f *os.File) error {
 fi, err := f.Stat()
 if err != nil {
  return err
 }

 mem, err := syscall.Mmap(int(f.Fd()), 0, int(fi.Size()), syscall.PROT_READ|syscall.PROT_WRITE, syscall.MAP_SHARED)
 if err != nil {
  return err
 }

 size := fi.Size()
 if size <= 1 {
  // Don't need to truncate file if it's too small
  return nil
 }

 trun := size/2 - 1
 for ; trun < fi.Size(); trun ++ {
  if mem[trun] == '\n' {
   break
  }
 }

 //fmt.Printf("size=%d, trun=%d\n", size, trun)
 if trun >= size - 1 {
  trun = size/2
 } else {
  trun = trun + 1
 }

 // Overwrite file content
 copy(mem[0:], mem[trun:])
 
 err = syscall.Munmap(mem)
 if err != nil {
  return err
 }

 // truncate file
 f.Truncate(fi.Size() - trun)

 // reset file offset
 f.Seek(trun,0)

 return nil
}


func main() {
 path := "data.dat"

 f, err := os.OpenFile(path, os.O_RDWR|os.O_CREATE, 0644)
 if err != nil {
  fmt.Println("Cannot create file")
  log.Fatal(err)
 }

 err = truncateText(f)
 if err != nil {
  fmt.Println("Cannot truncateLog file")
  log.Fatal(err)
 }

 f.Write([]byte("ABCD"))
 f.Close()
}

函數(shù)truncateText的功能就是把文件截取到原來的一半大小，并保持按行對齊；分如下幾步：

• 先把文件映射syscall.Mmap 到內(nèi)存。

• 查找到中間行的位置。

• 然后用內(nèi)置函數(shù)copy，把中間行以后的挪動到文件開始位置。

• 修改文件的大小file.Truncate

• 重置文件的偏移指針offset

• 取消文件映射syscall.Munmap

運行：

對于1G大小的日志文件，在我的Linux上執(zhí)行時間大約是：

$ go build && time ./main
real 0m1.861s
user 0m0.335s
sys  0m0.650s

以上就是如何在golang中使用truncate日志文件，小編相信有部分知識點可能是我們?nèi)粘９ぷ鲿姷交蛴玫降摹ＯＭ隳芡ㄟ^這篇文章學到更多知識。更多詳情敬請關(guān)注億速云行業(yè)資訊頻道。