Golang에서 하트비트 패턴 사용

애플리케이션 모니터링을 위해 Go에서 하트비트 구현

데이터와 소프트웨어 엔지니어의 균형을 맞추는 모험을 하는 동안 저는 항상 GoLang에서 조금 다른 것을 찾아서 GoLang의 작동 방식을 연구하고 이해하며 인터넷에서 찾은 일부 기본 강좌 및 기사보다 더 복잡한 것에 적용합니다. . 이 짧은 기사에서는 Ticker를 사용하여 채널 사용 외에도 애플리케이션의 하트비트("I'm Alive")를 시뮬레이션하는 시간 패키지인 Go Routines를 통해 구현한 방법을 보고하고 시연하겠습니다.

특정 함수를 호출하는 사람이 함수가 시간이 걸리는지, 처리 중인지 또는 잠겨 있는지를 알 수 있도록 하는 것이 매우 중요하다는 것은 많은 사람들에게 새로운 소식이 아닙니다. 즉, 대부분의 경우 메트릭을 수집하고 모든 것을 시각화하는 인터페이스로 보내는 애플리케이션 서버에 설치된 에이전트를 사용하는 모니터링 애플리케이션에 도입된 추적, 메트릭, 연결 등과 같은 몇 가지 다른 용어가 등장했습니다. 거의) 귀하의 지원서 상태입니다. 이러한 도구 중에는 DataDog, NewRelic, Slack, Grafana, Jaeger 등이 있습니다.

여기서는 무엇을 갖게 될까요?

좀 더 발전된 Go 개념을 다루는 빠르고 간단한 것을 만들기 위해 연구하고 생각하면서 하트비트 패턴을 활용하는 비교적 간단한 애플리케이션을 만들었습니다. 나에게 전화하는 사람은 누구든지 결과를 받고 동시에 내가 아직 활동 중인지 여부에 대한 정보를 받습니다. 보다 고급 시나리오에서는 Prometheus의 간단한 구현으로 이 문제(애플리케이션이 활성 상태입니까? CPU, 메모리, 개방형 고루틴)를 해결하므로 일부 비즈니스 특수성 측면에서 실제로 활성 애플리케이션이 무엇인지 사용자 정의하는 것이 흥미로울 수 있습니다. 동시적이고 맞춤화된 피드백은 아닙니다.

아워 오브 코드!

구조 측면에서 go mod를 사용하여 패키지 내에서 세 개의 파일만 만들었습니다.

• Dictionary.go: 검색할 기능의 이름 사전이 포함되어 있습니다.
• task.go: 사전에서 이름을 검색하는 기능과 동시에 team.Ticker의 채널 비트를 통해 활성 여부를 알려주는 기능이 포함된 작업입니다.
• task_test.go: task.go에 있는 함수의 단위 테스트를 수행하여 사전 데이터의 응답과 애플리케이션이 아직 실행 중인지에 대한 피드백을 모두 확인합니다!

Dictionary.go

Go 코드의 이 부분은 룬 문자를 문자열과 연관시키는 맵인 "사전"이라는 변수를 정의합니다.

각 지도 항목은 키(룬)와 값(문자열)입니다. 아래 예에서 키는 알파벳의 소문자이고 값은 각 문자와 연관된 이름입니다. 예를 들어 문자 'a'는 "airton"이라는 이름과 연결되고 문자 'b'는 "bruno"라는 이름과 연결되는 식입니다.

package heartbeat

var dicionario = map[rune]string{
    'a': "airton",
    'b': "bruno",
    'c': "carlos",
    'd': "daniel",
    'e': "eduardo",
    'f': "felipe",
    'g': "gustavo",
}

task.go

완전한 코드를 작성한 후 코드의 각 부분을 더 잘 설명합니다.

package heartbeat

import (
    "context"
    "fmt"
    "time"
)

func ProcessingTask(
    ctx context.Context, letras chan rune, interval time.Duration,
) (<-chan struct{}, <-chan string) {

    heartbeats := make(chan struct{}, 1)
    names := make(chan string)

    go func() {
        defer close(heartbeats)
        defer close(names)

        beat := time.NewTicker(interval)
        defer beat.Stop()

        for letra := range letras {
            select {
            case <-ctx.Done():
                return
            case <-beat.C:
                select {
                case heartbeats <- struct{}{}:
                default:
                }
            case names <- dicionario[letra]:
                lether := dicionario[letra]
                fmt.Printf("Letra: %s \n", lether)

                time.Sleep(3 * time.Second) // Simula um tempo de espera para vermos o hearbeats
            }
        }
    }()

    return heartbeats, names
}

종속성 가져오기

package heartbeat

import (
    "context"
    "fmt"
    "time"
)

여기에는 작업을 처리하는 동안 특정 시간 간격으로 "하트비트"를 보내는 기능을 구현하는 하트비트 패키지가 있습니다. 이를 위해서는 컨텍스트(Context Management), fmt(문자열 형식화용) 및 시간 제어를 위한 시간이 필요합니다.

