jdbc存储类型 #

适用于服务单机、集群部署的场景。

此种存储类型，适用于符合jdbc规范的数据库。

详见实现JdbcTransactionStorage

如何使用 #

这里以mysql为例。

创建数据库表 #

这里默认使用数据库名为AGG，开发者可以自行修改。
最新脚本请查看

CREATE DATABASE IF NOT EXISTS `AGG` CHARACTER SET 'utf8mb4' COLLATE 'utf8mb4_unicode_ci';

USE `AGG`;

CREATE TABLE IF NOT EXISTS `AGGREGATE_FRAMEWORK` (
  `ID` bigint NOT NULL AUTO_INCREMENT,
  `DOMAIN` varchar(100) DEFAULT NULL,
  `XID` varchar(64) NOT NULL,
  `CONTENT` varbinary(8000) DEFAULT NULL,
  `RETRIED_COUNT` int(11) DEFAULT NULL,
  `REQUEST_ID` int(11) DEFAULT NULL,
  `IS_DELETE` tinyint(1) DEFAULT 0 NOT NULL,
  `CREATE_TIME` datetime DEFAULT NULL,
  `LAST_UPDATE_TIME` datetime DEFAULT NULL,
  `VERSION` int(11) DEFAULT NULL,
  PRIMARY KEY (`ID`),
  UNIQUE KEY `UX_XID` (`XID`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

CREATE TABLE IF NOT EXISTS `AGG_DOMAIN` (
  `ID` bigint NOT NULL AUTO_INCREMENT,
  `DOMAIN` varchar(100) NOT NULL,
  `MAX_RETRY_COUNT` integer DEFAULT 3,
  `PHONE_NUMBERS` varchar(250),
  `ALERT_TYPE` varchar(10),
  `THRESHOLD` integer DEFAULT 0,
  `INTERVAL_MINUTES` integer DEFAULT 0,
  `LAST_ALERT_TIME` datetime DEFAULT NULL,
  `DING_ROBOT_URL` varchar(250) DEFAULT NULL,
  `CREATE_TIME` datetime DEFAULT NULL,
  `LAST_UPDATE_TIME` datetime DEFAULT NULL,
  `VERSION` int(11) DEFAULT NULL,
  PRIMARY KEY (`ID`),
  UNIQUE KEY `UX_DOMAIN` (`DOMAIN`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

添加配置 #

可如下配置，查看更多jdbc配置

spring.agg.storage.storageType=jdbc
spring.agg.storage.jdbc.driverClass=com.mysql.jdbc.Driver
spring.agg.storage.jdbc.jdbcUrl=jdbc:mysql://127.0.0.1:3306/AGG?useSSL=false&connectTimeout=1000&socketTimeout=5000
spring.agg.storage.jdbc.username=root
spring.agg.storage.jdbc.password=welcome1

maven依赖 #

 <!--aggregate-framework中测试使用版本为5.1.48-->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql.version}</version>
</dependency>