Java：Kafka Demo 升级 JDK 17，APIJSON 7.1.0, apijson-framework 及自身 7.1.5

Author: TommyLemon

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/pom.xml

@@ -9,14 +9,18 @@
 	</parent>
 	<groupId>apijson.demo</groupId>
 	<artifactId>apijsondemo-multidatasource-kafka</artifactId>
-	<version>7.0.3</version>
+	<version>7.1.5</version>
 
 	<name>apijsondemo-multidatasource-kafka</name>
 	<description>Demo project for testing APIJSON server based on SpringBoot</description>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+		<java.version>17</java.version>
+		<maven.compiler.encoding>UTF-8</maven.compiler.encoding>
+		<maven.compiler.source>17</maven.compiler.source>
+		<maven.compiler.target>17</maven.compiler.target>
 		<commons-lang3.version>3.12.0</commons-lang3.version>
 		<druid.version>1.1.16</druid.version>
 		<mybatisplus.version>3.5.1</mybatisplus.version>
@@ -37,7 +41,6 @@
 		<spring-context-support.version>5.3.18</spring-context-support.version>
 		<spring-boot-configuration-processor.version>2.6.6</spring-boot-configuration-processor.version>
 		<dynamic-datasource-spring-boot-starter.version>3.5.2</dynamic-datasource-spring-boot-starter.version>
-		<java.version>1.8</java.version>
 		<kafka.version>3.2.1</kafka.version>
 	</properties>
 
@@ -46,12 +49,12 @@
 		<dependency>
 			<groupId>com.github.Tencent</groupId>
 			<artifactId>APIJSON</artifactId>
-			<version>7.0.3</version>
+			<version>7.1.0</version>
 		</dependency>
 		<dependency>
 			<groupId>com.github.APIJSON</groupId>
 			<artifactId>apijson-framework</artifactId>
-			<version>7.0.3</version>
+			<version>7.1.5</version>
 		</dependency>
 
 		<!-- 需要用的数据库 JDBC 驱动 -->
@@ -62,6 +65,7 @@
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-web</artifactId>
+			<version>2.5.13</version>
 		</dependency>
 		<dependency>
 			<groupId>org.springframework</groupId>
@@ -147,6 +151,7 @@
 			<plugin>
 				<groupId>org.springframework.boot</groupId>
 				<artifactId>spring-boot-maven-plugin</artifactId>
+				<version>2.5.13</version>
 				<configuration>
 					<fork>true</fork>
 					<mainClass>apijson.demo.DemoApplication</mainClass>
@@ -162,9 +167,10 @@
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-compiler-plugin</artifactId>
+				<version>3.8.1</version>
 				<configuration>
-					<source>1.8</source>
-					<target>1.8</target>
+					<source>17</source>
+					<target>17</target>
 				</configuration>
 			</plugin>
 		</plugins>

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DataBaseUtil.java

