201206030/novel-plus
1
0
Fork 0
mirror of https://github.com/201206030/novel-plus.git synced 2025-04-26 17:20:52 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

build: Java版本升级到21 & SpringBoot版本升级到2.7.18

Browse Source
This commit is contained in:
xiongxiaoyang 2025-03-15 15:06:59 +08:00
parent fd200772c9
commit 9033ca6331
21 changed files with 244 additions and 549 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
config/shardingsphere-jdbc.yml Normal file
View File

@ -0,0 +1,53 @@
mode:
# 单机模式
type: Standalone
# 元数据持久化
repository:
# 数据库持久化
type: JDBC
# 数据源配置
dataSources:
ds_1:
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
driverClassName: com.mysql.cj.jdbc.Driver
jdbcUrl: jdbc:mysql://localhost:3306/novel_plus?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: test123456
ds_2:
dataSourceClassName: com.zaxxer.hikari.HikariDataSource
driverClassName: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/information_schema?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: test123456
# 规则配置
rules:
- !SINGLE
tables:
- "*.*"
- !SHARDING
tables: # 数据分片规则配置
book_content:
# 分库策略，缺省表示使用默认分库策略
actualDataNodes: ds_${1}.book_content${0..9}
# 分表策略
tableStrategy:
standard:
# 分片列名称
shardingColumn: chapter_id
# 分片算法名称
shardingAlgorithmName: bookContentSharding
shardingAlgorithms:
bookContentSharding:
# 行表达式分片算法，使用 Groovy 的表达式，提供对 SQL 语句中的 = 和 IN 的分片操作支持
type: INLINE
props:
# 分片算法的行表达式
algorithm-expression: book_content${chapter_id % 10}
props:
# 是否在日志中打印 SQL
sql-show: true

10
doc/sql/novel_plus.sql
View File

@ -3145,4 +3145,12 @@ where id = 16;
update crawl_source update crawl_source
set crawl_rule = replace(crawl_rule, 'xbiqugu.net', 'xbiqugu.la'); set crawl_rule = replace(crawl_rule, 'xbiqugu.net', 'xbiqugu.la');
delete
from sys_menu
where menu_id = 104;
delete
from sys_menu
where menu_id = 57;

70
novel-admin/pom.xml
View File

