GO 언어로 공유 된 여러 고루틴의 데이터베이스 연결을 올바르게 닫는 방법은 무엇입니까?

GO Multi-Goroutine 공유 데이터베이스 연결의 우아한 클로즈

GO 동시 프로그래밍에서 여러 고루 틴 공유 데이터베이스 연결이 일반적인 시나리오입니다. 부적절한 연결 종료로 인해 데이터 손실 또는 프로그램 충돌이 발생할 수 있습니다. 이 기사에서는 여러 고어 라틴 공유에 대한 데이터베이스 연결을 안전하게 닫는 방법을 살펴 봅니다.

문제 분석 :

기본 고 로우틴에서 직접 defer db.Close() 사용하면 모든 아동 고리 틴이 데이터베이스 작업을 완료했다고 보장 할 수 없으므로 연결이 사전에 닫히고 오류가 발생할 수 있습니다. 각 어린이 고리 틴에서 defer db.Close() 사용하면 연결이 여러 번 닫히고 동일한 오류가 발생합니다.

해결책:

카운터 및 sync.WaitGroup 사용하여 Goroutine의 실행 및 데이터베이스 연결 폐쇄를 조정하는 것이 좋습니다.

샘플 코드 :

 패키지 메인

수입 (수입)
    "FMT"
    "동조"
    "시간"

    "데이터베이스/SQL"
    _ "github.com/go-sql-driver/mysql"// 데이터베이스 드라이버로 교체)

DBCONN STRUCT 타입 {
    Conn *sql.db
    WG *SYNC.WAITGROUP
}

func opendb () (*dbconn, error) {
    db, err : = sql.open ( "mysql", "user : password@tcp (127.0.0.1:3306)/database") // 데이터베이스 연결 문자열로 대체! = nil {
        반환 nil, err
    }
    return & dbconn {conn : db, wg : & sync.waitgroup {}}, nil
}

func (dc *dbconn) close () 오류 {
    dc.wg.wait () // 모든 고 루틴이 반환을 완료 할 때까지 기다려 DC.conn.close ()
}

func querydb (dc *dbconn, i int) {
    DC.WG.DONE () 연기 ()
    dc.wg.add (1) // 카운터가 추가됩니다 1
    // ... 데이터베이스 작동 ...
    time.sleep (time.second) // 데이터베이스 작업 시뮬레이션 시간 소비 FMT.printf ( "Goroutine %d 완성 \ n", i)
}

func main () {
    dc, err : = opendb ()
    err! = nil {인 경우
        fmt.println ( "오류 열기 데이터베이스 :", err)
        반품
    }
    DC.Close ()을 지연시킵니다. // I : = 0의 연결을 마지막으로 닫으십시오. I <p> <strong>코드 설명 :</strong></p><ol>
<li> <code>dbConn</code> 구조에는 데이터베이스 연결 및 <code>sync.WaitGroup</code> 포함되어있어 고루 틴의 실행을 관리합니다.</li>
<li> <code>openDb</code> 함수는 데이터베이스 연결을 열고 <code>dbConn</code> 인스턴스를 반환합니다.</li>
<li> <code>close</code> 방법은 <code>dc.wg.Wait()</code> 사용하여 데이터베이스 연결을 닫기 전에 모든 고루틴이 완료 될 때까지 기다립니다.</li>
<li> <code>querydb</code> 함수는 <code>dc.wg.Add(1)</code> 사용하여 데이터베이스 작업을 실행하기 전에 카운터를 늘리고 <code>defer dc.wg.Done()</code> 사용하여 작업이 완료된 후 카운터를 줄입니다.</li>
<li> <code>main</code> 함수는 여러 고어 라인을 시작하여 <code>querydb</code> 함수를 실행하고 <code>defer dc.close()</code> 사용하여 데이터베이스 연결을 닫습니다.</li>
</ol><p> 이 방법을 사용하면 모든 Goroutine이 데이터베이스 작업을 완료 한 다음 데이터 손실 및 오류를 피하기 위해 데이터베이스 연결을 닫을 수 있습니다. 샘플 코드에서 데이터베이스 연결 문자열 및 드라이버를 교체해야합니다. 데이터베이스 운영 시간이 예측할 수없는 경우, 채널을 사용한 신호와 같은 모든 고어 라인이 완료 될 때까지 더 복잡한 메커니즘이 필요할 수 있습니다.</p>

위 내용은 GO 언어로 공유 된 여러 고루틴의 데이터베이스 연결을 올바르게 닫는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!