@@ -13,7 +13,7 @@ public class DataBaseUtil {
      * @param url
      * @return
      */
-    public static String getLibname(String url) {
+    public static String getDbName(String url) {
         Pattern p = Pattern.compile("jdbc:(?<db>\\w+):.*((//)|@)(?<host>.+):(?<port>\\d+)(/|(;DatabaseName=)|:)(?<dbName>\\w+)\\??.*");
         Matcher m = p.matcher(url);
         if(m.find()) {
@@ -41,7 +41,7 @@ public static String getDruidUrl(String datasource) {
 	}
 
 	public static String getDruidSchema(String datasource) {
-		return getLibname(DynamicDataSource.getDetail(datasource).getUrl()); // 数据库名;
+		return getDbName(DynamicDataSource.getDetail(datasource).getUrl()); // 数据库名;
 	}
 
 	public static String getDruidDBAccount(String datasource) {

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoApplication.java

@@ -26,8 +26,8 @@
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
 import apijson.Log;
-import apijson.framework.APIJSONApplication;
-import apijson.framework.APIJSONCreator;
+import apijson.framework.javax.APIJSONApplication;
+import apijson.framework.javax.APIJSONCreator;
 import apijson.orm.AbstractFunctionParser;
 import apijson.orm.AbstractVerifier;
 import apijson.orm.FunctionParser;
@@ -62,11 +62,14 @@ public void customize(ConfigurableServletWebServerFactory server) {
 
 	// 支持 APIAuto 中 JavaScript 代码跨域请求
 	@Bean
-	public WebMvcConfigurer corsConfigurer() {
+	public WebMvcConfigurer corsConfig() {
 		return new WebMvcConfigurer() {
 			@Override
 			public void addCorsMappings(CorsRegistry registry) {
-				registry.addMapping("/**").allowedOriginPatterns("*").allowedMethods("*").allowCredentials(true)
+				registry.addMapping("/**")
+						.allowedOriginPatterns("*")
+						.allowedMethods("*")
+						.allowCredentials(true)
 						.maxAge(3600);
 			}
 		};
@@ -81,17 +84,17 @@ public Parser<String> createParser() {
 			}
 
 			@Override
-			public SQLConfig createSQLConfig() {
+			public SQLConfig<String> createSQLConfig() {
 				return new DemoSQLConfig();
 			}
 
 			@Override
-			public FunctionParser createFunctionParser() {
+			public FunctionParser<String> createFunctionParser() {
 				return new DemoFunctionParser();
 			}
 
 			@Override
-			public SQLExecutor createSQLExecutor() {
+			public SQLExecutor<String> createSQLExecutor() {
 				return new DemoSQLExecutor();
 			}
 		};

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoController.java

@@ -29,7 +29,7 @@
 
 import apijson.RequestMethod;
 import apijson.StringUtil;
-import apijson.framework.APIJSONController;
+import apijson.framework.javax.APIJSONController;
 import apijson.orm.Parser;
 
 
@@ -46,10 +46,10 @@
  */
 @RestController
 @RequestMapping("")
-public class DemoController extends APIJSONController<Long> {
+public class DemoController extends APIJSONController<String> {
 
 	@Override
-	public Parser<Long> newParser(HttpSession session, RequestMethod method) {
+	public Parser<String> newParser(HttpSession session, RequestMethod method) {
 		return super.newParser(session, method).setNeedVerify(false);  // TODO 这里关闭校验，方便新手快速测试，实际线上项目建议开启
 	}
 

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoFunctionParser.java

@@ -7,12 +7,12 @@
 import apijson.NotNull;
 import apijson.RequestMethod;
 import apijson.StringUtil;
-import apijson.framework.APIJSONFunctionParser;
-import apijson.framework.APIJSONVerifier;
+import apijson.framework.javax.APIJSONFunctionParser;
+import apijson.framework.javax.APIJSONVerifier;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
-public class DemoFunctionParser extends APIJSONFunctionParser {
+public class DemoFunctionParser extends APIJSONFunctionParser<String> {
 	public DemoFunctionParser() {
 		this(null, null, 0, null, null);
 	}

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoObjectParser.java

@@ -8,11 +8,11 @@
 
 import apijson.NotNull;
 import apijson.RequestMethod;
-import apijson.framework.APIJSONObjectParser;
+import apijson.framework.javax.APIJSONObjectParser;
 import apijson.orm.Join;
 import apijson.orm.SQLConfig;
 
-public class DemoObjectParser extends APIJSONObjectParser {
+public class DemoObjectParser extends APIJSONObjectParser<String> {
 
     public DemoObjectParser(HttpSession session, @NotNull JSONObject request, String parentPath, SQLConfig arrayConfig
             , boolean isSubquery, boolean isTable, boolean isArrayMainTable) throws Exception {

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoParser.java

@@ -3,8 +3,8 @@
 import com.alibaba.fastjson.JSONObject;
 
 import apijson.RequestMethod;
-import apijson.framework.APIJSONObjectParser;
-import apijson.framework.APIJSONParser;
+import apijson.framework.javax.APIJSONObjectParser;
+import apijson.framework.javax.APIJSONParser;
 import apijson.orm.SQLConfig;
 
 public class DemoParser extends APIJSONParser<String> {
@@ -27,7 +27,7 @@ public DemoParser(RequestMethod method, boolean needVerify) {
 	// }
 
 	@Override
-	public APIJSONObjectParser createObjectParser(JSONObject request, String parentPath, SQLConfig arrayConfig, boolean isSubquery, boolean isTable, boolean isArrayMainTable) throws Exception {
+	public APIJSONObjectParser<String> createObjectParser(JSONObject request, String parentPath, SQLConfig arrayConfig, boolean isSubquery, boolean isTable, boolean isArrayMainTable) throws Exception {
 		return new DemoObjectParser(getSession(), request, parentPath, arrayConfig, isSubquery, isTable, isArrayMainTable).setMethod(getMethod()).setParser(this);
 	}
 

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoSQLConfig.java

@@ -19,7 +19,7 @@
 import com.alibaba.fastjson.annotation.JSONField;
 
 import apijson.RequestMethod;
-import apijson.framework.APIJSONSQLConfig;
+import apijson.framework.javax.APIJSONSQLConfig;
 import apijson.orm.AbstractSQLConfig;
 
 
@@ -29,7 +29,7 @@
  * https://github.com/Tencent/APIJSON/blob/master/%E8%AF%A6%E7%BB%86%E7%9A%84%E8%AF%B4%E6%98%8E%E6%96%87%E6%A1%A3.md#c-1-1%E4%BF%AE%E6%94%B9%E6%95%B0%E6%8D%AE%E5%BA%93%E9%93%BE%E6%8E%A5
  * @author Lemon
  */
-public class DemoSQLConfig extends APIJSONSQLConfig<Long> {
+public class DemoSQLConfig extends APIJSONSQLConfig<String> {
 
 	public DemoSQLConfig() {
 		super();

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DemoSQLExecutor.java

@@ -22,7 +22,7 @@
 import apijson.Log;
 import apijson.NotNull;
 import apijson.StringUtil;
-import apijson.framework.APIJSONSQLExecutor;
+import apijson.framework.javax.APIJSONSQLExecutor;
 import apijson.orm.SQLConfig;
 import lombok.extern.log4j.Log4j2;
 
@@ -32,7 +32,7 @@
  * @author Lemon
  */
 @Log4j2
-public class DemoSQLExecutor extends APIJSONSQLExecutor<Long> {
+public class DemoSQLExecutor extends APIJSONSQLExecutor<String> {
 	public static final String TAG = "DemoSQLExecutor";
 
 	// 适配连接池，如果这里能拿到连接池的有效 Connection，则 SQLConfig 不需要配置 dbVersion, dbUri, dbAccount,

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/DynamicDataSource.java

@@ -85,7 +85,7 @@ private void initJdbcDataSource() {
 			ItemDataSource dataSource = (ItemDataSource) dataSourceList.getDataSources().get(datasourceName);
 			DruidDataSource druid = (DruidDataSource) dataSource.getRealDataSource();
 			String url = druid.getDataSourceStat().getUrl(); // 数据库连接url
-			String schema = DataBaseUtil.getLibname(url); // 数据库名;
+			String schema = DataBaseUtil.getDbName(url); // 数据库名;
 			String database = JdbcUtils.getDbType(url).getDb().toUpperCase(); // 数据库类型
 			String dbAccount = druid.getUsername(); // 数据库用户名
 			String dbPassword = druid.getPassword(); // 数据库密码
@@ -111,9 +111,9 @@ public void initMQ_kafka() {
 		/* 1.创建kafka生产者的配置信息 */
 		Properties props = new Properties();
 		/*2.指定连接的kafka集群, broker-list */
-		props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "xxx:9092");  
+		props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "http://localhost:9092"); // TODO 改成你自己的
 		/*3.ack应答级别*/
-		props.put(ProducerConfig.ACKS_CONFIG, "all");
+		props.put(ProducerConfig.ACKS_CONFIG, "all"); // TODO 改成你自己的
 		/*4.重试次数*/ 
 		props.put(ProducerConfig.RETRIES_CONFIG, 3); 
 		/*5.批次大小，一次发送多少数据，当数据大于16k，生产者会发送数据到 kafka集群 */
@@ -128,11 +128,11 @@ public void initMQ_kafka() {
 
 
 		DynamicDataSource dynDataSource = new DynamicDataSource();
-		dynDataSource.setDatasourceName("kafka");
-		dynDataSource.setDatabase("MQ");
+		dynDataSource.setDatasourceName("kafka"); // TODO 改成你自己的
+		dynDataSource.setDatabase("MQ"); // TODO 改成你自己的
 		dynDataSource.setSchema(""); // 不需要配置数据库名
-		dynDataSource.setDbVersion("2.8.1"); // 后面做成动态的
-		dynDataSource.setClusterName("kafka");
+		dynDataSource.setDbVersion("2.8.1"); // TODO 改成你自己的 后面做成动态的
+		dynDataSource.setClusterName("kafka"); // TODO 改成你自己的
 		dynDataSource.setProps(props);
 		dataSourceMap.put(dynDataSource.getDatasourceName(), dynDataSource);
 	}

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/java/apijson/demo/KafkaSimpleProducer.java

@@ -12,7 +12,7 @@
 @Slf4j
 public class KafkaSimpleProducer {
 
-	public static int sendMessage(String datasource, Properties props,String topic, Object message) {
+	public static int sendMessage(String datasource, Properties props, String topic, Object message) {
 		KafkaProducer<String, Object> producer = null;
 		try {
 			/* 9.创建生产者对象 */
@@ -25,7 +25,7 @@ public static int sendMessage(String datasource, Properties props,String topic,
 			e.printStackTrace();
 			throw new IllegalArgumentException("动态数据源配置错误 " + datasource);
 		} finally {
-			if(producer != null) {
+			if (producer != null) {
 				/* 关闭资源 */  
 				producer.close();
 			}

APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka/src/main/resources/application.yml

@@ -22,9 +22,9 @@ spring:
       datasource:
         master:
           driver-class-name: com.mysql.cj.jdbc.Driver
-          url: jdbc:mysql://localhost:3306/xxxx?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true&useSSL=false
-          username: 
-          password: 
+          url: jdbc:mysql://localhost:3306?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true&useSSL=false
+          username: root
+          password: apijson
       filter:
         stat:
           log-slow-sql: true