@ -14,18 +14,14 @@
<parent> <parent>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId> <artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.18.RELEASE</version> <version>2.7.18</version>
<relativePath/> <relativePath/>
</parent> </parent>
<properties> <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <java.version>17</java.version>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<velocity.version>1.7</velocity.version> <velocity.version>1.7</velocity.version>
<activiti.version>5.22.0</activiti.version> <shardingsphere-jdbc.version>5.5.1</shardingsphere-jdbc.version>
<sharding.jdbc.version>3.0.0</sharding.jdbc.version>
<jackson.version>2.15.1</jackson.version>
</properties> </properties>
<dependencies> <dependencies>
@ -60,35 +56,24 @@
<groupId>net.sourceforge.nekohtml</groupId> <groupId>net.sourceforge.nekohtml</groupId>
<artifactId>nekohtml</artifactId> <artifactId>nekohtml</artifactId>
</dependency> </dependency>
<!-- 请求参数校验相关 -->
<dependency>
<groupId>org.hibernate.validator</groupId>
<artifactId>hibernate-validator</artifactId>
</dependency>
<!--mybatis --> <!--mybatis -->
<dependency> <dependency>
<groupId>mysql</groupId> <groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId> <artifactId>mysql-connector-java</artifactId>
<version>8.0.29</version> <version>8.0.29</version>
</dependency> </dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.6</version>
</dependency>
<dependency> <dependency>
<groupId>org.mybatis.spring.boot</groupId> <groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId> <artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.1.1</version> <version>1.1.1</version>
</dependency> </dependency>
<!--druid -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.2.9</version>
</dependency>
<!--commons --> <!--commons -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.6</version>
</dependency>
<dependency> <dependency>
<groupId>commons-configuration</groupId> <groupId>commons-configuration</groupId>
<artifactId>commons-configuration</artifactId> <artifactId>commons-configuration</artifactId>
@ -138,6 +123,12 @@
<groupId>org.apache.velocity</groupId> <groupId>org.apache.velocity</groupId>
<artifactId>velocity</artifactId> <artifactId>velocity</artifactId>
<version>1.7</version> <version>1.7</version>
<exclusions>
<exclusion>
<artifactId>commons-lang</artifactId>
<groupId>commons-lang</groupId>
</exclusion>
</exclusions>
</dependency> </dependency>
<!--<dependency>--> <!--<dependency>-->
<!--<groupId>org.springframework.boot</groupId>--> <!--<groupId>org.springframework.boot</groupId>-->
@ -166,6 +157,12 @@
<groupId>io.springfox</groupId> <groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId> <artifactId>springfox-swagger2</artifactId>
<version>2.6.1</version> <version>2.6.1</version>
<exclusions>
<exclusion>
<artifactId>guava</artifactId>
<groupId>com.google.guava</groupId>
</exclusion>
</exclusions>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.springfox</groupId> <groupId>io.springfox</groupId>
@ -195,24 +192,29 @@
<groupId>org.apache.commons</groupId> <groupId>org.apache.commons</groupId>
<artifactId>commons-text</artifactId> <artifactId>commons-text</artifactId>
<version>1.4</version> <version>1.4</version>
<exclusions>
<exclusion>
<artifactId>commons-lang3</artifactId>
<groupId>org.apache.commons</groupId>
</exclusion>
</exclusions>
</dependency> </dependency>
<!-- ShardingSphere-JDBC -->
<dependency> <dependency>
<groupId>io.shardingsphere</groupId> <groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-jdbc-spring-boot-starter</artifactId> <artifactId>shardingsphere-jdbc</artifactId>
<version>${sharding.jdbc.version}</version> <version>${shardingsphere-jdbc.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.shardingsphere</groupId> <groupId>org.yaml</groupId>
<artifactId>sharding-jdbc-spring-namespace</artifactId> <artifactId>snakeyaml</artifactId>
<version>${sharding.jdbc.version}</version> <version>2.2</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>com.fasterxml.jackson.core</groupId> <groupId>com.h2database</groupId>
<artifactId>jackson-databind</artifactId> <artifactId>h2</artifactId>
<version>${jackson.version}</version> <scope>runtime</scope>
</dependency> </dependency>
<!--war包部署需要--> <!--war包部署需要-->

10
novel-admin/src/main/java/com/java2nb/common/aspect/WebLogAspect.java
View File

@ -1,19 +1,16 @@
package com.java2nb.common.aspect; package com.java2nb.common.aspect;
import com.java2nb.common.utils.HttpContextUtils; import com.java2nb.common.utils.IPUtils;
import org.aspectj.lang.JoinPoint; import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*; import org.aspectj.lang.annotation.*;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder; import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes; import org.springframework.web.context.request.ServletRequestAttributes;
import sun.net.util.IPAddressUtil;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.Method;
import java.util.Arrays; import java.util.Arrays;
@Aspect @Aspect
@ -37,11 +34,10 @@ public class WebLogAspect {
logger.info("请求地址 : " + request.getRequestURL().toString()); logger.info("请求地址 : " + request.getRequestURL().toString());
logger.info("HTTP METHOD : " + request.getMethod()); logger.info("HTTP METHOD : " + request.getMethod());
// 获取真实的ip地址 // 获取真实的ip地址
//logger.info("IP : " + IPAddressUtil.getClientIpAddress(request)); logger.info("IP : " + IPUtils.getIpAddr(request));
logger.info("CLASS_METHOD : " + joinPoint.getSignature().getDeclaringTypeName() + "." logger.info("CLASS_METHOD : " + joinPoint.getSignature().getDeclaringTypeName() + "."
+ joinPoint.getSignature().getName()); + joinPoint.getSignature().getName());
logger.info("参数 : " + Arrays.toString(joinPoint.getArgs())); logger.info("参数 : " + Arrays.toString(joinPoint.getArgs()));
// loggger.info("参数 : " + joinPoint.getArgs());
} }

132
novel-admin/src/main/java/com/java2nb/common/config/DruidDBConfig.java
View File

