java springboot 消息中间件 ActiveMQ

引入依赖

在pom.xml中引入依赖spring-boot-starter-activemq

生产者（producer) 和 消费者（consumer）都会用到的代码

// 1.获取连接工厂
ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");

// 2.创建连接对象
Connnection connection = factory.createConnection();

// 3.启动连接
connection.start();

// 4.创建会话
Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

// 5.创建消息类型（主题或者队列）
Destination destination = session.createQueue("queue_style");
Destination destination = session.createTopic("Topic_style");

生产者（producer)

// 创建生产者
MessageProducer producer = session.createProducer(destination);

// 创建消息
TextMessage textMessage = session.createTextMessage("来自生产者创建的消息");

// 生产者发送消息
producer.send(textMessage);

消费者（consumer）

// 创建消费者
MessageConsumer consumer = session.createConsumer(destination);

// 为消费者设置监听器
consumer.setMessageListener(new MessageListener() {
            @Override
            public void onMessage(Message message) {
        // 消费者接收的消息对象
                TextMessage textMessage = (TextMessage) message;
            }