activemq部署linux

sudo apt update
sudo apt install openjdk-11-jdk

wget https://archive.apache.org/dist/activemq/5.16.3/apache-activemq-5.16.3-bin.tar.gz
tar -xvzf apache-activemq-5.16.3-bin.tar.gz
cd apache-activemq-5.16.3

./bin/activemq start

import javax.jms.*;

public class Producer {
    public static void main(String[] args) throws JMSException {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("TEST.QUEUE");

        MessageProducer producer = session.createProducer(destination);
        TextMessage message = session.createTextMessage("Hello, World!");
        producer.send(message);

        connection.close();
    }
}

import javax.jms.*;

public class Consumer {
    public static void main(String[] args) throws JMSException {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("TEST.QUEUE");

        MessageConsumer consumer = session.createConsumer(destination);
        Message message = consumer.receive(1000);

        if (message instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) message;
            System.out.println("Received: " + textMessage.getText());
        }

        connection.close();
    }
}