@ -1,132 +0,0 @@
package com.java2nb.common.config;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import javax.sql.DataSource;
import java.sql.SQLException;
/**
* Created by PrimaryKey on 17/2/4.
*/
@SuppressWarnings("AlibabaRemoveCommentedCode")
@Configuration
public class DruidDBConfig {
private Logger logger = LoggerFactory.getLogger(DruidDBConfig.class);
@Value("${spring.datasource.url}")
private String dbUrl;
@Value("${spring.datasource.username}")
private String username;
@Value("${spring.datasource.password}")
private String password;
@Value("${spring.datasource.driverClassName}")
private String driverClassName;
@Value("${spring.datasource.initialSize}")
private int initialSize;
@Value("${spring.datasource.minIdle}")
private int minIdle;
@Value("${spring.datasource.maxActive}")
private int maxActive;
@Value("${spring.datasource.maxWait}")
private int maxWait;
@Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
private int timeBetweenEvictionRunsMillis;
@Value("${spring.datasource.minEvictableIdleTimeMillis}")
private int minEvictableIdleTimeMillis;
@Value("${spring.datasource.validationQuery}")
private String validationQuery;
@Value("${spring.datasource.testWhileIdle}")
private boolean testWhileIdle;
@Value("${spring.datasource.testOnBorrow}")
private boolean testOnBorrow;
@Value("${spring.datasource.testOnReturn}")
private boolean testOnReturn;
@Value("${spring.datasource.poolPreparedStatements}")
private boolean poolPreparedStatements;
@Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")
private int maxPoolPreparedStatementPerConnectionSize;
@Value("${spring.datasource.filters}")
private String filters;
@Value("{spring.datasource.connectionProperties}")
private String connectionProperties;
@Bean(initMethod = "init", destroyMethod = "close") //声明其为Bean实例
@Primary //在同样的DataSource中，首先使用被标注的DataSource
public DataSource dataSource() {
DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(this.dbUrl);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);
//configuration
datasource.setInitialSize(initialSize);
datasource.setMinIdle(minIdle);
datasource.setMaxActive(maxActive);
datasource.setMaxWait(maxWait);
datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
datasource.setValidationQuery(validationQuery);
datasource.setTestWhileIdle(testWhileIdle);
datasource.setTestOnBorrow(testOnBorrow);
datasource.setTestOnReturn(testOnReturn);
datasource.setPoolPreparedStatements(poolPreparedStatements);
datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
try {
datasource.setFilters(filters);
} catch (SQLException e) {
logger.error("druid configuration initialization filter", e);
}
datasource.setConnectionProperties(connectionProperties);
return datasource;
}
@Bean
public ServletRegistrationBean druidServlet() {
ServletRegistrationBean reg = new ServletRegistrationBean();
reg.setServlet(new StatViewServlet());
reg.addUrlMappings("/druid/*");
reg.addInitParameter("allow", ""); //白名单
return reg;
}
@Bean public FilterRegistrationBean filterRegistrationBean() {
FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
filterRegistrationBean.setFilter(new WebStatFilter());
filterRegistrationBean.addUrlPatterns("/*");
filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
filterRegistrationBean.addInitParameter("profileEnable", "true");
filterRegistrationBean.addInitParameter("principalCookieName","USER_COOKIE");
filterRegistrationBean.addInitParameter("principalSessionName","USER_SESSION");
filterRegistrationBean.addInitParameter("DruidWebStatFilter","/*");
return filterRegistrationBean;
}
}

48
novel-admin/src/main/java/com/java2nb/common/config/Swagger2Config.java
View File

@ -1,48 +0,0 @@
package com.java2nb.common.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
/**
* ${DESCRIPTION}
*
* @author xiongxy
* @create 2019-11-02 23:53
*/
@EnableSwagger2
@Configuration
public class Swagger2Config {
@Bean
public Docket createRestApi() {
return new Docket(DocumentationType.SWAGGER_2)
.apiInfo(apiInfo())
.select()
//为当前包路径
.apis(RequestHandlerSelectors.any())
.paths(PathSelectors.any())
.build();
}
//构建 api文档的详细信息函数
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
//页面标题
.title("功能测试")
//创建人
.contact(new Contact("xiongxy", "1179705413@qq.com", "1179705413@qq.com"))
//版本号
.version("1.0")
//描述
.description("API 描述")
.build();
}
}

10
novel-admin/src/main/java/com/java2nb/common/dao/GeneratorMapper.java
View File

