Зарегистрируйтесь для доступа к 15+ бесплатным курсам по программированию с тренажером

Очереди Java: Корпоративные приложения на Spring Boot

Config.java

@Configuration
public class RabbitMqConfig {

    // Создаём очередь с именем (топиком) "queue"
    @Bean
    Queue queue() {
        return new Queue("queue", false);
    }

    // Создаём обменник с именем "exchange"
    @Bean
    TopicExchange exchange() {
        return new TopicExchange("exchange");
    }

    // Подключаем очередь с именем (топиком) "queue" к обменнику "exchange"
    // Сообщения с ключом "key" будут направлены в очередь "queue"
    @Bean
    Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("key");
    }
}

Consumer.java

@Component
public class Consumer {

    // Аннотация, которая позволяет прослушивать очередь с указанным именем
    // Когда в очереди появляется сообщение, вызывается отмеченный метод
    @RabbitListener(queues = "queue")
    public void processQueue(String message) {
        // В простейшем случае просто выводим полученное сообщение
        // В общем случае этот сервис может делать с сообщением все, что угодно.
        // Например, можно использовать данные пользователя из сообщения
        // и создавать аккаунт или отправлять пользователю письмо или смс
        // Получатель никак не зависит от отправителя, отправитель сообщения даже не знает,
        // кто и как будет использовать полученное сообщение
        System.out.printl(message);
    }
}

Producer.java

@Component
public class Producer {

    // Класс, который даёт простой доступ к брокеру сообщений RabbitMQ
    // Позволяет отправлять и получать сообщения
    @Autowired
    RabbitTemplate rabbitTemplate;

    // Метод, выполняющий отправку сообщений
    public void sendMessage(String message) {

        // Отправляем сообщение в обменник с ключом "key"
        // В зависимости от ключа, сообщение будет отправлено в нужную очередь
        rabbitTemplate.convertAndSend("exchange", "key", message);
    }
}

Аватары экспертов Хекслета

Остались вопросы? Задайте их в разделе «Обсуждение»

Вам ответят команда поддержки Хекслета или другие студенты.

Для полного доступа к курсу нужен базовый план

Базовый план откроет полный доступ ко всем курсам, упражнениям и урокам Хекслета, проектам и пожизненный доступ к теории пройденных уроков. Подписку можно отменить в любой момент.

Получить доступ
1000
упражнений
2000+
часов теории
3200
тестов

Открыть доступ

Курсы программирования для новичков и опытных разработчиков. Начните обучение бесплатно.

  • 130 курсов, 2000+ часов теории
  • 1000 практических заданий в браузере
  • 360 000 студентов
Отправляя форму, вы принимаете «Соглашение об обработке персональных данных» и соглашаетесь с «Условиями использования»

Наши выпускники работают в компаниях:

Логотип компании Альфа Банк
Логотип компании Aviasales
Логотип компании Yandex
Логотип компании Tinkoff
Рекомендуемые программы

С нуля до разработчика. Возвращаем деньги, если не удалось найти работу.

Иконка программы Java-разработчик
Профессия
с нуля
Разработка приложений на языке Java
1 декабря 10 месяцев

Используйте Хекслет по-максимуму!

  • Задавайте вопросы по уроку
  • Проверяйте знания в квизах
  • Проходите практику прямо в браузере
  • Отслеживайте свой прогресс

Зарегистрируйтесь или войдите в свой аккаунт

Отправляя форму, вы принимаете «Соглашение об обработке персональных данных» и соглашаетесь с «Условиями использования»