초기 기능 정의

func ProcessingTask (
    ctx context.Context, letras chan rune, interval time.Duration,
) (<-chan struct{}, <-chan string) {

이것은 ctx 컨텍스트, 문자 채널(유니코드 문자를 수신하는 채널) 및 시간 간격을 인수로 사용하는 ProcessTask 함수의 정의입니다. 이 함수는 두 개의 채널을 반환합니다. 각 "하트비트"에 대해 빈 구조체를 전송하는 하트비트 채널과 수신된 각 문자에 해당하는 문자의 이름을 전송하는 이름 채널입니다.

채널

heartbeats := make(chan struct{}, 1)
names := make(chan string)

이 두 줄은 두 개의 채널을 생성합니다. heartbeats는 한 요소의 용량을 갖는 버퍼 채널이고 names는 버퍼되지 않은 채널입니다.

무거운 작업을 수행하는 Go Routine

go func() 
    defer close(heartbeats)
    defer close(names)

    beat := time.NewTicker(interval)
    defer beat.Stop()

    for letra := range letras {
        select {
        case <-ctx.Done():
            return
        case <-beat.C:
            select {
            case heartbeats <- struct{}{}:
            default:
            }
        case names <- dicionario[letra]:
            lether := dicionario[letra]
            fmt.Printf("Letra: %s \n", lether)

            time.Sleep(3 * time.Second) // Simula um tempo de espera para vermos o hearbeats
        }
    }
}()

return heartbeats, names

ProcessingTask 함수의 기본 로직을 실행하는 익명 고루틴(또는 새 스레드에서 실행되는 익명 함수)입니다. for-range 루프를 사용하여 문자 채널에서 문자를 읽습니다. 루프 내에서 선택을 사용하여 사용 가능한 옵션 중에서 수행할 작업을 선택하세요.

• case <-ctx.Done(): 컨텍스트가 취소되면 return.
문을 사용하여 함수가 즉시 종료됩니다.
• case <-beat.C: 비트 티커가 값을 전송하면 고루틴은 기본값이 비어 있는 선택을 사용하여 빈 구조체를 하트비트 채널로 전송하려고 시도합니다.
• 케이스 이름 <- Dictionary[letter]: 문자가 수신되면 고루틴은 사전 사전에서 해당 문자의 이름을 가져와 이름 채널로 보내고 fmt 패키지를 사용하여 문자를 화면에 인쇄하고 기다립니다. 다음 문자로 넘어가기 3초 전. 이 시뮬레이션된 대기는 "하트비트"가 전송되는 것을 확인하기 위한 것입니다.

마지막으로 이 함수는 하트비트를 반환하고 채널 이름을 지정합니다.

애플리케이션 테스트

task_test.go

package heartbeat

var dicionario = map[rune]string{
    'a': "airton",
    'b': "bruno",
    'c': "carlos",
    'd': "daniel",
    'e': "eduardo",
    'f': "felipe",
    'g': "gustavo",
}

여기서 앞서 설명한 ProcessTask 함수에 대한 Go 단위 테스트를 만들었습니다. TestProcessingTask 테스트 함수는 시간 제한이 20초이고 유니코드 문자(문자) 채널이 있는 컨텍스트를 생성합니다. 그런 다음 익명의 고루틴은 가사 채널에 가사를 보냅니다. 그런 다음 컨텍스트, 유니코드 문자 채널 및 시간 간격을 사용하여 ProcessTask 함수가 호출됩니다. 하트비트 채널과 단어 채널이라는 두 개의 채널을 반환합니다.

그런 다음 테스트 기능은 선택을 통해 무한 루프를 실행합니다. 이 루프는 세 가지 채널(컨텍스트, 하트비트 채널, 단어 채널)에서 읽습니다.

컨텍스트가 취소되면 테스트 루프가 종료됩니다. 하트비트가 수신되면 "Application Up!" 표준 출력으로 인쇄됩니다. 단어가 수신되면 테스트에서는 해당 단어가 문자 사전에 있는지 확인합니다. 존재하지 않으면 테스트가 실패하고 오류 메시지가 표시됩니다.

따라서 이 단위 테스트에서는 시간 제한을 사용한 컨텍스트에서 실행되는 동안 한 채널에서 문자를 수신하고, 문자 이름을 다른 채널로 보내고, '하트비트'를 내보내는 프로세싱태스크 함수를 테스트합니다. 아... 그리고 단어 채널로 보낸 글자 이름이 사전에 있는지도 확인합니다.

내 결론

이 Go 코드는 Go 언어 및 단위 테스트의 몇 가지 중요한 개념을 보여줍니다.

• 컨텍스트
• 고루틴
• 채널
• 단위 테스트(select를 사용하여 여러 채널 모니터링)

내 GitHub의 전체 프로젝트: https://github.com/AirtonLira/heartbeatsGolang

LinkedIn - Airton Lira Junior

위 내용은 Golang에서 하트비트 패턴 사용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!