1、 本项目使用 IDEA 工具搭建,项目可以直接导入到 eclipse 中,如果使用 eclipse 创建,请自行百度。
2、 首先新建项目。
3、 点击 next
填写自己想要的信息
4、 点击 next
选择箭头选择的
5、 点击 next
6、 点击 finish,等待程序初始化和加载包完成。
pom文件中添加了对activemq的支持
7、 先创建包,出现如下程序结构
8、 创建 ActiveMQ 配置类
9、 创建生产者和消费者
定义生产者:
最终代码结构如下图所示:
10、 Springboot 需要开启调度,生产数据,在 Demo1Application 中添加 @EnableScheduling 注解
11、 现在开始运行程序
12、 程序正常运行
13、 Spring boot 默认 P2P 的模式,启用发布订阅模式,可以在 application.properties 中添加 spring.jms.pub-sub-domain=true
14、 再次运行程序
发布订阅模式已经启用
15、 将 ActiveMQ 配置成单独的服务,连接 ActiveMQ 服务,可以在可以在 application.properties 中添加spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin
16、 重新启动程序
17、 程序正常运行,查看 ActiveMQ 管理后台
已经连接到 ActiveMQ 服务。
18、程序下载
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于