ActiveMQ整合springboot

简介: ActiveMQ整合springboot

1、整合springboot

SpringBoot使用activeMq

Springboot 整合activeMq,使用@jmsListener

activemq与spring整合,配置消费者监听器设置sessionAcknowledgeMode问题

SpringBoot 整合ActiveMq自动重连

  • (1) 添加依赖
  <!-- activemq -->
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-spring</artifactId>
    </dependency>
    <dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-pool</artifactId>
    </dependency>
    <dependency>
      <groupId>org.messaginghub</groupId>
      <artifactId>pooled-jms</artifactId>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>

(2) application.yml

server:
  port: 8080 #springBoot项目访问端口
spring:
  activemq:
    broker-url: tcp://192.168.31.43:61616  #你activeMQ的ip和端口号
    user: admin   #activeMq账号
    password: admin #activeMq密码
    queue-name: active.queue #队列名
    pool:
      enabled: true       #连接池启动
      max-connections: 10 #最大连接数

或者application.properties

#mq
spring.activemq.broker-url=tcp://${ACTIVEMQ_HOST}:${ACTIVEMQ_PORT}?jms.prefetchPolicy.queuePrefetch=5
spring.activemq.close-timeout=5000ms
spring.activemq.in-memory=false
spring.activemq.pool.enabled=true
spring.jms.pub-sub-domain=true
spring.activemq.pool.max-connections=10
spring.activemq.send-timeout=3000ms

(3) 在SpringBoot的启动类,类上添加注解@EnableJms


2、自定义JmsListenerContainerFactory时,containerFactory字段的理解

自定义JmsListenerContainerFactory时,containerFactory字段的理解


3、SpringBoot消息源码:JmsListener注解解析

SpringBoot消息源码:JmsListener注解解析

相关文章
|
2月前
|
消息中间件 Java Kafka
SpringBoot实用开发篇第六章(整合第三方技术,ActiveMQ,RabbitMQ,RocketMQ,Kafka)
SpringBoot实用开发篇第六章(整合第三方技术,ActiveMQ,RabbitMQ,RocketMQ,Kafka)
|
2月前
|
消息中间件 监控 Java
使用Spring Boot结合ActiveMQ和MQTT实现消息的发送和接收
使用Spring Boot结合ActiveMQ和MQTT实现消息的发送和接收
212 3
|
1月前
|
消息中间件 Java Apache
使用Spring Boot实现与ActiveMQ的消息队列集成
使用Spring Boot实现与ActiveMQ的消息队列集成
|
消息中间件 Java
springboot整合ActiveMQ(点对点+发布订阅)
springboot整合ActiveMQ(点对点+发布订阅)
|
3月前
|
消息中间件 XML Java
SpringBoot2.0整合ActiveMQ
SpringBoot2.0整合ActiveMQ
58 2
|
3月前
|
消息中间件 Java
SpringBoot使用ActiveMq同时支持点对点推送和发布订阅
SpringBoot使用ActiveMq同时支持点对点推送和发布订阅
28 0
|
3月前
|
消息中间件 Java Kafka
SpringBoot整合 ActiveMQ快速入门 实现点对点推送
SpringBoot整合 ActiveMQ快速入门 实现点对点推送
47 0
|
10月前
|
消息中间件 Java 测试技术
53分布式电商项目 - Spring集成ActiveMQ
53分布式电商项目 - Spring集成ActiveMQ
25 0
|
消息中间件 Java Maven
Spring + activeMQ整合,并写了一个简单的小栗子
Spring + activeMQ整合,并写了一个简单的小栗子
86 0
|
消息中间件 缓存 NoSQL
Spring Boot+MyBatis+Redis+ActiveMQ+MySQL+Thymeleaf实现简单的高并发点赞功能(下)
Spring Boot+MyBatis+Redis+ActiveMQ+MySQL+Thymeleaf实现简单的高并发点赞功能(下)
338 0
Spring Boot+MyBatis+Redis+ActiveMQ+MySQL+Thymeleaf实现简单的高并发点赞功能(下)