我們有一個流程，用戶可以通過該流程請求我們需要從源頭獲取的文件。此來源不是最可靠的，因此我們使用 Amazon SQS 實施了一個隊列。我們將下載 URL 放入隊列中，然后使用我們用 Go 編寫的一個小應用程序對其進行輪詢。這個應用程序只是檢索消息，下載文件，然后將其推送到我們存儲它的 S3。一旦所有這些都完成，它會回調一個服務，該服務將通過電子郵件通知用戶，讓他們知道文件已準備就緒。最初我寫這個是為了創(chuàng)建n 個通道，然后將 1 個 go-routine 附加到每個通道，并使 go-routine 處于無限循環(huán)中。這樣我就可以確保我一次只處理固定數(shù)量的下載。我意識到這不是應該使用通道的方式，如果我現(xiàn)在理解正確的話，實際上應該有一個帶有n 個go-routines 的通道在該通道上接收。每個 go-routine 都處于無限循環(huán)中，等待一條消息，當它收到消息時，它將處理數(shù)據(jù)，做它應該做的一切，當它完成時，它將等待下一條消息。這讓我可以確保我一次只處理n 個文件。我認為這是正確的做法。我相信這是扇出，對吧？我并不需要做的，是要合并這些進程重新走到一起。下載完成后，它會回調遠程服務，以便處理剩余的過程。該應用程序無需執(zhí)行任何其他操作。好的，所以一些代碼：func main() {    queue, err := ConnectToQueue() // This works fine...    if err != nil {        log.Fatalf("Could not connect to queue: %s\n", err)    }    msgChannel := make(chan sqs.Message, 10)    for i := 0; i < MAX_CONCURRENT_ROUTINES; i++ {        go processMessage(msgChannel, queue)    }    for {        response, _ := queue.ReceiveMessage(MAX_SQS_MESSAGES)        for _, m := range response.Messages {            msgChannel <- m        }    }}func processMessage(ch <-chan sqs.Message, queue *sqs.Queue) {    for {        m := <-ch        // Do something with message m        // Delete message from queue when we're done        queue.DeleteMessage(&m)    }}我在這附近的任何地方嗎？我有n 個正在運行的 go-routines（其中MAX_CONCURRENT_ROUTINES= n）并且在循環(huán)中我們將繼續(xù)將消息傳遞到單個通道。這是正確的方法嗎？我需要關閉任何東西還是我可以無限期地運行它？我注意到的一件事是 SQS 正在返回消息，但是一旦我將 10 條消息傳入processMessage()（10 條是通道緩沖區(qū)的大?。?，實際上沒有進一步處理消息。