@ -9,25 +9,25 @@ import java.util.Map;
public interface GeneratorMapper { public interface GeneratorMapper {
@Select( @Select(
"select table_name tableName, engine, table_comment tableComment, create_time createTime from information_schema.tables" "select table_name tableName, engine, table_comment tableComment, create_time createTime from tables"
+ " where table_schema = 'novel_plus' and table_name like concat('%',#{tableName},'%')") + " where table_schema = 'novel_plus' and table_name like concat('%',#{tableName},'%')")
List<Map<String, Object>> list(@Param("tableName") String tableName); List<Map<String, Object>> list(@Param("tableName") String tableName);
@Select("select count(*) from information_schema.tables where table_schema = 'novel_plus'") @Select("select count(*) from tables where table_schema = 'novel_plus'")
int count(Map<String, Object> map); int count(Map<String, Object> map);
@Select( @Select(
"select table_name tableName, engine, table_comment tableComment, create_time createTime from information_schema.tables \r\n" "select table_name tableName, engine, table_comment tableComment, create_time createTime from tables \r\n"
+ " where table_schema = 'novel_plus' and table_name = #{tableName}") + " where table_schema = 'novel_plus' and table_name = #{tableName}")
Map<String, String> get(String tableName); Map<String, String> get(String tableName);
@Select( @Select(
"select column_name columnName, data_type dataType, column_comment columnComment, column_key columnKey, extra from information_schema.columns\r\n" "select column_name columnName, data_type dataType, column_comment columnComment, column_key columnKey, extra from columns\r\n"
+ " where table_name = #{tableName} and table_schema = 'novel_plus' order by ordinal_position") + " where table_name = #{tableName} and table_schema = 'novel_plus' order by ordinal_position")
List<Map<String, String>> listColumns(String tableName); List<Map<String, String>> listColumns(String tableName);
@Select( @Select(
"select column_name columnName, data_type dataType, column_comment columnComment, column_key columnKey, extra from information_schema.columns\r\n" "select column_name columnName, data_type dataType, column_comment columnComment, column_key columnKey, extra from columns\r\n"
+ " where table_name = #{tableName} and table_schema = 'novel_plus' and column_key = 'PRI' limit 1") + " where table_name = #{tableName} and table_schema = 'novel_plus' and column_key = 'PRI' limit 1")
Map<String, String> getPriColumn(String tableName); Map<String, String> getPriColumn(String tableName);
} }

16
novel-admin/src/main/java/com/java2nb/common/exception/MainsiteErrorController.java
View File

@ -2,32 +2,27 @@ package com.java2nb.common.exception;
import com.java2nb.common.utils.R; import com.java2nb.common.utils.R;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.servlet.error.ErrorAttributes; import org.springframework.boot.web.servlet.error.ErrorAttributes;
import org.springframework.boot.web.servlet.error.ErrorController; import org.springframework.boot.web.servlet.error.ErrorController;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.util.Map;
@RestController @RestController
public class MainsiteErrorController implements ErrorController { public class MainsiteErrorController implements ErrorController {
private Logger logger = LoggerFactory.getLogger(getClass());
private static final String ERROR_PATH = "/error"; private static final String ERROR_PATH = "/error";
@Autowired @Autowired
ErrorAttributes errorAttributes; ErrorAttributes errorAttributes;
@RequestMapping( @RequestMapping(
value = {ERROR_PATH}, value = {ERROR_PATH},
produces = {"text/html"} produces = {"text/html"}
) )
public ModelAndView errorHtml(HttpServletRequest request, HttpServletResponse response) { public ModelAndView errorHtml(HttpServletRequest request, HttpServletResponse response) {
int code = response.getStatus(); int code = response.getStatus();
@ -58,9 +53,4 @@ public class MainsiteErrorController implements ErrorController {
} }
} }
@Override
public String getErrorPath() {
// TODO Auto-generated method stub
return ERROR_PATH;
}
} }

144
novel-admin/src/main/java/com/java2nb/common/utils/JSONUtils.java
View File

