💬 Как реализовать reverse proxy на Go?

Reverse proxy — это механизм для перенаправления входящих запросов на другой сервер или сервис. Для реализации на Go можно использовать пакет httputil:

package main

import (
    "net/http"
    "net/http/httputil"
    "net/url"
)

func main() {
    targetServer := "example.com"
    proxy := httputil.NewSingleHostReverseProxy(&url.URL{
        Scheme: "http",
        Host:   targetServer,
    })

    http.Handle("/", proxy)
    http.ListenAndServe(":8000", nil)
}

В примере входящие запросы на обратный прокси на порту 8000 будут перенаправлены на целевой сервер example.com.

Мы также можем настроить поведение обратного прокси, реализовав функцию Director, которая может быть использована для изменения запроса перед его перенаправлением на целевой сервер.

📌 Пример настройки функции Director:

package main

import (
    "net/http"
    "net/http/httputil"
    "net/url"
)

func main() {
    targetServer := "example.com"
    proxy := httputil.NewSingleHostReverseProxy(&url.URL{
        Scheme: "http",
        Host:   targetServer,
    })

    proxy.Director = func(req *http.Request) {
        req.Header.Set("X-Forwarded-Host", req.Host)
        req.Header.Set("X-Origin-Host", targetServer)
        req.Host = targetServer
    }

    http.Handle("/", proxy)
    http.ListenAndServe(":8000", nil)
}

🧑‍💻 Статьи для IT: как объяснять и распространять значимые идеи

Напоминаем, что у нас есть бесплатный курс для всех, кто хочет научиться интересно писать — о программировании и в целом.

Что: семь модулей, посвященных написанию, редактированию, иллюстрированию и распространению публикаций.

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

👉Материалы регулярно дополняются, обновляются и корректируются. А еще мы отвечаем на все учебные вопросы в комментариях курса.

💬 Что из себя представляют теги структур в Go?

Теги структур — это аннотации, которые отображаются после типа в объявлении структуры Go. Каждый тег состоит из коротких строк, которым назначены определенные значения.

Они не влияют на саму логику программы, но позволяют контролировать процесс сериализации и десериализации данных, валидацию и многое другое.

Пример использования:

type User struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}

В этом примере к полям структуры User добавлены теги json, которые указывают, как эти поля должны быть сериализованы в JSON. Тег json:"name" говорит, что поле Name должно быть представлено как "name" в JSON, аналогично для поля Age.

Для работы с этими тегами можно использовать пакет reflect. Например, чтобы получить значение тега json для поля Name, можно использовать:

package main

import (
    "fmt"
    "reflect"
)

type User struct {
    Name string `json:"name"`
    Age  int    `json:"age"`
}

func main() {
    p := User{Name: "John Doe", Age: 30}
    t := reflect.TypeOf(p)
    field, ok := t.FieldByName("Name")
    if ok {
        fmt.Println(field.Tag.Get("json")) // Выведет: name
    }
}

💬 Как создать кэш на Go?

Кэш — это инструмент, который сохраняет данные в памяти, чтобы их можно было быстро получить позже. На Go можно создать кэш с использованием пакета sync или сторонних библиотек вроде go-cache:

package main

import (
    "fmt"
    "sync"
)

func main() {
    // создаем новый кэш
    cache := &sync.Map{}

    // добавляем пару ключ-значение в кэш
    cache.Store("key", "value")

    // извлекаем значение из кэша
    value, ok := cache.Load("key")
    if ok {
        fmt.Println(value) // Output: value
    }

    // удаляем ключ из кэша
    cache.Delete("key")

    // проверяем, существует ли ключ в кэше
    _, ok = cache.Load("key")
    fmt.Println(ok) // Output: false
}

В примере мы создаем новую структуру sync.Map и используем функции Store(), Load(), Delete() для добавления, извлечения и удаления пар ключ-значение из кэша соответственно.

💬 Что происходит при запуске программы на Go? Например, если пакет main импортирует пакет A, а пакет A зависит от пакета B.

🔸 Процесс начинается с пакета main
🔸 Пакет main импортирует пакет A
🔸 Пакет A импортирует пакет B
🔸 Инициализируются глобальные переменные (если таковые имеются) в пакете B
🔸 Выполняется функция init() или функции пакета B, если они существуют. Это первая функция init(), которая выполняется
🔸 Глобальные переменные, если таковые имеются, в пакете A инициализируются
🔸 Выполняется функция init() или функции пакета A, если таковые имеются
🔸 Инициализируются глобальные переменные в пакете main
🔸 Выполняется функция init() или функции пакета main, если они есть
🔸 Функция main() пакета main начинает выполнение

