diff --git a/README.md b/README.md
index d234e464..a8b99b07 100644
--- a/README.md
+++ b/README.md
@@ -2,26 +2,26 @@
# 概述
-uno('u:no,读wu no)提供基础的组件,来构建大型复杂应用的能力,截止于2023-07-06目前包含如下组件库:
+uno('u:no,读wu no)提供基础的组件,来构建大型复杂应用的能力。
-- core:核心库,提供通用的工具、事件总线、简易的类型系统、元数据转换,通用链式接口声明、简易的Task、Cache机制。
-- data:数据处理,包含通用查询模块、orm框架。
-- rule:规则引擎。
-- web:简易的web工具集,提供系统默认的HTTP请求端点。
-- test:基于spring环境方便使用的测试工具集。
+- core:核心库,提供通用的工具、事件总线、简易的类型系统、元数据转换,通用链式接口声明、简易的Task、Cache机制。
+- data:数据处理,包含通用查询模块、orm框架。
+- rule:规则引擎。
+- web:简易的web工具集,提供系统默认的HTTP请求端点。
+- test:基于spring环境方便使用的测试工具集。
- gis:构建mybatis的空间数据转换、jackson -> 标准geojson的转换、坐标系转换。
- auto:自动生成spi文件、还包括spring.factories。
- bom:项目包依赖集。
- plugins(未实现):通用的插件工具,包含微内核模式接口声明、jar包等第三方插件包加载与执行。
- components: 组件集合。
- - http: 构建openapi工具,响应式的http请求响应框架。
+ - http: 构建openapi工具,响应式的http请求响应框架。
- kafka:基于响应式背压封装的kafka。
- media:多媒体组件,基于命令模式提供通用api。
- netty:封装netty,构建无集群模式的RPC框架。
- sequential:时序数据的处理,包含数据接收、转换、处理,基于响应式,背压特性高性能的数据处理。
- websocket:封装websocket,具有数据批推,发布订阅模式,客户端可以使用Topic的路径树化。
-- starter:为各个组件编写spring-starter包。
+- starter:为各个组件编写spring-starter包。
diff --git a/pom.xml b/pom.xml
index 853c4747..85a1ae13 100644
--- a/pom.xml
+++ b/pom.xml
@@ -7,7 +7,7 @@
cc.alliounopom
- 1.1.5.RELEASE
+ 1.1.6-beta.1构建大型应用需要的基本能力 --- all in onehttps://github.com/b6688c/uno
@@ -36,7 +36,7 @@
212020.0.12
- 3.2.0
+ 3.2.13.2.13.8.13.1.0
@@ -200,50 +200,4 @@
-
-
- spring-milestones
- Spring Milestones
- https://repo.spring.io/milestone
-
- true
-
-
-
- spring-snapshots
- Spring Snapshots
- https://repo.spring.io/snapshot
-
- true
-
-
-
- snapshots
- https://oss.sonatype.org/content/repositories/snapshots/
-
- true
-
-
- true
-
-
-
-
-
- spring-milestones
- Spring Milestones
- https://repo.spring.io/milestone
-
- true
-
-
-
- spring-snapshots
- Spring Snapshots
- https://repo.spring.io/snapshot
-
- true
-
-
-
\ No newline at end of file
diff --git a/uno-auto/pom.xml b/uno-auto/pom.xml
index c0c40516..20ea35b4 100644
--- a/uno-auto/pom.xml
+++ b/uno-auto/pom.xml
@@ -5,18 +5,12 @@
unocc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.14.0.0uno-auto
-
- 8
- 8
- UTF-8
-
-
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/AbstractUnoProcessor.java b/uno-auto/src/main/java/cc/allio/uno/auto/AbstractUnoProcessor.java
index a3a866a3..18832b36 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/AbstractUnoProcessor.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/AbstractUnoProcessor.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto;
import javax.annotation.processing.AbstractProcessor;
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/BootAutoType.java b/uno-auto/src/main/java/cc/allio/uno/auto/BootAutoType.java
index a28f17d9..0e488cb8 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/BootAutoType.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/BootAutoType.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto;
/**
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/factories/AutoFactoriesProcessor.java b/uno-auto/src/main/java/cc/allio/uno/auto/factories/AutoFactoriesProcessor.java
index e7e8c482..81d1fb09 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/factories/AutoFactoriesProcessor.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/factories/AutoFactoriesProcessor.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.factories;
import cc.allio.uno.auto.AbstractUnoProcessor;
@@ -47,15 +31,13 @@
@SupportedAnnotationTypes("*")
@SupportedOptions("debug")
public class AutoFactoriesProcessor extends AbstractUnoProcessor {
- /**
- * The location to look for factories.
- *
Can be present in multiple JAR files.
- */
- private static final String FACTORIES_RESOURCE_LOCATION = "META-INF/spring.factories";
/**
* devtools,有 Configuration 注解的 jar 一般需要 devtools 配置文件
*/
private static final String DEVTOOLS_RESOURCE_LOCATION = "META-INF/spring-devtools.properties";
+ // Auto Configuration location
+ private static final String AUTO_CONFIGURATION_LOCATION = "META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports";
+
/**
* 数据承载
*/
@@ -123,10 +105,10 @@ private void generateFactoriesFiles() {
}
Filer filer = processingEnv.getFiler();
try {
- // 1. spring.factories
- FileObject factoriesFile = filer.createResource(StandardLocation.CLASS_OUTPUT, "", FACTORIES_RESOURCE_LOCATION);
- FactoriesFiles.writeFactoriesFile(factories, factoriesFile.openOutputStream());
- String classesPath = factoriesFile.toUri().toString().split("classes")[0];
+ // 1. auto configuration file
+ FileObject autoConfigurationFile = filer.createResource(StandardLocation.CLASS_OUTPUT, "", AUTO_CONFIGURATION_LOCATION);
+ FactoriesFiles.writeFactoriesFile(factories, autoConfigurationFile.openOutputStream());
+ String classesPath = autoConfigurationFile.toUri().toString().split("classes")[0];
Path projectPath = Paths.get(new URI(classesPath)).getParent();
// 2. devtools 配置,因为有 @Configuration 注解的需要 devtools
String projectName = projectPath.getFileName().toString();
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/factories/FactoriesFiles.java b/uno-auto/src/main/java/cc/allio/uno/auto/factories/FactoriesFiles.java
index c75cd23e..e653c278 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/factories/FactoriesFiles.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/factories/FactoriesFiles.java
@@ -1,22 +1,5 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.factories;
-
import cc.allio.uno.auto.model.MultiSetMap;
import java.io.BufferedWriter;
@@ -34,48 +17,48 @@
* @author L.cm
*/
class FactoriesFiles {
- private static final Charset UTF_8 = StandardCharsets.UTF_8;
+ private static final Charset UTF_8 = StandardCharsets.UTF_8;
- /**
- * 写出 spring.factories 文件
- * @param factories factories 信息
- * @param output 输出流
- * @throws IOException 异常信息
- */
- static void writeFactoriesFile(MultiSetMap factories,
- OutputStream output) throws IOException {
- BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8));
- Set keySet = factories.keySet();
- for (String key : keySet) {
- Set values = factories.get(key);
- if (values == null || values.isEmpty()) {
- continue;
- }
- writer.write(key);
- writer.write("=\\\n ");
- StringJoiner joiner = new StringJoiner(",\\\n ");
- for (String value : values) {
- joiner.add(value);
- }
- writer.write(joiner.toString());
- writer.newLine();
- }
- writer.flush();
- output.close();
- }
+ /**
+ * 写出 spring.factories 文件
+ *
+ * @param factories factories 信息
+ * @param output 输出流
+ * @throws IOException 异常信息
+ */
+ static void writeFactoriesFile(MultiSetMap factories,
+ OutputStream output) throws IOException {
+ BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8));
+ Set keySet = factories.keySet();
+ for (String key : keySet) {
+ Set values = factories.get(key);
+ if (values == null || values.isEmpty()) {
+ continue;
+ }
+ StringJoiner joiner = new StringJoiner("\n");
+ for (String value : values) {
+ joiner.add(value);
+ }
+ writer.write(joiner.toString());
+ writer.newLine();
+ }
+ writer.flush();
+ output.close();
+ }
- /**
- * 写出 spring-devtools.properties
- * @param projectName 项目名
- * @param output 输出流
- * @throws IOException 异常信息
- */
- static void writeDevToolsFile(String projectName,
- OutputStream output) throws IOException {
- BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8));
- String format = "restart.include.%s=/%s[\\\\w-]+\\.jar";
- writer.write(String.format(format, projectName, projectName));
- writer.flush();
- output.close();
- }
+ /**
+ * 写出 spring-devtools.properties
+ *
+ * @param projectName 项目名
+ * @param output 输出流
+ * @throws IOException 异常信息
+ */
+ static void writeDevToolsFile(String projectName,
+ OutputStream output) throws IOException {
+ BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8));
+ String format = "restart.include.%s=/%s[\\\\w-]+\\.jar";
+ writer.write(String.format(format, projectName, projectName));
+ writer.flush();
+ output.close();
+ }
}
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/model/MultiSetMap.java b/uno-auto/src/main/java/cc/allio/uno/auto/model/MultiSetMap.java
index c5d7dcec..b9caef01 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/model/MultiSetMap.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/model/MultiSetMap.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.model;
import java.util.*;
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/model/Sets.java b/uno-auto/src/main/java/cc/allio/uno/auto/model/Sets.java
index 339acf31..794b3301 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/model/Sets.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/model/Sets.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.model;
import java.util.Objects;
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/model/TypeHelper.java b/uno-auto/src/main/java/cc/allio/uno/auto/model/TypeHelper.java
index 7c572d1d..76359e3c 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/model/TypeHelper.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/model/TypeHelper.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.model;
import javax.annotation.processing.ProcessingEnvironment;
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoService.java b/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoService.java
index 96fa4c90..5bf34afb 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoService.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoService.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.service;
import java.lang.annotation.*;
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoServiceProcessor.java b/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoServiceProcessor.java
index b1441c42..807fa689 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoServiceProcessor.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/service/AutoServiceProcessor.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.service;
import cc.allio.uno.auto.AbstractUnoProcessor;
diff --git a/uno-auto/src/main/java/cc/allio/uno/auto/service/ServicesFiles.java b/uno-auto/src/main/java/cc/allio/uno/auto/service/ServicesFiles.java
index 1302dbf3..21942622 100644
--- a/uno-auto/src/main/java/cc/allio/uno/auto/service/ServicesFiles.java
+++ b/uno-auto/src/main/java/cc/allio/uno/auto/service/ServicesFiles.java
@@ -1,19 +1,3 @@
-/*
- * Copyright (c) 2018-2028, DreamLu All rights reserved.
- *
- * Redistribution and use in source and binary forms, with or without
- * modification, are permitted provided that the following conditions are met:
- *
- * Redistributions of source code must retain the above copyright notice,
- * this list of conditions and the following disclaimer.
- * Redistributions in binary form must reproduce the above copyright
- * notice, this list of conditions and the following disclaimer in the
- * documentation and/or other materials provided with the distribution.
- * Neither the name of the dreamlu.net developer nor the names of its
- * contributors may be used to endorse or promote products derived from
- * this software without specific prior written permission.
- * Author: DreamLu 卢春梦 (596392912@qq.com)
- */
package cc.allio.uno.auto.service;
import java.io.*;
diff --git a/uno-bom/pom.xml b/uno-bom/pom.xml
index f75aa6af..ca43b684 100644
--- a/uno-bom/pom.xml
+++ b/uno-bom/pom.xml
@@ -5,19 +5,19 @@
org.springframework.bootspring-boot-starter-parent
- 3.2.0
+ 3.2.24.0.0cc.alliouno-bom
- 1.1.5.RELEASE
+ 1.1.6-beta.1pom
- 1.1.5.RELEASE
+ 1.1.6-beta.11.5.9
@@ -34,16 +34,15 @@
2.2.171.6.23.0.0
-
- 3.0.3-SNAPSHOT
- 3.5.3
+ 3.0.3
+ 3.5.51.2.208.0.2212.2.0.142.2.228.4.1.jre8
- 4.1.3
+ 4.3.027.03.7.0
@@ -117,11 +116,6 @@
uno-starter-kafka${uno.version}
-
- cc.allio
- uno-starter-liquibase
- ${uno.version}
- cc.alliouno-starter-websocket
@@ -143,6 +137,51 @@
uno-data${uno.version}
+
+ cc.allio
+ uno-data-test
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-api
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-db
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-elasticsearch
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-influxdb
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-mongodb
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-neo4j
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-redis
+ ${uno.version}
+
+
+ cc.allio
+ uno-data-sql
+ ${uno.version}
+ cc.alliouno-web
diff --git a/uno-components/pom.xml b/uno-components/pom.xml
index 84f65179..a893d9af 100644
--- a/uno-components/pom.xml
+++ b/uno-components/pom.xml
@@ -5,7 +5,7 @@
unocc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.14.0.0
@@ -20,11 +20,6 @@
uno-component-netty
-
- 8
- 8
-
-
cc.allio
diff --git a/uno-components/uno-component-http/pom.xml b/uno-components/uno-component-http/pom.xml
index 5a189766..e9632cde 100644
--- a/uno-components/uno-component-http/pom.xml
+++ b/uno-components/uno-component-http/pom.xml
@@ -5,7 +5,7 @@
uno-componentscc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.1../pom.xml4.0.0
diff --git a/uno-components/uno-component-http/src/test/java/cc/allio/uno/component/http/api/OpenApiV3AssemblyTest.java b/uno-components/uno-component-http/src/test/java/cc/allio/uno/component/http/api/OpenApiV3AssemblyTest.java
index f03aceb6..d254ae10 100644
--- a/uno-components/uno-component-http/src/test/java/cc/allio/uno/component/http/api/OpenApiV3AssemblyTest.java
+++ b/uno-components/uno-component-http/src/test/java/cc/allio/uno/component/http/api/OpenApiV3AssemblyTest.java
@@ -36,7 +36,7 @@ protected void onInit() throws Throwable {
@Test
void testFindByPath() {
- StepVerifier.create(converter.find("/user/get"))
+ StepVerifier.create(converter.find("/user/getValue"))
.expectNextCount(1)
.verifyComplete();
}
@@ -72,7 +72,7 @@ void testAll() {
@Test
void testSwap() {
StepVerifier.create(
- converter.find("/user/get")
+ converter.find("/user/getValue")
.flatMap(swapper -> swapper
.addParameter("id", "1")
.swap()
@@ -85,7 +85,7 @@ void testSwap() {
@Test
void testAddToken() {
StepVerifier.create(
- converter.find("/user/get")
+ converter.find("/user/getValue")
.flatMap(swapper -> swapper
.addParameter("id", "1")
.swap()
diff --git a/uno-components/uno-component-kafka/pom.xml b/uno-components/uno-component-kafka/pom.xml
index a51878a2..0b634a1d 100644
--- a/uno-components/uno-component-kafka/pom.xml
+++ b/uno-components/uno-component-kafka/pom.xml
@@ -5,18 +5,12 @@
uno-componentscc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.14.0.0uno-component-kafka
-
- 8
- 8
- UTF-8
-
-
io.projectreactor.kafka
diff --git a/uno-components/uno-component-kafka/src/main/java/cc/allio/uno/component/kafka/UnoKafkaReceiver.java b/uno-components/uno-component-kafka/src/main/java/cc/allio/uno/component/kafka/UnoKafkaReceiver.java
index 6aeb94a8..7b325a8f 100644
--- a/uno-components/uno-component-kafka/src/main/java/cc/allio/uno/component/kafka/UnoKafkaReceiver.java
+++ b/uno-components/uno-component-kafka/src/main/java/cc/allio/uno/component/kafka/UnoKafkaReceiver.java
@@ -121,7 +121,7 @@ public Flux doSubscribe(int bufferSize) {
/**
* {@link org.apache.kafka.clients.consumer.Consumer#assignment()}
*
- * @return The set of partitions currently assigned to this consumer
+ * @return The setValue of partitions currently assigned to this consumer
*/
public Flux assignment() {
return receiver.doOnConsumer(org.apache.kafka.clients.consumer.Consumer::assignment)
diff --git a/uno-components/uno-component-netty/pom.xml b/uno-components/uno-component-netty/pom.xml
index 0fc3fe93..c0ff9195 100644
--- a/uno-components/uno-component-netty/pom.xml
+++ b/uno-components/uno-component-netty/pom.xml
@@ -6,17 +6,11 @@
uno-componentscc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.1uno-component-netty
-
- 8
- 8
- UTF-8
-
-
cc.allio
diff --git a/uno-components/uno-component-netty/src/main/java/cc/allio/uno/component/netty/AbstractNettyService.java b/uno-components/uno-component-netty/src/main/java/cc/allio/uno/component/netty/AbstractNettyService.java
index e4e70b76..e8b6f7da 100644
--- a/uno-components/uno-component-netty/src/main/java/cc/allio/uno/component/netty/AbstractNettyService.java
+++ b/uno-components/uno-component-netty/src/main/java/cc/allio/uno/component/netty/AbstractNettyService.java
@@ -44,7 +44,7 @@ public abstract class AbstractNettyService implements RemoteService {
/**
* 请求-响应,他们使用的id都是相同的
* 当请求来到时,根据请求的id put这个promisor对象
- * 当响应到来时,根据响应的id,get这个promisor对象并向 set promise对象
+ * 当响应到来时,根据响应的id,get这个promisor对象并向 setValue promise对象
*/
private final ConcurrentHashMap promises = new ConcurrentHashMap<>();
/**
diff --git a/uno-components/uno-component-sequential/pom.xml b/uno-components/uno-component-sequential/pom.xml
index 9cffbd4e..da635e60 100644
--- a/uno-components/uno-component-sequential/pom.xml
+++ b/uno-components/uno-component-sequential/pom.xml
@@ -5,18 +5,12 @@
uno-componentscc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.14.0.0uno-component-sequential
-
- 8
- 8
- UTF-8
-
-
cc.allio
@@ -29,7 +23,7 @@
cc.allio
- uno-data
+ uno-data-elasticsearchorg.springframework
diff --git a/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/context/DefaultSequentialContext.java b/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/context/DefaultSequentialContext.java
index 29662296..dc9fbc07 100644
--- a/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/context/DefaultSequentialContext.java
+++ b/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/context/DefaultSequentialContext.java
@@ -6,7 +6,7 @@
import cc.allio.uno.core.bus.DefaultEventContext;
import cc.allio.uno.core.util.id.IdGenerator;
import cc.allio.uno.component.sequential.Sequential;
-import cc.allio.uno.core.util.CoreBeanUtil;
+import cc.allio.uno.core.util.BeanUtils;
import org.springframework.context.ApplicationContext;
import java.util.*;
@@ -71,7 +71,7 @@ public Long getContextId() {
@Override
public Sequential getSequential() {
- return CoreBeanUtil.copy(sequential, sequential.getClass());
+ return BeanUtils.copy(sequential, sequential.getClass());
}
@Override
diff --git a/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/process/handle/AppendProcessHandler.java b/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/process/handle/AppendProcessHandler.java
index 4483f29d..eb802dd0 100644
--- a/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/process/handle/AppendProcessHandler.java
+++ b/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/process/handle/AppendProcessHandler.java
@@ -32,7 +32,7 @@ public interface AppendProcessHandler extends Comparable {
* is less than, equal to, or greater than the specified object.
* @throws NullPointerException if the specified object is null
* @throws ClassCastException if the specified object's type prevents it
- * from being compared to this object.
+ * xxxx being compared to this object.
* @see Comparable#compareTo(Object)
*/
@Override
diff --git a/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/washer/WashMachine.java b/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/washer/WashMachine.java
index d2f58efd..5c24312f 100644
--- a/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/washer/WashMachine.java
+++ b/uno-components/uno-component-sequential/src/main/java/cc/allio/uno/component/sequential/washer/WashMachine.java
@@ -3,8 +3,9 @@
import cc.allio.uno.component.sequential.context.SequentialContext;
import cc.allio.uno.component.sequential.Sequential;
import cc.allio.uno.core.reactive.BufferRate;
-import cc.allio.uno.data.orm.executor.SQLCommandExecutor;
-import cc.allio.uno.data.orm.executor.SQLCommandExecutorFactory;
+import cc.allio.uno.data.orm.executor.CommandExecutor;
+import cc.allio.uno.data.orm.executor.CommandExecutorFactory;
+import cc.allio.uno.data.orm.executor.options.ExecutorKey;
import com.google.common.collect.Lists;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
@@ -42,7 +43,7 @@ public class WashMachine {
this.recorderDisposable =
BufferRate.create(Flux.create(sink -> recorder = sink))
.doOnNext(records -> {
- SQLCommandExecutor sqlExecutor = SQLCommandExecutorFactory.getSQLExecutor(SQLCommandExecutor.ELASTICSEARCH_SQL_COMMAND_EXECUTOR_KEY);
+ CommandExecutor sqlExecutor = CommandExecutorFactory.getDSLExecutor(ExecutorKey.ELASTICSEARCH);
if (sqlExecutor != null) {
sqlExecutor.batchInsertPojos(records);
}
diff --git a/uno-components/uno-component-sequential/src/test/java/cc/allio/uno/component/sequential/dispatch/DispatchDispatcherTest.java b/uno-components/uno-component-sequential/src/test/java/cc/allio/uno/component/sequential/dispatch/DispatchDispatcherTest.java
index 2ba1cf99..3e38e4d9 100644
--- a/uno-components/uno-component-sequential/src/test/java/cc/allio/uno/component/sequential/dispatch/DispatchDispatcherTest.java
+++ b/uno-components/uno-component-sequential/src/test/java/cc/allio/uno/component/sequential/dispatch/DispatchDispatcherTest.java
@@ -3,7 +3,7 @@
import cc.allio.uno.component.sequential.*;
import cc.allio.uno.component.sequential.bus.SequentialEventBus;
import cc.allio.uno.component.sequential.process.DefaultProcessor;
-import cc.allio.uno.core.util.CoreBeanUtil;
+import cc.allio.uno.core.util.BeanUtils;
import cc.allio.uno.test.RunTest;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
@@ -12,7 +12,7 @@
import static org.junit.jupiter.api.Assertions.assertDoesNotThrow;
-@RunTest(components = {DefaultProcessor.class, SequentialEventBus.class, CoreBeanUtil.class, SubscriptionProperties.class, SubscriptionPropertiesTypeManager.class})
+@RunTest(components = {DefaultProcessor.class, SequentialEventBus.class, BeanUtils.class, SubscriptionProperties.class, SubscriptionPropertiesTypeManager.class})
@Slf4j
class DispatchDispatcherTest {
diff --git a/uno-components/uno-component-websocket/pom.xml b/uno-components/uno-component-websocket/pom.xml
index 818ee4a2..79e399b7 100644
--- a/uno-components/uno-component-websocket/pom.xml
+++ b/uno-components/uno-component-websocket/pom.xml
@@ -5,7 +5,7 @@
uno-componentscc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.14.0.0
@@ -13,12 +13,6 @@
提供封装的websocket,包含鉴权、心跳、连接管理、实现方只需要关注消息的处理
-
- 8
- 8
- UTF-8
-
-
org.springframework.boot
diff --git a/uno-components/uno-component-websocket/src/main/java/cc/allio/uno/component/websocket/WebSocketEndpoint.java b/uno-components/uno-component-websocket/src/main/java/cc/allio/uno/component/websocket/WebSocketEndpoint.java
index b6cb63c1..0732c923 100644
--- a/uno-components/uno-component-websocket/src/main/java/cc/allio/uno/component/websocket/WebSocketEndpoint.java
+++ b/uno-components/uno-component-websocket/src/main/java/cc/allio/uno/component/websocket/WebSocketEndpoint.java
@@ -69,10 +69,10 @@ public interface WebSocketEndpoint {
*
* @return WebSocketProperties实例对象
* @throws NoSuchBeanDefinitionException 没有找到{@link WebSocketProperties}的定义抛出
- * @throws NullPointerException {@link CoreBeanUtil#getContext()}为空时抛出
+ * @throws NullPointerException {@link BeanUtils#getContext()}为空时抛出
*/
default WebSocketProperties getProperties() {
- return CoreBeanUtil.getBean(WebSocketProperties.class);
+ return BeanUtils.getBean(WebSocketProperties.class);
}
diff --git a/uno-core/pom.xml b/uno-core/pom.xml
index dd1ef514..d0f933bc 100644
--- a/uno-core/pom.xml
+++ b/uno-core/pom.xml
@@ -5,7 +5,7 @@
unocc.allio
- 1.1.5.RELEASE
+ 1.1.6-beta.14.0.0
@@ -73,6 +73,10 @@
com.fasterxml.jackson.corejackson-annotations
+
+ com.fasterxml.jackson.datatype
+ jackson-datatype-jsr310
+ io.projectreactorreactor-core
diff --git a/uno-core/src/main/java/cc/allio/uno/core/api/Adapter.java b/uno-core/src/main/java/cc/allio/uno/core/api/Adapter.java
new file mode 100644
index 00000000..8d97e5f4
--- /dev/null
+++ b/uno-core/src/main/java/cc/allio/uno/core/api/Adapter.java
@@ -0,0 +1,27 @@
+package cc.allio.uno.core.api;
+
+/**
+ * 通用适配器定义
+ *
+ * @author jiangwei
+ * @date 2024/1/9 16:04
+ * @since 1.1.6
+ */
+public interface Adapter {
+
+ /**
+ * 根据原始的类型获取目标转换的类型
+ *
+ * @param o 原始类型
+ * @return 转换类型
+ */
+ R adapt(O o);
+
+ /**
+ * 根据目标的类型获取原始的类型
+ *
+ * @param r 目标类型
+ * @return 原始类型
+ */
+ O reverse(R r);
+}
diff --git a/uno-core/src/main/java/cc/allio/uno/core/api/EqualsTo.java b/uno-core/src/main/java/cc/allio/uno/core/api/EqualsTo.java
new file mode 100644
index 00000000..d8cd4369
--- /dev/null
+++ b/uno-core/src/main/java/cc/allio/uno/core/api/EqualsTo.java
@@ -0,0 +1,20 @@
+package cc.allio.uno.core.api;
+
+/**
+ * Java中接口类型不存在{@link Object#equals(Object)}方法,该接口的定义为了能够使得Java接口能够有类似的方法。
+ *