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

1. Отправка сообщений.
   ActiveMQ предоставляет различные методы отправки сообщений в очередь или тему. Вот пример использования API службы сообщений Java (JMS):

import javax.jms.*;
public class MessageSender {
    public void sendMessage() {
        try {
            // Create a connection factory
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            // Create a connection
            Connection connection = connectionFactory.createConnection();
            connection.start();
            // Create a session
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // Create a destination (queue or topic)
            Destination destination = session.createQueue("myQueue");
            // Create a message producer
            MessageProducer producer = session.createProducer(destination);
            // Create a text message
            TextMessage message = session.createTextMessage("Hello, ActiveMQ!");
            // Send the message
            producer.send(message);
            // Clean up resources
            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

2. Получение сообщений.
   ActiveMQ предоставляет несколько методов для получения сообщений из очереди или темы. Вот пример потребителя сообщения, использующего JMS:

import javax.jms.*;
public class MessageReceiver {
    public void receiveMessage() {
        try {
            // Create a connection factory
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            // Create a connection
            Connection connection = connectionFactory.createConnection();
            connection.start();
            // Create a session
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // Create a destination (queue or topic)
            Destination destination = session.createQueue("myQueue");
            // Create a message consumer
            MessageConsumer consumer = session.createConsumer(destination);
            // Start listening for messages
            consumer.setMessageListener(new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    if (message instanceof TextMessage) {
                        try {
                            String text = ((TextMessage) message).getText();
                            System.out.println("Received: " + text);
                        } catch (JMSException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
            // Wait for messages
            Thread.sleep(5000);
            // Clean up resources
            consumer.close();
            session.close();
            connection.close();
        } catch (JMSException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

3. Сохранение сообщений:
   ActiveMQ позволяет сохранять сообщения, чтобы обеспечить надежную доставку даже в случае сбоев системы. Вот пример настройки сохранения сообщений:

import javax.jms.*;
public class MessagePersistenceExample {
    public void sendMessageWithPersistence() {
        try {
            // Create a connection factory
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            // Create a connection
            Connection connection = connectionFactory.createConnection();
            connection.start();
            // Create a session with message persistence enabled
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Destination destination = session.createQueue("myQueue");
            // Create a message producer with delivery mode set to persistent
            MessageProducer producer = session.createProducer(destination);
            producer.setDeliveryMode(DeliveryMode.PERSISTENT);
            // Create and send a message
            TextMessage message = session.createTextMessage("Hello, ActiveMQ with Persistence!");
            producer.send(message);
            // Clean up resources
            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

4. Фильтрация сообщений:
   ActiveMQ предоставляет механизмы фильтрации для выборочного получения сообщений на основе определенных критериев. Вот пример использования селекторов сообщений:

import javax.jms.*;
public class MessageFilteringExample {
    public void receiveFilteredMessages() {
        try {
            // Create a connection factory
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            // Create a connection
            Connection connection = connectionFactory.createConnection();
            connection.start();
            // Create a session
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // Create a destination (queue or topic)
            Destination destination = session.createQueue("myQueue");
            // Create a message consumer with a selector
            MessageConsumer consumer = session.createConsumer(destination, "color = 'red'");
            // Start listening for messages
            consumer.setMessageListener(new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    if (message instanceof TextMessage) {
                        try {
                            String text = ((TextMessage) message).getText();
                            System.out.println("Received: " + text);
                        } catch (JMSException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
            // Wait for messages
            Thread.sleep(5000);
            // Clean up resources
            consumer.close();
            session.close();
            connection.close();
        } catch (JMSException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

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