第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

為一個通道使用多個接收器

為一個通道使用多個接收器

Go
桃花長相依 2021-11-22 20:03:59
我正在嘗試使用go-json-rest在 golang 中編寫 REST 服務(wù)該服務(wù)的目的只是將接收到的數(shù)據(jù)轉(zhuǎn)換為 CSV 并記錄下來。由于負載可能很重,我想使用 goroutines 進行日志記錄。目前我已經(jīng)創(chuàng)建了四個 LogWorkers(goroutine) 每個 goroutine 將把 CSV 記錄到單獨的文件中。當我執(zhí)行代碼時,日志總是從最后一個 goroutine 觸發(fā)。我看到在我的日志文件夾中創(chuàng)建了一個來自第四個例程的文件。這是我的服務(wù)器代碼package mainimport (    "github.com/ant0ine/go-json-rest/rest"    "log"    "net/http"    "strconv"    "time")const workerCount = 4var evChannel = make(chan Event)var workers = make([]*LogWorker, workerCount)const maxLogFileSize = 100 // In MBconst maxLogFileBackups = 30const maxLogFileAge = 5const logFileName = "/home/sam/tmp/go_logs/event_"func main() {    // Initialize workers    // Four workers is being created    for i := 0; i < workerCount; i++ {        var fileName = logFileName + strconv.Itoa(i)        workers[i] = NewLogWorker(fileName, maxLogFileSize, maxLogFileBackups, maxLogFileAge)        go workers[i].Work(evChannel)    }        // Initialize REST API    api := rest.NewApi()    //api.Use(rest.DefaultDevStack...)    api.Use(rest.DefaultCommonStack...)    router, err := rest.MakeRouter(        rest.Post("/events", StoreEvents),    )    if err != nil {        log.Fatal(err)    }    api.SetApp(router)    log.Fatal(http.ListenAndServe(":4545", api.MakeHandler()))}func StoreEvents(w rest.ResponseWriter, r *rest.Request) {    event := Event{}    err := r.DecodeJsonPayload(&event)    if err != nil {        rest.Error(w, err.Error(), http.StatusInternalServerError)        return    }    // TODO : Add validation if needed    // Add code to parse the request and add further information to event     // log.Println()    select {        case evChannel <- event:        case <- time.After(5 * time.Second):      // throw away the message, so sad    }        // evChannel <- event    //log.Println(Csv(event))    w.WriteHeader(http.StatusOK)}請注意 event 是一個包含一些字符串字段的結(jié)構(gòu)。SO 中已經(jīng)有一個類似的問題。當我嘗試在playground執(zhí)行 goroutine 時,它仍然打印上次goroutine的值。提供的答案有一些等待。完成。由于我的工人需要連續(xù)運行,我認為我不能使用它。請幫我找出為什么我的所有 goroutines (LogWorkers) 都沒有被使用?
查看完整描述

1 回答

?
瀟湘沐

TA貢獻1816條經(jīng)驗 獲得超6個贊

您正在每個 goroutine 中設(shè)置日志包的默認全局記錄器輸出。


您可能想要做更多類似的事情:


func (lw *LogWorker) Work(evChannel chan Event) {

    fmt.Println(lw.FileName)

    lg := log.New(&lumberjack.Logger {

        Filename:   lw.FileName,

        MaxSize:    lw.MaxSize,

        MaxBackups: lw.MaxBackups,

        MaxAge:     lw.MaxAge,

    }, "", 0)


    for {

        event := <- evChannel

        lg.Println(Csv(event))

    }

}

這將為每個 goroutine 提供一個記錄器。


在您的版本中,您可能只有最后一個要執(zhí)行(可能是最后一個 goroutine 生成,但不能保證)


為了進一步改進,您可能還希望將 for 循環(huán)寫為:


for event := range evChannel {

    lg.Println(Csv(event))

}

這樣,它會在通道關(guān)閉時終止 goroutine,而不是在關(guān)閉通道中的空值上旋轉(zhuǎn)。 請參閱此處以供參考


查看完整回答
反對 回復 2021-11-22
  • 1 回答
  • 0 關(guān)注
  • 205 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學習伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號