@ -1,6 +1,5 @@
package com.java2nb.common.utils; package com.java2nb.common.utils;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
@ -8,79 +7,80 @@ import java.util.HashMap;
import java.util.Map; import java.util.Map;
public class JSONUtils { public class JSONUtils {
/**
* Bean对象转JSON
*
* @param object
* @param dataFormatString
* @return
*/
public static String beanToJson(Object object, String dataFormatString) {
if (object != null) {
if (StringUtils.isEmpty(dataFormatString)) {
return JSONObject.toJSONString(object);
}
return JSON.toJSONStringWithDateFormat(object, dataFormatString);
} else {
return null;
}
}
/** /**
* Bean对象转JSON * Bean对象转JSON
* *
* @param object * @param object
* @return * @param dataFormatString
*/ * @return
public static String beanToJson(Object object) { */
if (object != null) { public static String beanToJson(Object object, String dataFormatString) {
return JSON.toJSONString(object); if (object != null) {
} else { if (StringUtils.isEmpty(dataFormatString)) {
return null; return JSONObject.toJSONString(object);
} }
} return JSON.toJSONStringWithDateFormat(object, dataFormatString);
} else {
return null;
}
}
/** /**
* String转JSON字符串 * Bean对象转JSON
* *
* @param key * @param object
* @param value * @return
* @return */
*/ public static String beanToJson(Object object) {
public static String stringToJsonByFastjson(String key, String value) { if (object != null) {
if (StringUtils.isEmpty(key) || StringUtils.isEmpty(value)) { return JSON.toJSONString(object);
return null; } else {
} return null;
Map<String, String> map = new HashMap<String, String>(16); }
map.put(key, value); }
return beanToJson(map, null);
}
/** /**
* 将json字符串转换成对象 * String转JSON字符串
* *
* @param json * @param key
* @param clazz * @param value
* @return * @return
*/ */
public static Object jsonToBean(String json, Object clazz) { public static String stringToJsonByFastjson(String key, String value) {
if (StringUtils.isEmpty(json) || clazz == null) { if (StringUtils.isEmpty(key) || StringUtils.isEmpty(value)) {
return null; return null;
} }
return JSON.parseObject(json, clazz.getClass()); Map<String, String> map = new HashMap<String, String>(16);
} map.put(key, value);
return beanToJson(map, null);
}
/** /**
* json字符串转map * 将json字符串转换成对象
* *
* @param json * @param json
* @return * @param clazz
*/ * @return
@SuppressWarnings("unchecked") */
public static Map<String, Object> jsonToMap(String json) { public static Object jsonToBean(String json, Object clazz) {
if (StringUtils.isEmpty(json)) { if (StringUtils.isEmpty(json) || clazz == null) {
return null; return null;
} }
return JSON.parseObject(json, Map.class); return JSON.parseObject(json, clazz.getClass());
} }
/**
* json字符串转map
*
* @param json
* @return
*/
@SuppressWarnings("unchecked")
public static Map<String, Object> jsonToMap(String json) {
if (StringUtils.isEmpty(json)) {
return null;
}
return JSON.parseObject(json, Map.class);
}
} }

82
novel-admin/src/main/resources/application-dev.yml
View File

@ -8,91 +8,13 @@ logging:
com.java2nb: debug com.java2nb: debug
spring: spring:
datasource: datasource:
type: com.alibaba.druid.pool.DruidDataSource driverClassName: org.apache.shardingsphere.driver.ShardingSphereDriver
driverClassName: com.mysql.cj.jdbc.Driver url: jdbc:shardingsphere:absolutepath:${user.dir}/config/shardingsphere-jdbc.yml
url: jdbc:mysql://127.0.0.1:3306/novel_plus?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
username: root
password: test123456
#password:
initialSize: 1
minIdle: 3
maxActive: 20
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis: 30000
validationQuery: select 'x'
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
# 打开PSCache，并且指定每个连接上PSCache的大小
poolPreparedStatements: true
maxPoolPreparedStatementPerConnectionSize: 20
# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
filters: stat,slf4j
# 通过connectProperties属性来打开mergeSql功能；慢SQL记录
connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 合并多个DruidDataSource的监控数据
#useGlobalDataSourceStat: true
redis: redis:
host: 127.0.0.1 host: 127.0.0.1
port: 6379 port: 6379
password: test123456 password: test123456
# 连接超时时间（毫秒） # 连接超时时间（毫秒）
timeout: 10000 timeout: 10000
jedis:
pool:
# 连接池中的最大空闲连接
max-idle: 8
# 连接池中的最小空闲连接
min-idle: 10
# 连接池最大连接数（使用负值表示没有限制）
max-active: 100
# 连接池最大阻塞等待时间（使用负值表示没有限制）
max-wait: -1
####使用shardingJdbc时，
####所有的jdbcType都不能是LONGVARCHAR,否则会导致java.io.NotSerializableException: java.io.StringReader错误
##### 应该替换所有的 LONGVARCHAR 类型为VARCHAR
sharding:
jdbc:
datasource:
names: ds0,ds1
ds0:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://localhost:3306/novel_plus?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: test123456
ds1:
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://localhost:3306/information_schema?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: test123456
config:
sharding:
props:
sql.show: true
tables:
book_content: #book_content表
key-generator-column-name: id #主键
actual-data-nodes: ds${0}.book_content${0..9} #数据节点
# database-strategy: #分库策略
# inline:
# sharding-column: book_id
# algorithm-expression: ds${book_id % 10}
table-strategy: #分表策略
inline:
shardingColumn: index_id
algorithm-expression: book_content${index_id % 10}
tables:
actual-data-nodes: ds${1}.tables
columns:
actual-data-nodes: ds${1}.columns
default-data-source-name: ds0

