ActiveMQ 的安装与使用(springboot版本)

Posted 大佬健

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ActiveMQ 的安装与使用(springboot版本)相关的知识,希望对你有一定的参考价值。

一、安装

上官网下载tar包

http://activemq.apache.org/

tar -zxvf 后进入bin/linux-86-64

./activimq start

启动

 

二、使用

 

pom文件引入依赖

 

<dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.47</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-pool</artifactId>
        </dependency>
        <dependency>

 

 

application.properties的配置文件

spring.activemq.broker-url=tcp://39.108.83.105:61616
#spring.activemq.broker-url=tcp://127.0.0.1:61616
spring.activemq.user=
spring.activemq.password=
spring.activemq.pool.enabled=true
spring.activemq.pool.max-connections=50
spring.activemq.pool.expiry-timeout=10000
spring.activemq.pool.idle-timeout=30000

#主题类型消息这个为true
spring.jms.pub-sub-domain=true

 

生产者代码:

@Component
public class JMSProducer {

    @Autowired
    private JmsTemplate jmsTemplate;

    public void sendMessage(Destination destination, String message) {
        this.jmsTemplate.convertAndSend(destination,message);
    }
}

 

消费者代码:

@Component
public class JMSConsumer {

    @JmsListener(destination = "myTopic")
    public void receiveQueue(String msg) {
        System.out.println(msg);
    }
}

 

调用类:

    @PostMapping("/postTopic")
    public String postTopic(@RequestBody JSONObject reqBody){
        ActiveMQTopic myTopic = new ActiveMQTopic("myTopic");
        jmsProducer.sendMessage(myTopic,reqBody.toJSONString());
        return "成功";
    }

 

以上是关于ActiveMQ 的安装与使用(springboot版本)的主要内容,如果未能解决你的问题,请参考以下文章

ActiveMQ 的安装与使用(单节点)

烂泥:ActiveMQ的集群安装与配置

烂泥:ActiveMQ的安装与配置

php ActiveMQ的安装与使用

分布式架构学习之:015--ActiveMQ 的安装与使用(单节点)

ActiveMQ 的安装与使用(springboot版本)