Как можно отправить параллельно 5 запросов к серверу

1️⃣ Как кратко ответить

Для отправки параллельно 5 запросов к серверу в Go можно использовать горутины и канал для синхронизации. Создайте 5 горутин, каждая из которых выполняет HTTP-запрос, и используйте sync.WaitGroup для ожидания завершения всех запросов.

2️⃣ Подробное объяснение темы

В языке программирования Go параллельное выполнение задач достигается с помощью горутин. Горутины — это легковесные потоки, которые позволяют выполнять функции одновременно. Для отправки параллельно 5 запросов к серверу, мы можем использовать горутины и механизм синхронизации sync.WaitGroup.

Пример кода

package main
​
import (
    "fmt"
    "net/http"
    "sync"
)
​
// Функция для выполнения HTTP-запроса
func makeRequest(url string, wg *sync.WaitGroup) {
    // Уменьшаем счетчик WaitGroup после завершения функции
    defer wg.Done()
​
    // Выполняем HTTP GET запрос
    resp, err := http.Get(url)
    if err != nil {
        fmt.Println("Ошибка при выполнении запроса:", err)
        return
    }
    // Закрываем тело ответа после завершения
    defer resp.Body.Close()
​
    // Выводим статус ответа
    fmt.Println("Получен ответ от", url, "с кодом статуса", resp.StatusCode)
}
​
func main() {
    // Создаем экземпляр WaitGroup
    var wg sync.WaitGroup
​
    // Список URL для запросов
    urls := []string{
        "http://example.com",
        "http://example.org",
        "http://example.net",
        "http://example.edu",
        "http://example.gov",
    }
​
    // Устанавливаем количество горутин, которые мы будем ожидать
    wg.Add(len(urls))
​
    // Запускаем горутину для каждого URL
    for _, url := range urls {
        // Запускаем горутину
        go makeRequest(url, &wg)
    }
​
    // Ожидаем завершения всех горутин
    wg.Wait()
    fmt.Println("Все запросы завершены")
}

Объяснение кода

1. Импортируемые пакеты:

   • fmt для вывода информации в консоль.
   • net/http для выполнения HTTP-запросов.
   • sync для использования WaitGroup.

2. Функция makeRequest:

   • Принимает URL и указатель на sync.WaitGroup.
   • Использует defer wg.Done() для уменьшения счетчика WaitGroup после завершения функции.
   • Выполняет HTTP GET запрос к указанному URL.
   • Обрабатывает ошибки, если они возникают.
   • Закрывает тело ответа с помощью defer resp.Body.Close().
   • Выводит код статуса ответа.

3. Функция main:

   • Создает экземпляр sync.WaitGroup.
   • Определяет список URL для запросов.
   • Устанавливает количество горутин, которые нужно ожидать, с помощью wg.Add(len(urls)).
   • Запускает горутину для каждого URL, передавая URL и указатель на WaitGroup.
   • Использует wg.Wait() для ожидания завершения всех горутин.
   • Выводит сообщение о завершении всех запросов.

Зачем это нужно

Параллельное выполнение запросов позволяет значительно ускорить обработку, особенно если каждый запрос занимает значительное время. Это полезно в ситуациях, когда необходимо одновременно взаимодействовать с несколькими внешними сервисами или API. Использование горутин и WaitGroup обеспечивает эффективное управление параллельными задачами и синхронизацию их завершения.