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消息队列的相关内容,主要包括MQ的安装与配置、构建过程、JMS规范和落地产品、MQ的传输协议、消息存储和持久化以及多借点集群的搭建等内容
整理最新的ActiveMQ笔记,消息中间件是解决的问题是能够解耦、能够削峰、能够异步处理,包含整合SpringBoot等、消息存储和持久化、多节点集群的使用、面试遇到和注意的问题等。
包括:独有消费者、消息异步分发、消息优先级、管理持久化消息、消息分组、 消息选择器、消息重递策略、慢消费者处理等 n 十三:杂项技术 包括:监控和管理Broker、集成ActiveMQ和Tomcat、什么时候使用ActiveMQ等 n ...
网盘文件永久链接 1:ActiveMQ入门和消息中间件 2:JMS基本概念和模型 3:JMS的可靠性机制 4:JMS的API结构和开发步骤 ...8:ActiveMQ消息存储持久化 9:ActiveMQ的静态网络链接 10:多线程consumer访问集群 ..........
KahaDB存储 KahaDB他是默认的持久化策略,...LevelDB持久化的性能高于KahaDB,但是在ActiveMQ官网对LevelDB的表述:LevelDB官方建议使用以及不再支持,推荐使用的是KahaDB 可以看到已经不在支持此项了。推荐使用KahaDB
限流降级规则持久化以及熔断规则根据feign配置自动生成;elasticJob分布式调度(支持分布式计算);springBootAdmin实现;商品详情页面根据模板引擎自动生成静态文件(CDN加速支持);activemq、rabbitmq、rocketmq、...
图解Redis中的AOF和RDB持久化策略的原理 redis读写分离架构实践 redis哨兵架构及数据丢失问题分析 redis Cluster数据分布算法之Hash slot redis使用常见问题及性能优化思路 redis高可用及高并发实战 缓存击穿...
C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库,并提供多种语言的API。 MongoDB:MongoDB是一个基于分布式文件存储的NO-SQL型数据库。 ActiveMQ:ActiveMQ 是Apache出品,能力强劲的开源消息...
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 ...
users-handler-实现CQRS的Command部分,并使用h2数据库进行持久化。 这些服务通过Apache ActiveMQ提供的JMS总线进行通信。 更详细的设计文档可。 先决条件 安装Docker Machine并撰写: : 生成并运行 git克隆 cd...
【消息队列】持久化消息非常慢 162 【消息队列】消息的不均匀消费 162 【消息队列】ActiveMQ中的消息重发时间间隔和重发次数吗? 164 【Dubbo】dubbo介绍 166 Dubbo 是什么 166 Dubbo 架构流程图 167 调用流程 167 ...
存储引擎 索引 锁 oracle db2 缓存 redis 数据结构 持久 复制 cas 单线程 memcache eacache Tair 消息队列 jms Queue Topic kafka 持久 复制 Stream Partition rocketMQ RabbitMQ ...
│ 第78节:ActiveMQ消息存储持久化.avi │ 第79节:ActiveMQ的静态网络链接.avi │ 第80节:多线程consumer访问集群.avi │ 第81节:集群下的消息回流功能.avi │ 第82节:容错的链接和动态网络连接.avi │ 第83节...
Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...
Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...
Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...
Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...
Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...
Chronicle 是一个超低延迟、高吞吐、持久化的消息和事件驱动的内存数据库,延迟只有16纳秒以及支持每秒钟 500-2000 万消息/记录。 google-api-translate-java(Java 语言对Google翻译引擎的封装类库) 语音识别程序 ...