Concurrent Logging - in Golang

개요

 

go routine 을 이용해서 프로그램의 여기저기서 하나의 파일에 write 한다면 어떻게 될까?

go routine 은 충돌을 하지 않을거란 보증은 하지 않는다.

 

참고 링크

- Golang Package os: https://golang.org/pkg/os

- Golang Package log: https://golang.org/pkg/log

- log for concurrency: https://codereview.stackexchange.com/a/209872

 

해법

 

하나의 리소스에 동시에 여럿이 접근하려 할때 충돌을 막는 방법을 생각하면 바로 mutex 가 떠오를 것이다.

 

1) A가 접근하면서 mutex lock 을 걸어놓는다. 그러면 다른 녀석이 접근 권한을 가지지 못한다.

2) A가 사용 완료후 mutex unlock 으로 해제하면 다른 녀석이 접근할 수 있다.

 

여기서는 여러 go routine 에서 하나의 log 파일에 write 를 하려하는데 mutex 와 같은 동시접근을 막아주는 녀석이 필요해진다.

이 경우엔 그냥 golang 의 log package 를 쓰면 된다.

 

해법 - 예제 프로그램

 

예제 프로그램 부터 돌려보자.

GitHub Gist: https://gist.github.com/nicewook/8ab51cc920b242f3fed6d560dd790afa

1) os.OpenFile() 로 파일을 엽니다. - os.O_CREATE: 없다면 생성됨 - os.O_APPEND: 있다면 기존 내용에 이어져서 써짐 - os.O+WRONLY: 쓰기만 가능합니다.   2) log.New() 함수로 type Logger 를 생성하고 포인터를 fileLogger 에 저장   3) wait.Add() 을 해두면 - wait.Done() 이 개수만큼 호출될때까지 - wait.Wait() 에서 기다림   4) for loop 를 통해 100개의 go routine 을 만들어 실행 - 현재 시간을 string 으로 변환하여 - 현재 go routine 의 번호와 함께 log 를 출력하고 - 파일에 저장한다.   프로그램을 go run main.go 로 돌려보면 concurrent_log.log 파일이 생성되며 log가 찍힌 것을 확인할 수 있다. → 그런데 그냥 File.WriteSting() 을 사용해도 문제는 없었다. → 하지만 문제가 생길 가능성이 있는 것이다.

 

참고. log. New() 의 파라미터들

 

func New(out io.Writer, prefix string, flag int) *Logger

 

코드에서는 log.New(f, "", 0) 을 주었다.

- f 는 io.Writer 로 Open 한 file 을 전달한 것

- prefix 는 따로 적을 것이 없으므로 "", 만약 log 라면 time.Now()로 현재 시간을 얻은 후 넣어줘도 될 것 같다.

- flag 는 아래 항목들을 | (OR 연산자)로 묶어 지정할 수 있다. 여기서는 아무것도 주지 않았음

표준플래그(log.LstdFlags) 날짜플래그(log.Ldate) 시간플래그(log.Ltime) 파일위치플래그(log.Lshortfile, log.Llongfile)

 

참고. Logger.Output 의 mutex

 

- 링크: https://golang.org/src/log/log.go?s=5252:5306#L139

 

 

runtime.Caller(calldepth) 는 뭘까?

 

링크: https://ispycode.com/GO/Logging/Output-with-Calldepth

GitHub Gist: https://gist.github.com/nicewook/2e9209b0d59a0bc00970179e636d590d

 

Call stack 관련이라 보면 되겠다. 호출한 함수1이 호출하는 함수2가 호출하는 함수3에서 log.Output() 을 호출했다면

아래 링크와 같이 호출한 파일의 함수 위치가 출력된다.

* log.New() 시에 log.Llogfile 플래그를 넣었다.