Какие знаешь способы взаимодействия между процессами?

Способы взаимодействия между процессами в Go

В Go, как и в других системах, взаимодействие между процессами (IPC, Inter-Process Communication) можно реализовать несколькими способами, каждый из которых подходит для разных сценариев. Основные методы включают использование системных вызовов, сетевых протоколов и специализированных библиотек.

1. Сетевые методы (TCP/IP, HTTP, gRPC)

Это наиболее универсальный способ, особенно для процессов на разных машинах.

TCP/IP сокеты

Прямое взаимодействие через сетевые сокеты.

// Пример сервера
conn, err := net.Listen("tcp", ":8080")
// Пример клиента
conn, err := net.Dial("tcp", "localhost:8080")

HTTP/REST API

Стандартный подход для веб-сервисов.

// Использование net/http
http.HandleFunc("/endpoint", handler)
http.ListenAndServe(":8080", nil)

gRPC

Высокоэффективный протокол на основе Protocol Buffers.

// Определение сервиса в .proto файле, генерация кода
server := grpc.NewServer()
lis, _ := net.Listen("tcp", ":50051")
server.Serve(lis)

2. Системные IPC механизмы (Unix/Linux)

Для процессов на одной машине подходят низкоуровневые методы.

Unix Domain Sockets (UDS)

Более быстрые, чем TCP, и работают только локально.

conn, err := net.Listen("unix", "/tmp/socket.sock")

Сигналы (Signals)

Для простых событий (завершение, перезапуск).

signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)

Память, разделяемая между процессами (Shared Memory)

В Go обычно используется через системные вызовы или специализированные библиотеки (например, mmap). Не является стандартной практикой в Go из-за сложности управления.

3. Каналы (Channels) и файлы

Более простые, но ограниченные методы.

Файлы

Чтение/запись в файлы или директории (например, для логов или конфигурации).

data, err := os.ReadFile("/tmp/data.txt")

Каналы (Pipe)

Коммуникация через стандартные pipe (например, stdin/stdout).

cmd := exec.Command("another_process")
stdin, _ := cmd.StdinPipe()
stdin.Write([]byte("data"))

4. Сообщения и очереди (Message Queues)

Для сложных сценариев с асинхронной коммуникацией.

Очереди сообщений (MQ)

Внешние системы: RabbitMQ, Kafka, NATS.

// Пример с NATS
nc, _ := nats.Connect(nats.DefaultURL)
nc.Publish("subject", []byte("message"))

5. RPC через стандартные библиотеки

Go предоставляет собственные RPC реализации.

net/rpc (стандартный RPC)

Устаревший, но простой метод для внутренней коммуникации.

rpc.Register(&Service{})
rpc.HandleHTTP()
http.ListenAndServe(":8080", nil)

Выбор метода в Go

При выборе метода IPC в Go стоит учитывать:

• Локацию процессов: локальные (UDS, сигналы) vs удаленные (TCP, HTTP).
• Производительность: gRPC и UDS обычно быстрее HTTP.
• Сложность реализации: net/http проще, чем низкоуровневые сокеты.
• Асинхронность: очереди сообщений для декапсуляции процессов.
• Стандарты экосистемы: в микросервисах чаще используют gRPC или HTTP.

На практике в современных Go-приложениях чаще всего применяют HTTP/REST для публичных API и gRPC для внутренней коммуникации между сервисами. Для локальных процессов на Unix-системах могут использовать Unix Domain Sockets для максимальной скорости. Важно также помнить о безопасности (аутентификация, TLS) и надежности (таймауты, повторные попытки) при реализации IPC.