2014 подписчиков

🦫Сетевое программирование в Go

Напишем Go-программу для создания сервера, способного обрабатывать множество соединений и следить за ними.

Go-сервер похож на офисного секретаря, который принимает звонки (сетевые соединения), ведет учет звонков (логирование данных) и может общаться с несколькими людьми одновременно (параллельная обработка нескольких соединений).

Отправная точка: импорт пакетов

Начнем с импорта необходимых пакетов:

import (

"context"

"log"

"net"

"os"

"time"

"golang.org/x/sync/semaphore"

)

Эти пакеты предоставляют инструменты для работы с сетями, логирования, управления контекстами и использования семафоров. “Семафоры” — это образное выражение, обозначающее контроль над количеством параллельных процессов.

Пакет Semaphore

В Go пакет semaphore используется для ограничения количества определенных операций, выполняемых одновременно.

Представьте его в виде светофора. Он управляет потоком машин (комплексом программных задач), чтобы предотвратить пробки (чрезмерное использование ресурсов).

Что касается кода, то здесь semaphore ограничивает количество соединений, которые сервер обрабатывает одновременно.

Создание главной функции

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

func main() {

// Создаем семафор с максимальным весом maxConcurrentConnections.

sem = semaphore.NewWeighted(maxConcurrentConnections)

// Создаем файл лога.

logFile, err := os.OpenFile("network.log", os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)

if err != nil {

log.Fatalf("Error opening log file: %v", err)

}

defer logFile.Close()

// Устанавливаем вывод логера по умолчанию в файл лога.

log.SetOutput(logFile)

// Прослушиваем входящие соединения.

l, err := net.Listen("tcp", ":2000")

if err != nil {

log.Fatalf("Error listening: %v", err)

}

// Закрываем слушателя при закрытии приложения.

defer func() {

if err = l.Close(); err != nil {

log.Printf("Error closing listener: %v", err)

}

}()

log.Println("Listening on localhost:2000")

// ...

}

🟠Продолжение

@golang

1 минута

31 июля 2023