78
novel-admin/src/main/resources/application-prod.yml
View File

@ -8,85 +8,13 @@ logging:
com.java2nb: error com.java2nb: error
spring: spring:
datasource: datasource:
type: com.alibaba.druid.pool.DruidDataSource driverClassName: org.apache.shardingsphere.driver.ShardingSphereDriver
driverClassName: com.mysql.cj.jdbc.Driver url: jdbc:shardingsphere:absolutepath:${user.dir}/config/shardingsphere-jdbc.yml
url: jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
username: root
password: test123456
#password:
initialSize: 1
minIdle: 3
maxActive: 20
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis: 30000
validationQuery: select 'x'
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
# 打开PSCache，并且指定每个连接上PSCache的大小
poolPreparedStatements: true
maxPoolPreparedStatementPerConnectionSize: 20
# 配置监控统计拦截的filters，去掉后监控界面sql无法统计，'wall'用于防火墙
filters: stat,slf4j
# 通过connectProperties属性来打开mergeSql功能；慢SQL记录
connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
# 合并多个DruidDataSource的监控数据
#useGlobalDataSourceStat: true
redis: redis:
host: 127.0.0.1 host: 127.0.0.1
port: 6379 port: 6379
password: test password: test123456
# 连接超时时间（毫秒） # 连接超时时间（毫秒）
timeout: 10000 timeout: 10000
jedis:
pool:
# 连接池中的最大空闲连接
max-idle: 8
# 连接池中的最小空闲连接
min-idle: 10
# 连接池最大连接数（使用负值表示没有限制）
max-active: 100
# 连接池最大阻塞等待时间（使用负值表示没有限制）
max-wait: -1
####使用shardingJdbc时，
####所有的jdbcType都不能是LONGVARCHAR,否则会导致java.io.NotSerializableException: java.io.StringReader错误
##### 应该替换所有的 LONGVARCHAR 类型为VARCHAR
sharding:
jdbc:
datasource:
names: ds0 #,ds1
ds0:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://localhost:3306/novel_plus?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: test123456
# ds1:
# type: com.alibaba.druid.pool.DruidDataSource
# driver-class-name: com.mysql.jdbc.Driver
# url: jdbc:mysql://localhost:3306/novel_plus2
# username: root
# password: test123456
config:
sharding:
props:
sql.show: true
tables:
book_content: #book_content表
key-generator-column-name: id #主键
actual-data-nodes: ds${0}.book_content${0..9} #数据节点
# database-strategy: #分库策略
# inline:
# sharding-column: book_id
# algorithm-expression: ds${book_id % 10}
table-strategy: #分表策略
inline:
shardingColumn: index_id
algorithm-expression: book_content${index_id % 10}

22
novel-common/pom.xml
View File

