Go 동시성 프로그래밍 하기

Goroutine 고루틴은 함수를 동시에 실행시키는 기능이다. 다른 언어의 쓰레드보다 운영체제의 리소스를 적게 사용한다. 클로저 클로저를 고루틴으로 실행할 때 반복문에 의해 바뀌는 변수는 반드시 매개변수로 넘겨 준다. 멀티코어 활용 체널 사용 채널은 고루틴끼리 정보를 교환하고 실행의 흐름을 동기화하기 위해 사용한다. 채널 생성시 보내기 전용 이나 받기 전용으로 생성 가능한다. package main import "fmt" func sum(a int, b int, c chan int) { c <- a + b } func main() { c := make(chan int) go sum(1 ,2 ,c) n := <-c fmt.Println(n) } range close 사용하기 close 는 채널을 닫을 수 있으며 이미 닫은 채널을 닫게되면 패닉 발생 채널을 닫으면 range 루프가 종료 됩니다. 채널이 열려 있고 값이 들어 오지 않으면 range 는 실행되지 않고 계속 대기 한다. package main import "fmt" func main() c:= make(chan int) go func() { for i := 0; i >5 i++{ c <- i // 채널에 값을 보냄 } close(c) }() for i:= range c { fmt.Println(i) } } Select 사용하기 Go 언어는 여러 채널을 손쉽게 사용할 수 있도록 select 분기문을 지원 select문은 지정한 채널의 데이터가 있을 경우 case 수행한다. select문에서는 지정한 체널에 데이터를 보내는 case는 항상 수행 된다. for{ case c1 <- 10: // 매번 체널 c1 에 값을 보냄 case s:= <-c2: // c2 값이 들어 왔을때는 값을 꺼낸뒤 s에 대입 } 동기화 객체 Mutex: 뮤텍스 ,상호 배제, 공유 데이터 보호에 주로 사용 RWMutex: 읽기/쓰기 뮤텍스 입니다. 일기와 쓰기 동작을 나누어서 잠금을 걸수 있습니다. Cond: 조건 변수 (condition variable) 입니다. 대기하고 있는 하나이상의 객체를 깨울수 있다. Once: 특정함수를 딱 한번만 실행할때 사용합니다. Pool: 멀티 쓰레드 (고루틴)에서 사용할 수 있는 객체풀 입니다. 자주 사용하는 객체를 풀에 보관하여 사용가능 하다. WaitGroup:고루틴이 모두 끝날 때까지 기다리는 기능 Atomic: 원자적 연산이라고도 하며 더 이상 쪼갤 수 없는 연산 의미 고루틴에서 안전하게 값을 연산하는 기능 입니다.

May 3, 2019 · 2 min · 289 words · Hillfolk

Go Messaging System

Nats Message Echo System Intro Nats Server는 IoT 메시징 및 마이크로 서비스 아키텍처를 위한 간단하고 고성능의 오픈소스 메시징 시스템 입니다. go로 작성되어 있으며 Python, Java, Ruby, Node.js 등으로 작성된 클라이언트가 있습니다. NATS Design Goals The core principles underlying NATS are performance, scalability, and ease-of-use. Based on these principles, NATS is designed around the following core features: Highly performant (fast) Always on and available (dial tone) Extremely lightweight (small footprint) Support for multiple qualities of service (including guaranteed “at-least-once” delivery with NATS Streaming) Support for various messaging models and use cases (flexible) Pub Code var urls = flag.String("s", nats.DefaultURL, "The nats server URLs (separated by comma)") log.SetFlags(0) flag.Usage = usage flag.Parse() args := flag.Args() if len(args) < 2 { usage() } nc, err := nats.Connect(*urls) if err != nil { log.Fatal(err) } defer nc.Close() subj, msg := args[0], []byte(args[1]) for { nc.Publish(subj, msg) nc.Flush() } if err := nc.LastError(); err != nil { log.Fatal(err) } else { log.Printf("Published [%s] : '%s'\n", subj, msg) } Sub Code var urls = flag.String("s", nats.DefaultURL, "The nats server URLs (separated by comma)") var showTime = flag.Bool("t", false, "Display timestamps") log.SetFlags(0) flag.Usage = usage flag.Parse() args := flag.Args() if len(args) < 1 { usage() } nc, err := nats.Connect(*urls) if err != nil { log.Fatalf("Can't connect: %v\n", err) } subj, i := args[0], 0 nc.Subscribe(subj, func(msg *nats.Msg) { i += 1 printMsg(msg, i) }) nc.Flush() if err := nc.LastError(); err != nil { log.Fatal(err) } log.Printf("Listening on [%s]\n", subj) if *showTime { log.SetFlags(log.LstdFlags) }

May 2, 2019 · 2 min · 248 words · Hillfolk

Go Cobra 사용하기

Cobra는 강력한 Cli 라이브러리로서 Go 기반에서 구동된다. 해당 모듈은 docker, kubernetes, hugo 등에서 사용될 정도로 안정적인 라이브러리 이다. cobra github Install go get을 이용해서 package를 설치하고 코드에 import 해준다. go get -u github.com/spf13/cobra/cobra import "github.com/spf13/cobra" Cobra Generator Cobra Generator를 사용하면 손쉽게 Cobra를 적용할수 있다. cobra 팩키지가 설치된 경우 자동으로 cobra 프로젝트를 추가하거나 Command을 추가하는 명령을 사용할 수 있다. Generator는 $GOPATH 하위 리소스에서 사용가능하다. 초기화 init 명령으로 cobra에게 적합한 프로젝트 구성 및 자동으로 cobra 코드를 생성해 준다. ...

May 1, 2019 · 1 min · 121 words · Hillfolk

Go MongoDB 사용하기

MongoDB MongoDB는 C++로 작성된 오픈소스 문서지향(Document-Oriented) 적 Cross-platform 데이터베이스이며, 뛰어난 확장성과 성능을 가지고 있다. Go용 MongoDB 드라이버 Go 에서 Mongodb 용 라이브러리는 몇개 정도 지원 되는것으로 보인다. 그중에 mongo-go-driver 공식 Go 드라이버를 기준으로 작성 하였습니다. Install go get go.mongodb.org/mongo-driver/mongo import & Create client import시 주소에 주의해야한다. 일부 문서에는 이전 github 주소로 되어 있는 경우가 있다. import "go.mongodb.org/mongo-driver/mongo" import "go.mongodb.org/mongo-driver/mongo/options" client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017")) MongoDB Connect MongoDB 연결시 일정시간이 지나면 연결 종료 신호를 보낼수 있도록 context.WithTimOut 함수를 이용하여 타임아웃 시간을 지정한후 연결한다. 연결 체크는 Ping 함수를 통해서할수 있다. ...

May 1, 2019 · 2 min · 400 words · Hillfolk

Firedac에서 SQLite 사용하기(Window)#

Firedac에서 SQLite 사용하기(Window)# firedac은 델파이에서 기본적으로 제공하는 데이터베이스 엑서스 컴포넌트입니다. Window 나 MacOS 또는 모바일에서 다 사용이 가능하기 때문에 최근에는 가장 쉽게 접근할수 있는 컴포넌트입니다. 회사에서 프로젝트를 진행하면서 로컬에서 데이터베이스를 사용해야 하기 때문에 가벼운 SQLite 를 사용해야 할때 쉽게 설치가 가능하기 때문에 사용해봤습니다. 그러면서 FireDac에서 SQLite 를 사용하는 방법에 대해서 간단하게 포스트 남깁니다. FireDac에서 SQLite3 연결하기 우선 연결을 위해서는 Driver 를 설정해야 합니다. 그리고 TFDPhysSQLiteDriverLink 를 Form에 올려 놓고 VenderHome 와 VenderLib 를 지정합니다. 저늘 실행파일이 실행되는 곳에서 SQLite3 폴더를 만들고 그안에 DLL 파일을 넣었습니다. 컴포넌트에 아래와 같이 지정해 줍니다. ...

February 26, 2019 · 1 min · 182 words · Hillfolk