Foundation of ActiveMQ

One 、 install

Portal ：ActiveMQ

And JDK Corresponding version , Otherwise, an error will be reported

 ActiveMQ The correct startup of requires installation jdk

jdk Installation documentation for ：

linux install jdk8_ Last d Light language blog -CSDN Blog _linux install jdk

 Unpack the command  ：tar -zxvf apache-activemq-5.16.5-bin.tar.gz
 Get into bin Catalog  ： cd apache-activemq-5.16.5/bin/
 start-up ActiveMQ ： ./activemq start

Launch success screen ：

activemq The default port number is ：61616 , The port number for external access is ：ip:8161/admin/

account number ：admin

password ：admin

cannot access activemq Console solution ：

Portal ： cannot access activemq Of 8161 Console _WHJwhj552200 The blog of -CSDN Blog _activemq The console cannot be accessed

  Attention to detail ： Need to restart activemq

Click on Queues You can view the message queue

  Two 、SpringBoot Integrate ActiveMQ test

① Import dependence , The downloaded version will be introduced into that version

<!-- activemq  rely on  -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

② The configuration file

server:
  port: 8001
spring:
  application:
    name: activemq
  activemq:
    broker-url: tcp://xxx.xxx.xxx.xxx:61616
    user: admin
    password: admin
  jms:
    pub-sub-domain: false # Configure whether it is in publish subscribe mode , Default false For point-to-point mode 

③ Point to point mode

Generator message sending ：

  Consumer message acceptance ：

// Inject IOC Containers 
@Component
public class ActivemqListener {
 
    // Set up queue Destination , Same as the previously configured destinationName bring into correspondence with 
    @JmsListener(destination = "test-queue")
    public void receiveMsg(Message message) throws JMSException {
 
        // Because the message we send is of string type , So here we judge and filter the types 
        if(message instanceof TextMessage){
            
            // Forced to TextMessage
            TextMessage textMessage = (TextMessage) message;
 
            System.out.println(textMessage.getText());
        }
    }
}

  Last , Start the startup class , That is, you can send it point-to-point , Receive messages sent by producers ！

④ Publish subscribe

Modify the configuration

  producer

consumer  

Because this is a release - A subscription model , So we must first run consumers , After the consumer successfully starts , Restart producer