golang async message processing

async_message.go

package main

import (
    "fmt"
    "time"
)

type MessageProcessor struct {
    sendChannel    chan<- string // Канал для отправки сообщений
    receiveChannel <-chan string // Канал для приема сообщений
}

func main() {
    // Создаем каналы для отправки и приема сообщений
    sendChannel := make(chan string)
    receiveChannel := make(chan string)

    // Создаем экземпляр структуры MessageProcessor
    processor := MessageProcessor{
        sendChannel:    sendChannel,
        receiveChannel: receiveChannel,
    }

    // Запускаем горутину для асинхронной обработки сообщений
    go processor.processMessages()

    // Отправляем сообщения в канал отправки
    processor.sendChannel <- "Сообщение 1"
    processor.sendChannel <- "Сообщение 2"
    processor.sendChannel <- "Сообщение 3"

    // Ждем некоторое время, чтобы обработчик успел обработать все сообщения
    time.Sleep(2 * time.Second)

    // Закрываем каналы
    close(sendChannel)
    close(receiveChannel)
}

func (mp *MessageProcessor) processMessages() {
    // Бесконечный цикл для обработки сообщений из канала приема
    for message := range mp.receiveChannel {
        // Обрабатываем сообщение
        fmt.Println("Обработка сообщения:", message)

        // Имитируем обработку сообщения
        time.Sleep(1 * time.Second)
    }
}