Перейти на PRO

Что такое JMS и как его использовать в Java?

Тип вопроса: Брокеры сообщений Вероятность: 10% Категория: Java Разработчик

Ответ

JMS (Java Message Service) — это стандартное Java API для асинхронного обмена сообщениями между приложениями или компонентами в рамках системы (Message-Oriented Middleware).

Основные модели обмена:

  1. Очереди (Point-to-Point): Сообщение отправляется в конкретную очередь и доставляется одному потребителю.
  2. Топики (Publish/Subscribe): Сообщение публикуется в топик и доставляется всем активным подписчикам.

Ключевые интерфейсы JMS:

  • ConnectionFactory — фабрика для создания соединений с брокером (ActiveMQ, IBM MQ, etc.).
  • Connection — активное соединение с сервером JMS.
  • Session — контекст для создания и получения сообщений, может быть транзакционным.
  • Destination — адресат сообщения (Queue или Topic).
  • MessageProducer / MessageConsumer — для отправки и приема сообщений.

Пример отправки сообщения в очередь:

import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

public class JmsProducer {
    public static void main(String[] args) throws JMSException {
        // 1. Создание фабрики соединений
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        // 2. Установка соединения и запуск
        Connection connection = factory.createConnection();
        connection.start();
        // 3. Создание сессии (не транзакционная, авто-подтверждение)
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 4. Создание очереди назначения
        Queue queue = session.createQueue("ORDER.QUEUE");
        // 5. Создание отправителя
        MessageProducer producer = session.createProducer(queue);
        // 6. Создание и отправка текстового сообщения
        TextMessage message = session.createTextMessage("New order #12345");
        producer.send(message);
        System.out.println("Message sent: " + message.getText());
        // 7. Закрытие ресурсов
        session.close();
        connection.close();
    }
}

Практическое применение:

  • Развязка сервисов: Микросервисы общаются через очереди, не зная друг о друге.
  • Гарантированная доставка: Сообщения сохраняются брокером до получения.
  • Асинхронная обработка: Отправитель не блокируется, ожидая ответа.
  • Масштабирование: Можно запускать несколько экземпляров потребителей для одной очереди (конкурентные потребители).

Ответ 18+ 🔞

А, слушай, смотри, вот эта ваша JMS, блядь! Ну, внатуре, как почтальон между твоими программами, только не сосёт, а реально работает. Суть проще, чем кажется, ёпта.

Представь, есть два способа перепихнуться сообщениями, как в жизни, блядь:

  1. Очереди (Point-to-Point). Это как пиздюлей передать конкретному челу. Кинул записку в его личный ящик (очередь) — он один её и получит. Больше никто, даже если там сто мудаков стоят и ждут. Его личная пиздюлина.
  2. Топики (Publish/Subscribe). А это уже как орать на всю деревню через рупор. Крикнул в топик — и все, кто уши к нему приложил (подписался), услышат. Вещание, блядь, массовое.

А теперь главные герои этой пьесы, интерфейсы, на которых всё держится:

  • ConnectionFactory — это, сука, проходная на завод. Через неё ты получаешь пропуск (соединение) к брокеру, типа ActiveMQ.
  • Connection — сам пропуск, активная жила к серверу.
  • Session — твой рабочий кабинет внутри. В нём ты и создаёшь сообщения, и получаешь. Можешь даже бардак устроить (транзакцию), а потом всё откатить, если что.
  • Destination — адрес, куда слать: либо ящик (Queue), либо рупор (Topic).
  • MessageProducer / MessageConsumer — это уже твои руки. Один — чтобы швырять, другой — чтобы ловить.

Вот, смотри, как накодить отправку, чтобы было понятно даже мартышке:

import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;

public class JmsProducer {
    public static void main(String[] args) throws JMSException {
        // 1. Берём пропускную систему (фабрику) для нашего брокера
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        // 2. Получаем живой пропуск и прёмываемся внутрь
        Connection connection = factory.createConnection();
        connection.start();
        // 3. Занимаем кабинет (сессию). Без транзакций, подтверждения — автоматом.
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        // 4. Находим тот самый ящик "ORDER.QUEUE", куда будем совать
        Queue queue = session.createQueue("ORDER.QUEUE");
        // 5. Назначаем ответственного за кидание (производителя)
        MessageProducer producer = session.createProducer(queue);
        // 6. Пишем записку и хуяк — в ящик!
        TextMessage message = session.createTextMessage("New order #12345");
        producer.send(message);
        System.out.println("Message sent: " + message.getText());
        // 7. Уходим, гасим свет, закрываем всё за собой. Не как свинья.
        session.close();
        connection.close();
    }
}

А где это, блядь, в жизни пригождается? Да везде, сука!

  • Развязал сервисы, и живи спокойно. Один микросервис плюнул сообщение в очередь и пошёл дальше пить кофе. Другой его когда-нибудь возьмёт и обработает. Они друг про друга нихуя не знают и знать не хотят — идеальные отношения.
  • Гарантия, что не потеряется. Брокер — он как ответственный курьер, ёбаный в рот. Сохранит сообщение, пока получатель не распишется в получении пиздюлей.
  • Не жди ответа, свободен! Отправил и пошёл делать другие дела. Асинхронность, блядь, мать её.
  • Масштабируйся, как хочешь. Если очередь забивается — запускай ещё таких же потребителей, пусть пашут. Конкурентные потребители, ёпта!

Вот и вся магия. Не rocket science, а просто удобная хуйня, чтобы системы между собой не как идиоты по HTTP синхронно дёргались, а по-взрослому, через посредника, общались.

© ХакСобесов, 2026
support@hacksobesov.com