ActiveMQ 持久化讯息数据库信息
2024-05-13 11:41:43
www.MyException.Cn 发布于：2012-11-10 10:48:50 浏览：0次
ActiveMQ 持久化消息数据库信息
最近有网友问我，ActiveMQ持久化的中表结构是什么，表需要人工创建吗？我告诉他们不需要，ActiveMQ会帮助我们生成的。只需要制定采用的数据库名称并，创建数据库即可。以为为ActiveMQ采用MySQL5.1持久化产生的SQL语句：
持久化的代码实现为：
http://topmanopensource.iteye.com/blog/1066383
持久化mysql数据库的3张表；
activemq_acks：ActiveMQ的签收信息。
activemq_lock:ActiveMQ的锁信息。
activemq_msgs:ActiveMQ的消息的信息
# MySQL-Front 5.1 (Build 4.2)/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE */;
/*!40101 SET SQL_MODE='STRICT_TRANS_TABLES,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION' */;
/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES */;
/*!40103 SET SQL_NOTES='ON' */;
/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS */;
/*!40014 SET FOREIGN_KEY_CHECKS=0 */;# Host: localhost Database: activemq
# ------------------------------------------------------
# Server version 5.1.40-communityDROP DATABASE IF EXISTS `activemq`;
CREATE DATABASE `activemq` /*!40100 DEFAULT CHARACTER SET utf8 */;
USE `activemq`;#
# Source for table activemq_acks
#DROP TABLE IF EXISTS `activemq_acks`;
CREATE TABLE `activemq_acks` (`CONTAINER` varchar(250) NOT NULL,`SUB_DEST` varchar(250) DEFAULT NULL,`CLIENT_ID` varchar(250) NOT NULL,`SUB_NAME` varchar(250) NOT NULL,`SELECTOR` varchar(250) DEFAULT NULL,`LAST_ACKED_ID` bigint(20) DEFAULT NULL,`PRIORITY` bigint(20) NOT NULL DEFAULT '5',PRIMARY KEY (`CONTAINER`,`CLIENT_ID`,`SUB_NAME`,`PRIORITY`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;#
# Dumping data for table activemq_acks
#LOCK TABLES `activemq_acks` WRITE;
/*!40000 ALTER TABLE `activemq_acks` DISABLE KEYS */;
/*!40000 ALTER TABLE `activemq_acks` ENABLE KEYS */;
UNLOCK TABLES;#
# Source for table activemq_lock
#DROP TABLE IF EXISTS `activemq_lock`;
CREATE TABLE `activemq_lock` (`ID` bigint(20) NOT NULL,`TIME` bigint(20) DEFAULT NULL,`BROKER_NAME` varchar(250) DEFAULT NULL,PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;#
# Dumping data for table activemq_lock
#LOCK TABLES `activemq_lock` WRITE;
/*!40000 ALTER TABLE `activemq_lock` DISABLE KEYS */;
INSERT INTO `activemq_lock` VALUES (1,NULL,NULL);
/*!40000 ALTER TABLE `activemq_lock` ENABLE KEYS */;
UNLOCK TABLES;#
# Source for table activemq_msgs
#DROP TABLE IF EXISTS `activemq_msgs`;
CREATE TABLE `activemq_msgs` (`ID` bigint(20) NOT NULL,`CONTAINER` varchar(250) DEFAULT NULL,`MSGID_PROD` varchar(250) DEFAULT NULL,`MSGID_SEQ` bigint(20) DEFAULT NULL,`EXPIRATION` bigint(20) DEFAULT NULL,`MSG` longblob,`PRIORITY` bigint(20) DEFAULT NULL,PRIMARY KEY (`ID`),KEY `ACTIVEMQ_MSGS_MIDX` (`MSGID_PROD`,`MSGID_SEQ`),KEY `ACTIVEMQ_MSGS_CIDX` (`CONTAINER`),KEY `ACTIVEMQ_MSGS_EIDX` (`EXPIRATION`),KEY `ACTIVEMQ_MSGS_PIDX` (`PRIORITY`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;#
# Dumping data for table activemq_msgs
#LOCK TABLES `activemq_msgs` WRITE;
/*!40000 ALTER TABLE `activemq_msgs` DISABLE KEYS */;
INSERT INTO `activemq_msgs` VALUES (1,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',1,0,X'0000010C1C0000000501017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000001000000000000000400000000000000010000000000000000040000000130450E28660001000000120000000E74657374206D657373616765203100000000000000000000000000000000000000000000000130450E28950000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (2,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',2,0,X'0000010C1C0000000601017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000002000000000000000500000000000000010000000000000000040000000130450E29020001000000120000000E74657374206D657373616765203200000000000000000000000000000000000000000000000130450E29020000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (3,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',3,0,X'0000010C1C0000000701017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000003000000000000000600000000000000010000000000000000040000000130450E29310001000000120000000E74657374206D657373616765203300000000000000000000000000000000000000000000000130450E29310000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (4,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',4,0,X'0000010C1C0000000801017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000004000000000000000700000000000000010000000000000000040000000130450E29500001000000120000000E74657374206D657373616765203400000000000000000000000000000000000000000000000130450E29500000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (5,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',5,0,X'0000010C1C0000000901017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000005000000000000000800000000000000010000000000000000040000000130450E298F0001000000120000000E74657374206D657373616765203500000000000000000000000000000000000000000000000130450E298F0000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (6,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',6,0,X'0000010C1C0000000A01017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000006000000000000000900000000000000010000000000000000040000000130450E29AE0001000000120000000E74657374206D657373616765203600000000000000000000000000000000000000000000000130450E29AE0000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (7,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',7,0,X'0000010C1C0000000B01017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000007000000000000000A00000000000000010000000000000000040000000130450E29ED0001000000120000000E74657374206D657373616765203700000000000000000000000000000000000000000000000130450E29ED0000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (8,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',8,0,X'0000010C1C0000000C01017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000008000000000000000B00000000000000010000000000000000040000000130450E2A0C0001000000120000000E74657374206D657373616765203800000000000000000000000000000000000000000000000130450E2A0C0000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (9,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',9,0,X'0000010C1C0000000D01017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A31000000000000000100000000000000010000000000000009000000000000000C00000000000000010000000000000000040000000130450E2A2B0001000000120000000E74657374206D657373616765203900000000000000000000000000000000000000000000000130450E2A2B0000000000000000',4);
INSERT INTO `activemq_msgs` VALUES (10,'queue://ActiveMQ.QUEUE','ID:EASYWAY-SYSDEPARTMENT-1198-1306828613359-2:1:1:1',10,0,X'0000010D1C0000000E01017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001016401000E4163746976654D512E51554555450000016E017B01002F49443A454153595741592D5359534445504152544D454E542D313139382D313330363832383631333335392D323A3100000000000000010000000000000001000000000000000A000000000000000D00000000000000010000000000000000040000000130450E2A3B0001000000130000000F74657374206D65737361676520313000000000000000000000000000000000000000000000000130450E2A3B0000000000000000',4);
/*!40000 ALTER TABLE `activemq_msgs` ENABLE KEYS */;
UNLOCK TABLES;/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;
/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;转载于:https://www.cnblogs.com/wuxi/p/3142287.html
ActiveMQ 持久化讯息数据库信息相关推荐
- ActiveMQ持久化方式(转)
消息持久性对于可靠消息传递来说应该是一种比较好的方法,有了消息持久化,即使发送者和接受者不是同时在线或者消息中心在发送者发送消息后宕机了,在消息 中心重新启动后仍然可以将消息发送出去,如果把这种持久化 ...
- ActiveMQ持久化方式
ActiveMQ持久化方式 发表于8个月前(2014-09-04 15:55) 阅读(686) | 评论(0) 17人收藏此文章, 我要收藏 赞1 慕课网,程序员升职加薪神器,点击免费学习 摘要 ...
- 《Storm实时数据处理》一2.6 统计与持久化日志统计信息
本节书摘来华章计算机<Storm实时数据处理>一书中的第2章 ,第2.6节,(澳)Quinton Anderson 著 卢誉声 译更多章节内容可以访问云栖社区"华章计算机&quo ...
- ActiveMQ持久化到mysql
ActiveMQ持久化到mysql 配置 1.找到apache-activemq-5.15.2/examples/conf下面的activemq-jdbc-performance.xml 2.打开ac ...
- python消息队列框架持久化_消息队列如果持久化到数据库的话，相对于直接操作数据库有啥优势？...
MQ的作用很多,典型作用: 1.削峰填谷:如果短时间内要处理的业务量大于数据库的服务能力,则可能会卡死数据库:使用MQ可以慢慢处理. 2.异步化:如果处理的工作非常耗时,则RPC的请求一直halt,对 ...
- 使用Logstash同步MySQL数据库信息到ElasticSearch
点击蓝色"程序猿DD"关注我哟 加个"星标",不忘签到哦 转载自公众号:SpringForAll社区 关注我,回复口令获取可获取独家整理的学习资料: - 001 ...
- vb如何测试连接mysql_怎么在vb程序中查找数据库信息并显示
要查找数据库信息,关键是要解决链接数据库的问题,下面简述Vb如何SQL数据库: 有两种方法可以实现,一种是通过ODBC数据源的配置进行连接,一种是通过纯代码编辑进行连接,下面我们就详细介绍一下这两种连 ...
- MySQL -A不预读数据库信息(use dbname 更快)
mysql数据库预读与不预读数据库信息(use dbname)-Reading table information for completion of table and column names ...
- Bigdata之sql+mplot：利用数据库信息和基于mplot将信息数据各种可视化(图表+地图+动态图)
Bigdata之sql+plot:利用数据库信息和基于mplot将信息数据各种可视化 目录 1.图表可视化 1.图表可视化
最新文章
- mysql+dump+选项_mysqldump 备份常用选项以及备份脚本
- 错误处理笔记 导入 torch.utils.tensorboard时 找不到tensorboard
- 神策数据张涛：AARRR 模型面临的新挑战
- C/C++ / 函数调用规则汇总
- Hugepages你用了吗？--原理概念篇
- 使用脚本在Linux服务器上自动安装Kubernetes的包管理器Helm
- 一、操作系统——处理机（作业）调度算法：先来先服务算法FCFS、最短作业优先算法SJF（非抢占式）、 最短剩余时间优先算法SRTN（抢占式）、最高响应比优先算法HRRN
- CentOS 8 安装 Docker 报错 requires containerd.io ＞= 1.4.1, but none of the providers can be installed
- console.log打印值，颜色 - 解决篇
- idea 批量导入包
- JAVA给banking作界面_银行运行模拟编程 求助！！！
- LightOJ 1055 BFS暴力
- 基于深度学习的2D和3D仿射变换配准
- 网页设计html对联样式代码,纯CSS做对联广告代码
- cad补全三视图_cad补画三视图练习题.doc
- win10文件资源管理器打开时很慢
- java calendar时间计算_Java Calendar计算所在时区的时间偏移量
- 【技术贴】怎么装系统？到店里重装系统，装驱动。价钱多少 ？
- 大数据技术原理与应用 第一篇 大数据基础
- 重组人表皮生长因子（EGF）原液 ——风口浪尖的明星成分