`

ActiveMQ持久化存储

阅读更多
  activeMQ的消息可以存储在不同的存储中,(默认是kahaDB,levelDB,mysql,oracle)
1、配置数据库连接
  C:\M\apache-activemq-5.14.1\confactivemq.xml添加数据库连接数据。
  1、1替换数据库连接
  
 <persistenceAdapter>
		    <jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#mysqlDB"/> 
            <!--<kahaDB directory="${activemq.data}/kahadb"/>-->
        </persistenceAdapter>
   


   1、2增加连接数据库信息
  
<bean id="mysqlDB" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
		<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
		<property name="url" value="jdbc:mysql://localhost/test?relaxAutoCommit=true"/>
		<property name="username" value="root"/>
		<property name="password" value="root"/>
		<property name="maxActive" value="200"/>
		<property name="poolPreparedStatements" value="true"/>
	  </bean>
   




2、增加连接数据jar文件至MQ引用文件夹
   下载commons-dbcp.jar,commons-pool.jar,mysql-onnector-java.jar三个文件
   复制jar文件到C:\M\apache-activemq-5.14.1\lib文件夹

3、启动mq结果



  • 大小: 34.6 KB
  • 大小: 121.1 KB
分享到:
评论

相关推荐

    ActiveMQ知识点汇总.pdf

    整理了ActiveMQ消息队列的相关内容,主要包括MQ的安装与配置、构建过程、JMS规范和落地产品、MQ的传输协议、消息存储和持久化以及多借点集群的搭建等内容

    ActiveMQ.pdf

    整理最新的ActiveMQ笔记,消息中间件是解决的问题是能够解耦、能够削峰、能够异步处理,包含整合SpringBoot等、消息存储和持久化、多节点集群的使用、面试遇到和注意的问题等。

    ActiveMQ.rar

    包括:独有消费者、消息异步分发、消息优先级、管理持久化消息、消息分组、 消息选择器、消息重递策略、慢消费者处理等 n 十三:杂项技术 包括:监控和管理Broker、集成ActiveMQ和Tomcat、什么时候使用ActiveMQ等 n ...

    实战ActiveMQ集群与应用视频教程.zip

    网盘文件永久链接 1:ActiveMQ入门和消息中间件 2:JMS基本概念和模型 3:JMS的可靠性机制 4:JMS的API结构和开发步骤 ...8:ActiveMQ消息存储持久化 9:ActiveMQ的静态网络链接 10:多线程consumer访问集群 ..........

    java实现的消息中间件之AcitveMQ详解,学习学习

    KahaDB存储 KahaDB他是默认的持久化策略,...LevelDB持久化的性能高于KahaDB,但是在ActiveMQ官网对LevelDB的表述:LevelDB官方建议使用以及不再支持,推荐使用的是KahaDB 可以看到已经不在支持此项了。推荐使用KahaDB

    springCloudAlibaba架构完整Demo

    限流降级规则持久化以及熔断规则根据feign配置自动生成;elasticJob分布式调度(支持分布式计算);springBootAdmin实现;商品详情页面根据模板引擎自动生成静态文件(CDN加速支持);activemq、rabbitmq、rocketmq、...

    Java思维导图xmind文件+导出图片

    图解Redis中的AOF和RDB持久化策略的原理 redis读写分离架构实践 redis哨兵架构及数据丢失问题分析 redis Cluster数据分布算法之Hash slot redis使用常见问题及性能优化思路 redis高可用及高并发实战 缓存击穿...

    word源码java-springboot-study:Springboot内部培训文档,集成所有第三方组件

    C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。 MongoDB:MongoDB是一个基于分布式文件存储的NO-SQL型数据库。 ActiveMQ:ActiveMQ 是Apache出品,能力强劲的开源消息...

    Redis:Redis代码

    Redis真的那么好用吗? 一、Redis是什么? Redis是一个开源的底层使用C语言...持久化数据访问较慢、 用key查询 2、消息队列 相当于消息订阅系统,比如ActiveMQ、RocketMQ。如果对数据有较高一致性要求时,还是建议使用

    大型分布式网站架构与实践

     2.2 持久化存储 71  2.2.1 MySQL扩展 72  2.2.2 HBase 80  2.2.3 Redis 91  2.3 消息系统 95  2.3.1 ActiveMQ & JMS 96  2.4 垂直化搜索引擎 104  2.4.1 Lucene简介 105  2.4.2 Lucene的使用 108  2.4.3 ...

    meetup:微服务探索

    users-handler-实现CQRS的Command部分,并使用h2数据库进行持久化。 这些服务通过Apache ActiveMQ提供的JMS总线进行通信。 更详细的设计文档可。 先决条件 安装Docker Machine并撰写: : 生成并运行 git克隆 cd...

    java面试题,180多页,绝对良心制作,欢迎点评,涵盖各种知识点,排版优美,阅读舒心

    【消息队列】持久化消息非常慢 162 【消息队列】消息的不均匀消费 162 【消息队列】ActiveMQ中的消息重发时间间隔和重发次数吗? 164 【Dubbo】dubbo介绍 166 Dubbo 是什么 166 Dubbo 架构流程图 167 调用流程 167 ...

    【白雪红叶】JAVA学习技术栈梳理思维导图.xmind

    存储引擎 索引 锁 oracle db2 缓存 redis 数据结构 持久 复制 cas 单线程 memcache eacache Tair 消息队列 jms Queue Topic kafka 持久 复制 Stream Partition rocketMQ RabbitMQ ...

    网络架构师148讲视频课程

    │ 第78节:ActiveMQ消息存储持久化.avi │ 第79节:ActiveMQ的静态网络链接.avi │ 第80节:多线程consumer访问集群.avi │ 第81节:集群下的消息回流功能.avi │ 第82节:容错的链接和动态网络连接.avi │ 第83节...

    java开源包1

    Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...

    java开源包11

    Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...

    java开源包2

    Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...

    java开源包3

    Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...

    java开源包6

    Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...

    java开源包5

    Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...

Global site tag (gtag.js) - Google Analytics