📌 Если пакет main импортирует пакет B самостоятельно, то ничего не произойдет, поскольку все, что связано с пакетом B, запускается пакетом A. Так происходит потому, что пакет A сначала импортирует пакет B.

💬 Как устроено фаззинг-тестирование в Go?

Фаззинг представляет собою технологию автоматизированного поиска ошибок с помощью случайных входных данных и анализа реакции программы на них. Она полезна, если нужно проверить граничные условия или корректность обработки потока ввода — то есть тогда, когда нужно найти значения, при которых «падает» программа. В Go 1.18 была введена встроенная поддержка фаззинг-тестирования.

📌 Основные правила для фаззинг-тестов в Go:

1. Название метода должно начинаться с FuzzXxx, принимать только *testing.F в качестве аргумента и не возвращать значение.
2. Название файла с фаззинг-тестами: *_test.go.
3. Фаззинг target должна быть вызовом метода (*testing.F).Fuzz, который принимает *testing.T в качестве первого параметра, за которым следуют аргументы для фаззинга (не возвращает значение).
4. В одном фаззинг-тесте должна быть ровно одна фаззинг target.
5. Все элементы seed corpus должны иметь типы, идентичные аргументам для фаззинга, в том же порядке. Это касается вызовов (*testing.F).Add и любых файлов corpus в директории testdata/fuzz.
6. Аргументы для фаззинга могут быть только следующих типов:
- string, []byte
- int, int8, int16, int32/rune, int64
- uint, uint8/byte, uint16, uint32, uint64
- float32, float64
- bool

⚡️ Паттерн Transactional Outbox: теория и практика от Николая Тузова

⌛ Таймкоды:

00:00 Какую проблему мы решаем
05:47 Нам нужна атомарность
07:03 Про Two-Phase Commit
07:36 NoSQL базы данных
09:59 Гарантия доставки - "At Least Once"
11:48 Практика: пишем Outbox для сокращателя ссылок
12:43 Storage: сохраняем сообщения в таблицу
28:01 Event Sender: отправка сообщений из таблицы
36:52 Подключаем Event Sender
39:09 Тестируем отправку сообщений
41:12 Итоги

📺 Смотреть полностью

💬 Чем observability (наблюдаемость) отличается от «традиционного» мониторинга?

Мониторинг фокусируется на вопросах, ответы на которые помогут определить или предсказать некоторые ожидаемые или ранее имевшие место режимы отказа. Проще говоря, мониторинг сосредоточен на «известных неизвестных».

Предполагается, что система будет вести себя — и, следовательно, выходить из строя — определенным и предсказуемым образом. Когда обнаруживается новый режим отказа, его симптомы добавляются в пакет мониторинга, и процесс начинается сначала.

Мониторинг — это наши действия в системе, которые предпринимаются с целью узнать, работает она или не работает. Методы observability, напротив, основной упор делают на понимание системы, позволяющее соотносить события и поведение. Observability — это свойство системы, которое позволяет спросить, почему она не работает.

Три столпа observability — это собирательное название, под которым иногда упоминаются три наиболее распространенных (и основополагающих) инструмента — логирование, метрики и трассировка.

💬 Какие особенности необходимо учитывать при работе с функциями context.WithValue и context.Value?

Они позволяют определять и получать произвольные пары ключ/значение, которые могут использоваться процессами, обрабатывающими запросы.

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

👉 Подробнее

💬 Какие существуют распространенные реализации шаблона запрос/ответ?

🔸 REST — это архитектурный стиль для создания сетевых приложений, основанный на принципах HTTP. Он предполагает использование стандартных HTTP-методов (GET, POST, PUT, DELETE и т. д.) для выполнения операций над ресурсами, идентифицируемыми с помощью URL.
🔸 Вызов удаленных процедур (Remote Procedure Calls, RPC). RPC-фреймворки позволяют программам запускать процедуры в другом адресном пространстве (на удалённых узлах, либо в независимой сторонней системе на том же узле). В Go имеется стандартная реализация RPC в форме пакета net/rpc. Есть также две крупные реализации RPC, поддерживающие разные языки программирования: Apache Thrift и gRPC. Несмотря на сходство целей и архитектуры, gRPC, пользуется большей популярностью в сообществе.
🔸 GraphQL — язык запросов и управляющих воздействий, который часто считают альтернативой REST. Он особенно эффективен при работе со сложными наборами данных.

👉 А ваша служба является RESTful? Все что необходимо/обязательно знать про веб службы и REST (читать)