@ -52,18 +52,16 @@
</dependency> </dependency>
<!-- 分库分表--> <!-- 分库分表-->
<!-- sharding jdbc依赖 --> <!-- ShardingSphere-JDBC -->
<dependency> <dependency>
<groupId>io.shardingsphere</groupId> <groupId>org.apache.shardingsphere</groupId>
<artifactId>sharding-jdbc-spring-boot-starter</artifactId> <artifactId>shardingsphere-jdbc</artifactId>
<version>${sharding.jdbc.version}</version> <version>${shardingsphere-jdbc.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.shardingsphere</groupId> <groupId>com.h2database</groupId>
<artifactId>sharding-jdbc-spring-namespace</artifactId> <artifactId>h2</artifactId>
<version>${sharding.jdbc.version}</version> <scope>runtime</scope>
</dependency> </dependency>
@ -117,6 +115,12 @@
<optional>true</optional> <optional>true</optional>
</dependency> </dependency>
<!-- 请求参数校验相关 -->
<dependency>
<groupId>org.hibernate.validator</groupId>
<artifactId>hibernate-validator</artifactId>
</dependency>
<dependency> <dependency>
<groupId>io.github.xxyopen</groupId> <groupId>io.github.xxyopen</groupId>
<artifactId>xxy-model</artifactId> <artifactId>xxy-model</artifactId>

45
novel-common/src/main/resources/application-common-dev.yml
View File

@ -23,49 +23,8 @@ spring:
#连接超时时间（毫秒） #连接超时时间（毫秒）
timeout: 30000 timeout: 30000
datasource: datasource:
url: jdbc:mysql://127.0.0.1:3306/novel_plus?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai url: jdbc:shardingsphere:absolutepath:${user.dir}/config/shardingsphere-jdbc.yml
username: root driver-class-name: org.apache.shardingsphere.driver.ShardingSphereDriver
password: test123456
driver-class-name: com.mysql.cj.jdbc.Driver
####使用shardingJdbc时，
####所有的jdbcType都不能是LONGVARCHAR,否则会导致java.io.NotSerializableException: java.io.StringReader错误
##### 应该替换所有的 LONGVARCHAR 类型为VARCHAR
sharding:
jdbc:
datasource:
names: ds0 #,ds1
ds0:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://localhost:3306/novel_plus?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
username: root
password: test123456
# ds1:
# type: com.alibaba.druid.pool.DruidDataSource
# driver-class-name: com.mysql.jdbc.Driver
# url: jdbc:mysql://localhost:3306/novel_plus2
# username: root
# password: test123456
config:
sharding:
props:
sql.show: true
tables:
book_content: #book_content表
key-generator-column-name: id #主键
actual-data-nodes: ds${0}.book_content${0..9} #数据节点
# database-strategy: #分库策略
# inline:
# sharding-column: book_id
# algorithm-expression: ds${book_id % 10}
table-strategy: #分表策略
inline:
shardingColumn: index_id
algorithm-expression: book_content${index_id % 10}
content: content:
save: save:

2
novel-common/src/main/resources/application-common.yml
View File

@ -27,6 +27,8 @@ mybatis:
logging: logging:
config: classpath:logback-boot.xml config: classpath:logback-boot.xml
pagehelper:
helper-dialect: mysql

7
novel-crawl/pom.xml
View File

@ -21,6 +21,12 @@
<artifactId>novel-common</artifactId> <artifactId>novel-common</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.yaml</groupId>
<artifactId>snakeyaml</artifactId>
<version>2.2</version>
</dependency>
<dependency> <dependency>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId> <artifactId>spring-boot-starter-security</artifactId>
@ -29,7 +35,6 @@
<dependency> <dependency>
<groupId>com.fasterxml.jackson.core</groupId> <groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId> <artifactId>jackson-databind</artifactId>
<version>${jackson.version}</version>
</dependency> </dependency>

12
novel-crawl/src/main/java/com/java2nb/novel/core/listener/StarterListener.java
View File

@ -14,10 +14,10 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateUtils; import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.ServletContextInitializer;
import org.springframework.stereotype.Component;
import javax.servlet.ServletContextEvent; import javax.servlet.ServletContext;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -26,10 +26,10 @@ import java.util.concurrent.TimeUnit;
/** /**
* @author Administrator * @author Administrator
*/ */
@WebListener @Component
@Slf4j @Slf4j
@RequiredArgsConstructor @RequiredArgsConstructor
public class StarterListener implements ServletContextListener { public class StarterListener implements ServletContextInitializer {
private final BookService bookService; private final BookService bookService;
@ -41,7 +41,7 @@ public class StarterListener implements ServletContextListener {
private int updateThreadCount; private int updateThreadCount;
@Override @Override
public void contextInitialized(ServletContextEvent sce) { public void onStartup(ServletContext servletContext) {
for (int i = 0; i < updateThreadCount; i++) { for (int i = 0; i < updateThreadCount; i++) {
new Thread(() -> { new Thread(() -> {
log.info("程序启动,开始执行自动更新线程。。。"); log.info("程序启动,开始执行自动更新线程。。。");

4
novel-crawl/src/main/resources/application.yml
View File

@ -8,7 +8,9 @@ server:
spring: spring:
profiles: profiles:
active: dev active: dev
config:
use-legacy-processing: true
#登录用户名密码 #登录用户名密码
admin: admin:
username: admin username: admin

7
novel-front/pom.xml
View File

@ -20,6 +20,12 @@
<artifactId>novel-common</artifactId> <artifactId>novel-common</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.yaml</groupId>
<artifactId>snakeyaml</artifactId>
<version>2.2</version>
</dependency>
<!--JWT(Json Web Token)登录支持--> <!--JWT(Json Web Token)登录支持-->
<dependency> <dependency>
<groupId>io.jsonwebtoken</groupId> <groupId>io.jsonwebtoken</groupId>
@ -48,7 +54,6 @@
<dependency> <dependency>
<groupId>com.fasterxml.jackson.core</groupId> <groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId> <artifactId>jackson-databind</artifactId>
<version>${jackson.version}</version>
</dependency> </dependency>
</dependencies> </dependencies>

32
novel-front/src/main/java/com/java2nb/novel/core/listener/StarterListener.java
View File

@ -5,36 +5,34 @@ import com.java2nb.novel.entity.WebsiteInfo;
import com.java2nb.novel.mapper.WebsiteInfoMapper; import com.java2nb.novel.mapper.WebsiteInfoMapper;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.web.servlet.ServletContextInitializer;
import org.springframework.stereotype.Component;
import javax.servlet.ServletContextEvent; import javax.servlet.ServletContext;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
/** /**
* 启动监听器 * 启动监听器
* *
* @author xiongxiaoyang * @author xiongxiaoyang
*/ */
@WebListener @Component
@Slf4j @Slf4j
@RequiredArgsConstructor @RequiredArgsConstructor
public class StarterListener implements ServletContextListener { public class StarterListener implements ServletContextInitializer {
private final WebsiteProperties websiteProperties; private final WebsiteProperties websiteProperties;
private final WebsiteInfoMapper websiteInfoMapper; private final WebsiteInfoMapper websiteInfoMapper;
@Override @Override
public void contextInitialized(ServletContextEvent sce) { public void onStartup(ServletContext servletContext) {
sce.getServletContext() servletContext.setAttribute("website", websiteInfoMapper.selectByPrimaryKey(1L).orElse(new WebsiteInfo() {{
.setAttribute("website", websiteInfoMapper.selectByPrimaryKey(1L).orElse(new WebsiteInfo() {{ setName(websiteProperties.getName());
setName(websiteProperties.getName()); setDomain(websiteProperties.getDomain());
setDomain(websiteProperties.getDomain()); setKeyword(websiteProperties.getKeyword());
setKeyword(websiteProperties.getKeyword()); setDescription(websiteProperties.getDescription());
setDescription(websiteProperties.getDescription()); setQq(websiteProperties.getQq());
setQq(websiteProperties.getQq()); setLogo("/images/logo.png");
setLogo("/images/logo.png"); setLogoDark("/images/logo_white.png");
setLogoDark("/images/logo_white.png"); }}));
}}));
} }
} }

2
novel-front/src/main/resources/application.yml
View File

@ -5,6 +5,8 @@ spring:
profiles: profiles:
active: dev active: dev
include: website,alipay,oss include: website,alipay,oss
config:
use-legacy-processing: true
jwt: jwt:
secret: novel!#20191230 secret: novel!#20191230

7
pom.xml
View File

@ -20,14 +20,14 @@
<parent> <parent>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId> <artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.18.RELEASE</version> <version>2.7.18</version>
<relativePath/> <relativePath/>
</parent> </parent>
<properties> <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version> <java.version>17</java.version>
<maven.test.skip>true</maven.test.skip> <maven.test.skip>true</maven.test.skip>
<mysql.version>8.0.29</mysql.version> <mysql.version>8.0.29</mysql.version>
<mybatis.version>2.1.4</mybatis.version> <mybatis.version>2.1.4</mybatis.version>
@ -40,12 +40,11 @@
<jest.version>6.3.1</jest.version> <jest.version>6.3.1</jest.version>
<redis.version>1.4.1.RELEASE</redis.version> <redis.version>1.4.1.RELEASE</redis.version>
<redisson.version>3.12.5</redisson.version> <redisson.version>3.12.5</redisson.version>
<sharding.jdbc.version>3.0.0</sharding.jdbc.version> <shardingsphere-jdbc.version>5.5.1</shardingsphere-jdbc.version>
<aliyun-sdk-oss.version>3.16.3</aliyun-sdk-oss.version> <aliyun-sdk-oss.version>3.16.3</aliyun-sdk-oss.version>
<commons-fileupload.version>1.5</commons-fileupload.version> <commons-fileupload.version>1.5</commons-fileupload.version>
<alipay-sdk-java.version>4.35.139.ALL</alipay-sdk-java.version> <alipay-sdk-java.version>4.35.139.ALL</alipay-sdk-java.version>
<xxyopen.version>1.0.0</xxyopen.version> <xxyopen.version>1.0.0</xxyopen.version>
<jackson.version>2.15.1</jackson.version>
</properties> </properties>
<dependencyManagement> <dependencyManagement>