springboot集成activemq的实例代码
ActiveMQ ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。 特性
更多关于 ActiveMQ 的内容可以点击这里。 Spring-Boot 集成 ActiveMQ 添加maven依赖 <!-- <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> --> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-client</artifactId> </dependency> 没有直接使用注释的依赖,是因为其含有如下依赖 <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-broker</artifactId> </dependency> 而它的作用是什么呢,会在程序中直接内嵌 ActivityMQ,也就是说不需要安装 ActiveMQ,但是这个如果服务宕机了,内嵌的 ActiveMQ 也就没了。关键,这个内嵌的 ActiveMQ 而无法看到图形化界面,所以这里没有直接使用注释里的依赖。 在application.properties中增加如下配置 # activemq spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.user=admin spring.activemq.password=admin spring.activemq.in-memory=true spring.activemq.pool.enabled=false 这里对 ActiveMQ 的端口做一个简短说明,61616为消息代理接口 ,8161 为管理界面 JAVA代码实现 定义QUEUE package com.activemq.queue; import org.apache.activemq.command.ActiveMQQueue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import javax.jms.Queue; @Configuration public class QueueConfig { @Bean public Queue logQueue() { return new ActiveMQQueue(QueueName.LOG_QUEUE); } } 消息生产者 package com.activemq.producer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.jms.core.JmsMessagingTemplate; import org.springframework.stereotype.Component; import javax.jms.Queue; @Component public class LogProducer implements CommandLineRunner { private static final Logger LOGGER = LoggerFactory.getLogger(LogProducer.class); @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @Autowired private Queue logQueue; @Override public void run(String... strings) throws Exception { send("This is a log message."); LOGGER.info("Log Message was sent to the Queue named sample.log"); } public void send(String msg) { this.jmsMessagingTemplate.convertAndSend(this.logQueue,msg); } } 消息消费者 package com.activemq.consumer; import com.activemq.queue.QueueName; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component; @Component public class LogConsumer { private static final Logger LOGGER = LoggerFactory.getLogger(LogConsumer.class); @JmsListener(destination = QueueName.LOG_QUEUE) public void receivedQueue(String msg) { LOGGER.info("Has received from " + QueueName.LOG_QUEUE + ",msg: " + msg); } } 测试接口 @Autowired private LogProducer logProducer; @GetMapping("/activemq/send") public String activemq(HttpServletRequest request,String msg) { msg = StringUtils.isEmpty(msg) ? "This is Empty Msg." : msg; try { logProducer.send(msg); } catch (Exception e) { e.printStackTrace(); } return "Activemq has sent OK."; } 启动类 增加如下注解@EnableJms @Configuration//配置控制 @EnableAutoConfiguration//启用自动配置 @ComponentScan//组件扫描 @EnableConfigurationProperties({EmailProp.class}) @EnableJms public class Bootstrap { private static final Logger LOGGER = LoggerFactory .getLogger(Bootstrap.class); public static void main(String[] args) throws Exception { SpringApplication.run(Bootstrap.class,args); LOGGER.info("Server running..."); } } 测试 运行服务,在浏览器输入 http://127.0.0.1:8080/activemq/send?msg=test%20log,会在控制台看到如下输出 INFO 1498 --- [enerContainer-1] c.j.a.activemq.consumer.LogConsumer : Has received from sample.log,msg: test log [DefaultMessageListenerContainer-1] INFO c.j.a.activemq.consumer.LogConsumer - Has received from sample.log,msg: test log 打开 ActiveMQ 的管理页面,用户名密码都是admin,可以看到如下信息 官方示例:https://github.com/spring-projects/spring-boot/blob/master/spring-boot-samples/spring-boot-sample-activemq 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程小技巧。 您可能感兴趣的文章:
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
- java – Spring Boot扩展CrudRepository
- 如何在Java中组合两个ResultSet?
- 我应该使用什么java库进行图像裁剪/ letterboxing?
- java – Kryo crash EnvironmentFailureException
- 在循环中执行插入时javax.persistence.TransactionRequired
- Java 关于eclipse导入项目发生的问题及解决方法(推荐)
- JavaWeb文件上传下载功能示例解析
- java – JIT自动内联的方法大小是多少?
- java – 数组偶数和奇数排序
- java – 如何将字符串HH:MM转换为Joda持续时间?