maven项目的创建

1. 新建工程

maven项目的创建.mdmaven项目的创建.mdmaven项目的创建.md

2. 引入依赖

maven项目的创建.mdmaven项目的创建.md

3. 编写测试类

maven项目的创建.mdmaven项目的创建.mdmaven项目的创建.md添加客户端手动应答,需要将内部类也需要改造。
maven项目的创建.md

4. 编写测试类(消息持久化订阅到文件)

  1. 建类
    maven项目的创建.md
  2. 将生产者和消费者都黏贴过来

消费者改为“自动应答”

当生产者先发布消息,消费者后接收消息时,消费者接收不到消息,此时需要进行消息持久化订阅到文件

  1. 修改本地ActiveMQ的配置文件activemq.xml文件【持久化到文件】
    maven项目的创建.md
    可以看一下刚安装的时候有没有这个文件“data->kahadb”

  2. 修改消息持久化订阅的java类
    maven项目的创建.md5. 完毕(持久化到文件)

5. 编写测试类(消息持久化到MySQL)

  1. 将MySQL的数据库驱动复制到ActiveMQ的lib目录下。
  2. 在${activemq.base}/conf/activemq.xml文件中配置持久化配置器
    maven项目的创建.md
<persistenceAdapter>
    	<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#derby-ds"/>
</persistenceAdapter>
  1. 在${activemq.base}/conf/activemq.xml文件中配置数据源
    maven项目的创建.md
<bean id="derby-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">

maven项目的创建.md

相关文章:

  • 2021-11-20
  • 2021-09-12
  • 2021-07-09
  • 2022-01-25
猜你喜欢
  • 2021-07-02
  • 2021-06-19
  • 2021-12-28
  • 2021-08-16
  • 2021-09-21
  • 2021-07-08
相关资源
相似解决方案