Springboot -ActiveMQ中Qunue模式使用

柔光的暖阳◎ 2022-04-08 10:26 152阅读 0赞

## 下载 ##

官方网站 [http://activemq.apache.org/][http_activemq.apache.org]

Windows版本  
[https://archive.apache.org/dist/activemq/5.12.0/apache-activemq-5.12.0-bin.zip][https_archive.apache.org_dist_activemq_5.12.0_apache-activemq-5.12.0-bin.zip]

Linux 版  
[https://archive.apache.org/dist/activemq/5.12.0/apache-activemq-5.12.0-bin.tar.gz][https_archive.apache.org_dist_activemq_5.12.0_apache-activemq-5.12.0-bin.tar.gz]

安装直接解压即可  
在bin 目录下 输入命令 ./activemq start 即可启动

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70]

登陆 ActiveMQ 监控平台  
[http://localhost:8161/admin/][http_localhost_8161_admin] username 和 password都为 admin（登陆密码可以在conf/user.properties中配置）  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70 1]

## springboot整合使用 ##

(1)导入依赖

org.springframework.boot spring-boot-starter-activemq

(2)添加application配置  
spring.jms.pub-sub-domain= \# 配置消息的类型，如果是true则表示为topic消息，如果为false表示Queue消息  
spring.activemq.broker-url= \#指定ActiveMQ broker的URL  
spring.activemq.in-memory= \#是否是内存模式，默认为true  
spring.activemq.packages.trust-all= \#信任所有包，传输自定义对象时需要设置为true

Springboot启动类上加 注解

(3)传输对象时，对象需要实现序列化接口

## 生产者 ##

注入 JmsMessagingTemplate  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70 2]

## 消费者 ##

在消费的方法上打上@JmsListener(destination =”queueName”) 注解  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70 3]

[http_activemq.apache.org]: http://activemq.apache.org/
[https_archive.apache.org_dist_activemq_5.12.0_apache-activemq-5.12.0-bin.zip]: https://archive.apache.org/dist/activemq/5.12.0/apache-activemq-5.12.0-bin.zip
[https_archive.apache.org_dist_activemq_5.12.0_apache-activemq-5.12.0-bin.tar.gz]: https://archive.apache.org/dist/activemq/5.12.0/apache-activemq-5.12.0-bin.tar.gz
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70]: /images/20220406/856a8331b7834809a9f839054b610dd5.png
[http_localhost_8161_admin]: http://localhost:8161/admin/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70 1]: /images/20220406/6dd3e0a5d110436998256d7192b260f7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70 2]: /images/20220406/bb04e30942cd4f7ab46273cc35581114.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zOTE1MzIxMA_size_16_color_FFFFFF_t_70 3]: /images/20220406/6191364365f54129891753d78710b77b.png