콘텐츠로 이동
Wippy

명령 디스패치

명령 디스패치

섹션 제목: “명령 디스패치”

디스패치 시스템은 프로세스에서 핸들러로 명령을 라우팅합니다. 프로세스는 상관 태그와 함께 명령을 yield하고, 핸들러는 비동기 작업을 실행하고, 결과는 이벤트 큐를 통해 돌아옵니다.

흐름

섹션 제목: “흐름”
sequenceDiagram
    participant P as 프로세스
    participant W as 워커
    participant R as 레지스트리
    participant H as 핸들러


    P->>W: yield(command, tag)
    W->>R: getHandler(cmdID)
    R-->>W: handler
    W->>H: Handle(cmd, tag, receiver)
    H-->>H: 비동기 작업
    H->>W: CompleteYield(tag, result)
    W->>P: 이벤트 큐잉, 웨이크
    P->>P: 결과로 재개

명령 레지스트리

섹션 제목: “명령 레지스트리”

레지스트리는 하이브리드 구조로 핸들러를 저장합니다:

type Registry struct {
    handlers [256]Handler         // 시스템 명령: O(1) 인덱스
    extended map[CommandID]Handler // 확장 명령: 맵 조회
    frozen   atomic.Bool          // 부트 후 락 프리
}

시스템 명령(0-255)은 배열 인덱싱을 사용합니다. 확장 명령은 맵 조회를 사용합니다. Freeze() 후에는 모든 조회가 락 프리입니다.

명령 ID 범위

섹션 제목: “명령 ID 범위”
범위모듈예제
1-9processSend, Spawn, Terminate, Cancel, Monitor, Unmonitor, Link, Unlink, Exec
10-29clockSleep, Ticker, Timer
30-39socketDial, Listen, Accept, Close
50-59streamRead, Write, Close, Seek
60-69httpRequest, RequestBatch
70-79tty터미널 I/O
80-89websocketConnect, Send, Receive
90-99eventSubscribe, Send
100-119sqlQuery, Execute, Prepare, Stmt, Tx ops
120-129storeGet, Set, Delete, Has
130-139securityValidateToken, CreateToken
140-149functionCall, AsyncStart, AsyncCancel
150-159execProcessWait
160-169cloudstorageUpload, Download, List, Presigned URLs
170-179evalCompile, Run
180-189workflowSideEffect, Call, Version, UpsertAttrs
190-199contractOpen, Call, AsyncCall, AsyncCancel
256+custom사용자 정의 서비스

등록은 MustRegisterCommands()를 통해 부트 중에 발생합니다. 충돌은 시작 시 패닉을 발생시킵니다.

명령 정의

섹션 제목: “명령 정의”

명령은 고유한 CommandID가 있는 데이터 구조입니다:

const MyCommand dispatcher.CommandID = 200


type MyCmd struct {
    Input  string
    Option int
}


var myCmdPool = sync.Pool{New: func() any { return &MyCmd{} }}


func (c *MyCmd) CmdID() dispatcher.CommandID { return MyCommand }


func (c *MyCmd) Release() {
    c.Input = ""
    c.Option = 0
    myCmdPool.Put(c)
}

풀 재사용은 핫 패스에서 할당을 제거합니다. 패키지 init에서 등록:

func init() {
    dispatcher.MustRegisterCommands("myservice", MyCommand)
}

디스패처

섹션 제목: “디스패처”

디스패처는 관련 핸들러를 그룹화합니다. 핸들러를 등록하기 위해 RegisterAll을 구현하고 설정/해제를 위한 라이프사이클 메서드를 가집니다:

type Handler interface {
    Handle(ctx context.Context, cmd Command, tag uint64, receiver ResultReceiver) error
}


type ResultReceiver interface {
    CompleteYield(tag uint64, data any, err error)
}
type Dispatcher struct {
    // 서비스 상태
}


func (d *Dispatcher) RegisterAll(register func(id dispatcher.CommandID, h dispatcher.Handler)) {
    register(myapi.MyCommand, dispatcher.HandlerFunc(d.handleMyCommand))
}


func (d *Dispatcher) handleMyCommand(ctx context.Context, cmd Command, tag uint64, receiver ResultReceiver) error {
    c := cmd.(*myapi.MyCmd)
    go func() {
        result := doWork(c)
        if ctx.Err() == nil {
            receiver.CompleteYield(tag, result, nil)
        }
    }()
    return nil
}

부트 컴포넌트로 등록:

func MyDispatcher() boot.Component {
    return boot.New(boot.P{
        Name:      "dispatcher.myservice",
        DependsOn: []boot.Name{DispatcherName},
        Load: func(ctx context.Context) (context.Context, error) {
            reg := dispatcher.GetRegistrar(ctx)
            svc := myservice.NewDispatcher()
            svc.RegisterAll(reg.Register)
            return ctx, nil
        },
    })
}

Yield와 상관관계

섹션 제목: “Yield와 상관관계”

프로세스가 비동기 작업이 필요하면 상관 태그와 함께 명령을 yield합니다:

type Yield struct {
    Cmd Command
    Tag uint64    // 상관관계를 위한 프로세스 로컬 카운터
}

워커는 각 스텝 후 StepOutput에서 yield를 추출하고 핸들러에 디스패치합니다. 각 태그는 결과를 다시 매칭할 수 있도록 요청을 고유하게 식별합니다.

참고

섹션 제목: “참고”