💬 Как создать альтернативу bytes.Buffer, которая реализует интерфейс io.ReadWriter, позволяет узнать длину и емкость буфера и занимает меньше памяти, чем bytes.Buffer?

Для этой задачи можно использовать новый тип, основанный на срезе байт. Вот пример реализации:

// Buffer — буфер байтов переменного размера с методами Read и Write
// Нулевое значение Buffer — пустой буфер, готовый к использованию
type Buffer []byte

// Write записывает len(p) байт из p в Buffer
func (b *Buffer) Write(p []byte) (int, error) {
    *b = append(*b, p...)
    return len(p), nil
}

// Read читает до len(p) байт в p из Buffer
func (b *Buffer) Read(p []byte) (int, error) {
    if len(p) == 0 {
        return 0, nil
    }
    if len(*b) == 0 {
        return 0, io.EOF
    }
    n := copy(p, *b)
    *b = (*b)[n:]
    return n, nil
}

В примере создается тип Buffer, который является срезом байт (`[]byte`). Методы Write и Read реализованы для добавления данных в буфер и чтения данных из буфера соответственно.

👉 Другое решение можно найти здесь

💬 Как Go обновляет сторонние пакеты?

В Go для управления сторонними пакетами используется инструмент go get или модули Go. В более ранних версиях Go до введения модулей, для установки и обновления сторонних пакетов использовалась команда go get. Она скачивала и устанавливала пакеты из удаленного репозитория в $GOPATH.

С появлением модулей Go (Go 1.11+), использование go get для управления зависимостями стало менее распространенным. Вместо этого, мы можем создать и поддерживать файл go.mod, который описывает зависимости проекта.

Для обновления зависимостей в проекте с модулями Go используется команда go get -u или go get -u=patch для обновления до последней минорной версии или патча соответственно. Это обновление происходит в контексте модульной структуры проекта и сохраняет совместимость версий зависимостей.

По умолчанию Go добавляет последнюю доступную версию пакета. Чтобы проверить, какие еще версии пакета доступны, используется команда go list. По умолчанию она выдает адрес текущего пакета, по которому его можно импортировать.

Чтобы изменить версию конкретного пакета до версии vX.X.X, используется следующая команда:

go get github.com/example/repo@vX.X.X

Обновляем указанные зависимости:

go get -u <package-name>

💬 В чем суть протокола веб-сокет и в чем преимущество Go при работе с веб-сокетами?

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

Горутины в Go более эффективны по сравнению с традиционными потоками операционной системы благодаря меньшему потреблению памяти и более низким накладным расходам на создание и управление ими.

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

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

Это делает Go идеальным выбором для реализации веб-сокет серверов, где требуется эффективная обработка и обмен сообщениями между клиентом и сервером в реальном времени.

🧑‍💻 Статьи для IT: как объяснять и распространять значимые идеи

Напоминаем, что у нас есть бесплатный курс для всех, кто хочет научиться интересно писать — о программировании и в целом.

Что: семь модулей, посвященных написанию, редактированию, иллюстрированию и распространению публикаций.

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

👉Материалы регулярно дополняются, обновляются и корректируются. А еще мы отвечаем на все учебные вопросы в комментариях курса.

💬 Как в Go вернуть из функции ошибку, не импортируя дополнительных пакетов, даже стандартных?

📌 Простой пример:

package main

// CustomError определяет структуру для ошибки
type CustomError struct {
    message string
}

// Error реализует интерфейс error для CustomError
func (e *CustomError) Error() string {
    return e.message
}

// Функция, которая может вернуть ошибку
func divide(a, b float64) (float64, *CustomError) {
    if b == 0 {
        // Создание и возврат ошибки
        return 0, &CustomError{message: "division by zero"}
    }
    return a / b, nil
}

func main() {
    result, err := divide(4, 0)
    if err != nil {
        // Обработка ошибки
        println("Error:", err.Error())
    } else {
        println("Result:", result)
    }
}

🔷 Структура CustomError содержит одно поле message типа string, которое будет хранить сообщение об ошибке.
🔷 Метод Error возвращает сообщение об ошибке. Это позволяет CustomError удовлетворять интерфейсу error.
🔷 Функция принимает два параметра типа float64 и возвращает два значения: результат типа float64 и ошибку типа *CustomError.
🔷 Если второй аргумент b равен нулю, создается и возвращается ошибка с помощью CustomError.
🔷 Результат и ошибка, возвращаемые функцией, проверяются. Если ошибка существует, она обрабатывается (в данном случае выводится на экран с помощью println). Если ошибки нет, выводится результат деления.