8 Commits
Author SHA1 Message Date
timi 5770a41893 Merge pull request 'v0.0.3' (#8) from dev into master
Reviewed-on: #8
2026-04-27 15:50:11 +00:00
timi a919cf0a52 Merge pull request 'v0.0.2' (#7) from dev into master
Reviewed-on: #7
2026-01-19 09:24:19 +00:00
timi 5612d6a24a Merge pull request 'v0.0.2' (#6) from dev into master
Reviewed-on: #6
2026-01-19 09:14:14 +00:00
timi db530c1fed Merge pull request 'v0.0.2' (#5) from dev into master
Reviewed-on: #5
2026-01-19 09:08:52 +00:00
timi 1fe9cf7b77 Merge pull request 'v0.0.2' (#4) from dev into master
Reviewed-on: #4
2026-01-19 09:03:06 +00:00
timi 0d21b154ca Merge pull request 'v0.0.2' (#3) from dev into master
Reviewed-on: #3
2026-01-19 08:59:04 +00:00
timi acba4c11d9 Merge pull request 'v0.0.2' (#2) from dev into master
Reviewed-on: #2
2026-01-19 06:43:33 +00:00
timi d21fba0fc1 Merge pull request 'v0.0.2' (#1) from dev into master
Reviewed-on: #1
2026-01-19 06:30:23 +00:00
17 changed files with 535 additions and 655 deletions
-2
View File
@@ -1,2 +0,0 @@
/cache
/project.local.yml
-154
View File
@@ -1,154 +0,0 @@
# the name by which the project can be referenced within Serena
project_name: "timi-java"
# list of languages for which language servers are started; choose from:
# al bash clojure cpp csharp
# csharp_omnisharp dart elixir elm erlang
# fortran fsharp go groovy haskell
# haxe java julia kotlin lua
# markdown
# matlab nix pascal perl php
# php_phpactor powershell python python_jedi r
# rego ruby ruby_solargraph rust scala
# swift terraform toml typescript typescript_vts
# vue yaml zig
# (This list may be outdated. For the current list, see values of Language enum here:
# https://github.com/oraios/serena/blob/main/src/solidlsp/ls_config.py
# For some languages, there are alternative language servers, e.g. csharp_omnisharp, ruby_solargraph.)
# Note:
# - For C, use cpp
# - For JavaScript, use typescript
# - For Free Pascal/Lazarus, use pascal
# Special requirements:
# Some languages require additional setup/installations.
# See here for details: https://oraios.github.io/serena/01-about/020_programming-languages.html#language-servers
# When using multiple languages, the first language server that supports a given file will be used for that file.
# The first language is the default language and the respective language server will be used as a fallback.
# Note that when using the JetBrains backend, language servers are not used and this list is correspondingly ignored.
languages:
- java
# the encoding used by text files in the project
# For a list of possible encodings, see https://docs.python.org/3.11/library/codecs.html#standard-encodings
encoding: "utf-8"
# line ending convention to use when writing source files.
# Possible values: unset (use global setting), "lf", "crlf", or "native" (platform default)
# This does not affect Serena's own files (e.g. memories and configuration files), which always use native line endings.
line_ending:
# The language backend to use for this project.
# If not set, the global setting from serena_config.yml is used.
# Valid values: LSP, JetBrains
# Note: the backend is fixed at startup. If a project with a different backend
# is activated post-init, an error will be returned.
language_backend:
# whether to use project's .gitignore files to ignore files
ignore_all_files_in_gitignore: true
# advanced configuration option allowing to configure language server-specific options.
# Maps the language key to the options.
# Have a look at the docstring of the constructors of the LS implementations within solidlsp (e.g., for C# or PHP) to see which options are available.
# No documentation on options means no options are available.
ls_specific_settings: {}
# list of additional paths to ignore in this project.
# Same syntax as gitignore, so you can use * and **.
# Note: global ignored_paths from serena_config.yml are also applied additively.
ignored_paths: []
# whether the project is in read-only mode
# If set to true, all editing tools will be disabled and attempts to use them will result in an error
# Added on 2025-04-18
read_only: false
# list of tool names to exclude.
# This extends the existing exclusions (e.g. from the global configuration)
#
# Below is the complete list of tools for convenience.
# To make sure you have the latest list of tools, and to view their descriptions,
# execute `uv run scripts/print_tool_overview.py`.
#
# * `activate_project`: Activates a project based on the project name or path.
# * `check_onboarding_performed`: Checks whether project onboarding was already performed.
# * `create_text_file`: Creates/overwrites a file in the project directory.
# * `delete_memory`: Delete a memory file. Should only happen if a user asks for it explicitly,
# for example by saying that the information retrieved from a memory file is no longer correct
# or no longer relevant for the project.
# * `edit_memory`: Replaces content matching a regular expression in a memory.
# * `execute_shell_command`: Executes a shell command.
# * `find_file`: Finds files in the given relative paths
# * `find_referencing_symbols`: Finds symbols that reference the given symbol using the language server backend
# * `find_symbol`: Performs a global (or local) search using the language server backend.
# * `get_current_config`: Prints the current configuration of the agent, including the active and available projects, tools, contexts, and modes.
# * `get_symbols_overview`: Gets an overview of the top-level symbols defined in a given file.
# * `initial_instructions`: Provides instructions Serena usage (i.e. the 'Serena Instructions Manual')
# for clients that do not read the initial instructions when the MCP server is connected.
# * `insert_after_symbol`: Inserts content after the end of the definition of a given symbol.
# * `insert_before_symbol`: Inserts content before the beginning of the definition of a given symbol.
# * `list_dir`: Lists files and directories in the given directory (optionally with recursion).
# * `list_memories`: List available memories. Any memory can be read using the `read_memory` tool.
# * `onboarding`: Performs onboarding (identifying the project structure and essential tasks, e.g. for testing or building).
# * `read_file`: Reads a file within the project directory.
# * `read_memory`: Read the content of a memory file. This tool should only be used if the information
# is relevant to the current task. You can infer whether the information
# is relevant from the memory file name.
# You should not read the same memory file multiple times in the same conversation.
# * `rename_memory`: Renames or moves a memory. Moving between project and global scope is supported
# (e.g., renaming "global/foo" to "bar" moves it from global to project scope).
# * `rename_symbol`: Renames a symbol throughout the codebase using language server refactoring capabilities.
# For JB, we use a separate tool.
# * `replace_content`: Replaces content in a file (optionally using regular expressions).
# * `replace_symbol_body`: Replaces the full definition of a symbol using the language server backend.
# * `safe_delete_symbol`:
# * `search_for_pattern`: Performs a search for a pattern in the project.
# * `write_memory`: Write some information (utf-8-encoded) about this project that can be useful for future tasks to a memory in md format.
# The memory name should be meaningful.
excluded_tools: []
# list of tools to include that would otherwise be disabled (particularly optional tools that are disabled by default).
# This extends the existing inclusions (e.g. from the global configuration).
included_optional_tools: []
# fixed set of tools to use as the base tool set (if non-empty), replacing Serena's default set of tools.
# This cannot be combined with non-empty excluded_tools or included_optional_tools.
fixed_tools: []
# list of mode names to that are always to be included in the set of active modes
# The full set of modes to be activated is base_modes + default_modes.
# If the setting is undefined, the base_modes from the global configuration (serena_config.yml) apply.
# Otherwise, this setting overrides the global configuration.
# Set this to [] to disable base modes for this project.
# Set this to a list of mode names to always include the respective modes for this project.
base_modes:
# list of mode names that are to be activated by default.
# The full set of modes to be activated is base_modes + default_modes.
# If the setting is undefined, the default_modes from the global configuration (serena_config.yml) apply.
# Otherwise, this overrides the setting from the global configuration (serena_config.yml).
# This setting can, in turn, be overridden by CLI parameters (--mode).
default_modes:
# initial prompt for the project. It will always be given to the LLM upon activating the project
# (contrary to the memories, which are loaded on demand).
initial_prompt: ""
# time budget (seconds) per tool call for the retrieval of additional symbol information
# such as docstrings or parameter information.
# This overrides the corresponding setting in the global configuration; see the documentation there.
# If null or missing, use the setting from the global configuration.
symbol_info_budget:
# list of regex patterns which, when matched, mark a memory entry as read‑only.
# Extends the list from the global configuration, merging the two lists.
read_only_memory_patterns: []
# list of regex patterns for memories to completely ignore.
# Matching memories will not appear in list_memories or activate_project output
# and cannot be accessed via read_memory or write_memory.
# To access ignored memory files, use the read_file tool on the raw file path.
# Extends the list from the global configuration, merging the two lists.
# Example: ["_archive/.*", "_episodes/.*"]
ignored_memory_patterns: []
+3 -3
View File
@@ -6,7 +6,7 @@
<groupId>com.imyeyu.java</groupId>
<artifactId>timi-java</artifactId>
<version>0.1.0</version>
<version>0.0.3</version>
<packaging>jar</packaging>
<properties>
@@ -50,7 +50,7 @@
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.46</version>
<version>1.18.36</version>
</dependency>
</dependencies>
</plugin>
@@ -92,7 +92,7 @@
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.46</version>
<version>1.18.40</version>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
+1 -41
View File
@@ -2,10 +2,8 @@ package com.imyeyu.java;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Objects;
@@ -74,39 +72,6 @@ public interface TimiJava {
return !isEmpty(object);
}
static boolean hasEmpty(Object... objects) {
for (Object object : objects) {
if (isEmpty(object)) {
return true;
}
}
return false;
}
static boolean allEmpty(Object... objects) {
for (Object object : objects) {
if (isNotEmpty(object)) {
return false;
}
}
return true;
}
static boolean allNotEmpty(Object... objects) {
for (Object object : objects) {
if (isEmpty(object)) {
return false;
}
}
return true;
}
static <T> T nullIfEmpty(T object) {
if (isEmpty(object)) {
return null;
}
return object;
}
/**
* 为空时取默认值
*
@@ -116,7 +81,7 @@ public interface TimiJava {
* @param <T> 对象类型
*/
static <T> T defaultIfNull(T obj, T defaultObj) {
return obj != null ? obj : defaultObj;
return Objects.requireNonNullElse(obj, defaultObj);
}
/**
@@ -191,9 +156,4 @@ public interface TimiJava {
static <T> Iterable<T> safeIterable(Iterable<T> iterable) {
return defaultIfNull(iterable, Collections::emptyIterator);
}
@SafeVarargs
static <T> List<T> ofList(T... objs) {
return objs == null ? List.of() : Arrays.stream(objs).filter(Objects::nonNull).toList();
}
}
@@ -1,62 +0,0 @@
package com.imyeyu.java.bean;
import lombok.Getter;
import java.util.Map;
/**
* 致命错误
*
* @author 夜雨
* @since 2023-04-27 15:55
*/
@Getter
public class ActionError extends AssertionError {
/** 代码 */
protected final ResultCode code;
/** 消息代码 */
protected final String messageCode;
/** 消息插值参数 */
protected final transient Map<String, Object> messageArgs;
/** @param code 代码 */
public ActionError(ResultCode code) {
this(code, code.toString());
}
/**
* 构造器
*
* @param code 代码
* @param messageCode 消息代码
*/
public ActionError(ResultCode code, String messageCode) {
this(code, messageCode, null);
}
/**
* 构造器
*
* @param code 代码
* @param messageCode 消息代码
* @param messageArgs 消息插值参数
*/
public ActionError(ResultCode code, String messageCode, Map<String, Object> messageArgs) {
super(messageCode);
this.code = code;
this.messageCode = messageCode;
this.messageArgs = messageArgs;
}
/**
* 转为通用响应
*
* @return 响应
*/
public Response<?> toResponse() {
return new Response<>(code).messageCode(messageCode, messageArgs);
}
}
@@ -1,133 +0,0 @@
package com.imyeyu.java.bean;
import com.imyeyu.java.TimiJava;
import lombok.Getter;
import java.util.Map;
/**
* 通用运行时异常,附加通用代码和消息代码
*
* @author 夜雨
* @since 2021-05-20 15:18
*/
@Getter
public class ActionException extends RuntimeException {
/** 代码 */
protected final ResultCode code;
/** 消息代码 */
protected final String messageCode;
/** 消息插值参数 */
protected final transient Map<String, Object> messageArgs;
/** @param code 代码 */
public ActionException(ResultCode code) {
this(code, code.toString());
}
/**
* 构造器
*
* @param code 代码
* @param messageCode 消息代码
*/
public ActionException(ResultCode code, String messageCode) {
this(code, messageCode, (Map<String, Object>) null);
}
/**
* 构造器
*
* @param code 代码
* @param messageCode 消息代码
* @param messageArgs 消息插值参数
*/
public ActionException(ResultCode code, String messageCode, Map<String, Object> messageArgs) {
super(messageCode);
this.code = code;
this.messageCode = messageCode;
this.messageArgs = messageArgs;
}
/**
* 构造器
*
* @param code 代码
* @param messageCode 消息代码
* @param e 异常
*/
public ActionException(ResultCode code, String messageCode, Throwable e) {
super(messageCode, e);
this.code = code;
this.messageCode = messageCode;
this.messageArgs = null;
}
/**
* 转为通用响应
*
* @return 响应
*/
public Response<?> toResponse() {
return new Response<>(code).messageCode(messageCode, messageArgs);
}
public static <T> T required(T t, String messageCode) {
if (TimiJava.isEmpty(t)) {
throw new ActionException(ResultCode.ARG_MISS, messageCode);
}
return t;
}
public static <T> T required(T t, String messageCode, Map<String, Object> messageArgs) {
if (TimiJava.isEmpty(t)) {
throw new ActionException(ResultCode.ARG_MISS, messageCode, messageArgs);
}
return t;
}
public static <T> void requiredNull(T t, String messageCode) throws ActionException {
if (t != null) {
throw new ActionException(ResultCode.ERROR, messageCode);
}
}
public static <T> void requiredNull(T t, String messageCode, Map<String, Object> messageArgs) throws ActionException {
if (t != null) {
throw new ActionException(ResultCode.ERROR, messageCode, messageArgs);
}
}
public static void requiredTrue(boolean bool, String messageCode) throws ActionException {
if (bool) {
return;
}
throw new ActionException(ResultCode.ERROR, messageCode);
}
public static void requiredTrue(boolean bool, String messageCode, Map<String, Object> messageArgs) throws ActionException {
if (bool) {
return;
}
throw new ActionException(ResultCode.ERROR, messageCode, messageArgs);
}
public static void requiredTrue(CallbackReturn<Boolean> callback, String messageCode) throws ActionException {
ActionException.required(callback, "not found callback");
if (callback.handler()) {
return;
}
throw new ActionException(ResultCode.ERROR, messageCode);
}
public static void requiredTrue(CallbackReturn<Boolean> callback, String messageCode, Map<String, Object> messageArgs) throws ActionException {
ActionException.required(callback, "not found callback");
if (callback.handler()) {
return;
}
throw new ActionException(ResultCode.ERROR, messageCode, messageArgs);
}
}
@@ -30,22 +30,4 @@ public class BasePage {
public void next() {
index++;
}
/**
* 获取偏移量
*
* @return 偏移量
*/
public long getOffset() {
return (long) index * size;
}
/**
* 获取限制数量
*
* @return 限制数量
*/
public long getLimit() {
return size;
}
}
@@ -0,0 +1,81 @@
package com.imyeyu.java.bean;
import java.util.Map;
/**
* 多语言消息接口
*
* @author 夜雨
* @since 2024-04-01 10:28
*/
public interface LanguageMsgMapping<T> {
/**
* 设置消息
*
* @param msg 消息
* @return 原对象
*/
T msg(String msg);
/**
* 设置消息多语言键
*
* @param msgKey 键
* @return 原对象
*/
T msgKey(String msgKey);
/**
* 设置消息多语言键并附加插值参数
*
* @param msgKey 键
* @param msgArgs 插值参数
* @return 原对象
*/
T msgKey(String msgKey, Map<String, Object> msgArgs);
/**
* 设置消息
*
* @param msg 消息
*/
void setMsg(String msg);
/**
* 获取消息
*
* @return 消息
*/
String getMsg();
/**
* 设置消息多语言键
*
* @param msgKey 键
*/
void setMsgKey(String msgKey);
/**
* 设置消息多语言键并附加插值参数列表
*
* @param msgKey 键
* @param msgArgs 插值参数
*/
void setMsgKey(String msgKey, Map<String, Object> msgArgs);
/**
* 获取消息多语言键
*
* @return 键
*/
String getMsgKey();
/**
* 获取附加插值参数
*
* @return 附加插值参数列表
*/
Map<String, Object> getMsgArgs();
}
@@ -1,21 +0,0 @@
package com.imyeyu.java.bean;
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* 多语言数据契约
*
* @author 夜雨
* @since 2026-09-18 13:35
*/
@Data
@EqualsAndHashCode(callSuper = true)
public class Multilingual extends Language implements MultilingualValue {
/** 唯一标识 */
private String id;
/** 业务类型 */
private String bizType;
}
@@ -1,25 +0,0 @@
package com.imyeyu.java.bean;
/**
* 多语言值对象
*
* @author 夜雨
* @since 2026-09-18 13:35
*/
public interface MultilingualValue {
/**
* 获取唯一标识
*
* @return 唯一标识
*/
String getId();
/**
* 获取指定语言值
*
* @param language 指定语言
* @return 语言值
*/
String getValue(Language.Enum language);
}
@@ -1,135 +0,0 @@
package com.imyeyu.java.bean;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import java.io.Serializable;
import java.util.Map;
/**
* 通用接口返回对象
*
* @param <T> 数据类型
*
* @author 夜雨
* @since 2021-07-01 20:18
*/
@NoArgsConstructor
public class Response<T> implements Serializable {
/** 响应代码 */
@Setter
@Getter
protected Integer code;
/** 响应消息 */
@Getter
@Setter
protected String message;
/** 响应消息代码 */
@Getter
@Setter
protected String messageCode;
/** 消息插值参数 */
@Getter
@Setter
protected transient Map<String, Object> messageArgs;
/** 数据体 */
@Setter
@Getter
protected T data;
/**
* 构造器
*
* @param code 代码
*/
public Response(ResultCode code) {
this(code, null);
}
/**
* 构造器
*
* @param code 代码
* @param data 数据体
*/
public Response(ResultCode code, T data) {
this(code, data, null);
}
/**
* 构造器
*
* @param code 代码
* @param data 数据体
* @param message 响应消息
*/
public Response(ResultCode code, T data, String message) {
this.code = code.getValue();
this.data = data;
this.message = message;
}
/** @return true 为成功,code 为 20000 段 */
public boolean isSuccess() {
return code != null && code <= 30000;
}
/** @return true 为失败,isSuccess 取反 */
public boolean isFail() {
return !isSuccess();
}
/**
* 转为通用异常
*
* @return 异常
*/
public ActionException toException() {
ResultCode code = ResultCode.fromCode(this.code);
if (code == null) {
throw new NullPointerException("unknow timi code: " + this.code);
}
return new ActionException(code, messageCode == null ? message : messageCode, messageArgs);
}
/**
* 设置响应消息
*
* @param message 响应消息
* @return 本对象
*/
public Response<T> message(String message) {
this.message = message;
return this;
}
/**
* 设置响应消息代码
*
* @param messageCode 响应消息代码
* @return 本对象
*/
public Response<T> messageCode(String messageCode) {
this.messageCode = messageCode;
return this;
}
/**
* 设置响应消息代码和插值参数
*
* @param messageCode 响应消息代码
* @param messageArgs 插值参数
* @return 本对象
*/
public Response<T> messageCode(String messageCode, Map<String, Object> messageArgs) {
this.messageCode = messageCode;
this.messageArgs = messageArgs;
return this;
}
}
@@ -1,4 +1,4 @@
package com.imyeyu.java.bean;
package com.imyeyu.java.bean.timi;
import lombok.Getter;
@@ -9,7 +9,7 @@ import lombok.Getter;
* @since 2021-05-21 14:32
*/
@Getter
public enum ResultCode {
public enum TimiCode {
// ---------- 200 正常 ----------
@@ -80,7 +80,7 @@ public enum ResultCode {
/** 代码 */
final Integer value;
ResultCode(Integer value) {
TimiCode(Integer value) {
this.value = value;
}
@@ -89,7 +89,7 @@ public enum ResultCode {
*
* @return 异常
*/
public ActionException toException() {
public TimiException toException() {
return toException(toString());
}
@@ -99,8 +99,8 @@ public enum ResultCode {
* @param msg 异常消息
* @return 异常
*/
public ActionException toException(String msg) {
return new ActionException(this, msg);
public TimiException toException(String msg) {
return new TimiException(this, msg);
}
/**
@@ -108,8 +108,8 @@ public enum ResultCode {
*
* @return 返回对象
*/
public Response<?> toResponse() {
return new Response<>(this).message(toString());
public TimiResponse<?> toResponse() {
return new TimiResponse<>(this).msg(toString());
}
/**
@@ -118,11 +118,11 @@ public enum ResultCode {
* @param code 代码
* @return 对象
*/
public static ResultCode fromCode(int code) {
ResultCode[] codes = values();
for (ResultCode resultCode : codes) {
if (resultCode.getValue() == code) {
return resultCode;
public static TimiCode fromCode(int code) {
TimiCode[] codes = values();
for (TimiCode timiCode : codes) {
if (timiCode.getValue() == code) {
return timiCode;
}
}
return null;
@@ -0,0 +1,91 @@
package com.imyeyu.java.bean.timi;
import com.imyeyu.java.bean.LanguageMsgMapping;
import lombok.Getter;
import java.util.Map;
/**
* 致命错误
*
* @author 夜雨
* @since 2023-04-27 15:55
*/
public class TimiError extends AssertionError implements LanguageMsgMapping<TimiError> {
/** 代码 */
@Getter
protected final TimiCode code;
protected transient String msgKey;
protected transient Map<String, Object> msgArgs;
/** @param code 代码 */
public TimiError(TimiCode code) {
this.code = code;
}
/**
* 构造器
*
* @param code 代码
* @param msg 消息
*/
public TimiError(TimiCode code, String msg) {
super(msg);
this.code = code;
}
public TimiResponse<?> toResponse() {
return new TimiResponse<>(code).msg(getMessage()).msgKey(msgKey, msgArgs);
}
@Override
public TimiError msg(String msg) {
throw new UnsupportedOperationException("unsupported to change message");
}
@Override
public TimiError msgKey(String msgKey) {
setMsgKey(msgKey);
return this;
}
@Override
public TimiError msgKey(String msgKey, Map<String, Object> msgArgs) {
setMsgKey(msgKey, msgArgs);
return this;
}
@Override
public void setMsg(String msg) {
throw new UnsupportedOperationException("unsupported to change message");
}
@Override
public String getMsg() {
return getMessage();
}
@Override
public void setMsgKey(String msgKey) {
this.msgKey = msgKey;
}
@Override
public String getMsgKey() {
return msgKey;
}
@Override
public void setMsgKey(String msgKey, Map<String, Object> msgArgs) {
this.msgKey = msgKey;
this.msgArgs = msgArgs;
}
@Override
public Map<String, Object> getMsgArgs() {
return msgArgs;
}
}
@@ -0,0 +1,160 @@
package com.imyeyu.java.bean.timi;
import com.imyeyu.java.TimiJava;
import com.imyeyu.java.bean.CallbackReturn;
import com.imyeyu.java.bean.LanguageMsgMapping;
import lombok.Getter;
import java.util.Map;
/**
* 通用运行时异常,附加通用代码
*
* @author 夜雨
* @since 2021-05-20 15:18
*/
public class TimiException extends RuntimeException implements LanguageMsgMapping<TimiException> {
/** 代码 */
@Getter
protected final TimiCode code;
protected transient String msgKey;
protected transient Map<String, Object> msgArgs;
/** @param code 代码 */
public TimiException(TimiCode code) {
this.code = code;
}
/**
* 构造器
*
* @param code 代码
* @param msg 消息
*/
public TimiException(TimiCode code, String msg) {
super(msg);
this.code = code;
}
/**
* 构造器
*
* @param code 代码
* @param msg 消息
*/
public TimiException(TimiCode code, String msg, Throwable e) {
super(msg, e);
this.code = code;
}
public TimiResponse<?> toResponse() {
return new TimiResponse<>(code).msg(getMessage()).msgKey(msgKey, msgArgs);
}
@Override
public TimiException msg(String msg) {
throw new UnsupportedOperationException("unsupported to change message");
}
@Override
public TimiException msgKey(String msgKey) {
setMsgKey(msgKey);
return this;
}
@Override
public TimiException msgKey(String msgKey, Map<String, Object> msgArgs) {
setMsgKey(msgKey, msgArgs);
return this;
}
@Override
public void setMsg(String msg) {
throw new UnsupportedOperationException("unsupported to change message");
}
@Override
public String getMsg() {
return getMessage();
}
@Override
public void setMsgKey(String msgKey) {
this.msgKey = msgKey;
}
@Override
public void setMsgKey(String msgKey, Map<String, Object> msgArgs) {
this.msgKey = msgKey;
this.msgArgs = msgArgs;
}
@Override
public String getMsgKey() {
return msgKey;
}
@Override
public Map<String, Object> getMsgArgs() {
return msgArgs;
}
public static <T> T required(T t, String message) {
if (TimiJava.isEmpty(t)) {
throw new TimiException(TimiCode.ARG_MISS, message);
}
return t;
}
public static <T> T required(T t, String message, String msgKey) {
if (TimiJava.isEmpty(t)) {
throw new TimiException(TimiCode.ARG_MISS, message).msgKey(msgKey);
}
return t;
}
public static <T> void requiredNull(T t, String message) throws TimiException {
if (t != null) {
throw new TimiException(TimiCode.ERROR, message);
}
}
public static <T> void requiredNull(T t, String message, String msgKey) throws TimiException {
if (t != null) {
throw new TimiException(TimiCode.ERROR, message).msgKey(msgKey);
}
}
public static void requiredTrue(boolean bool, String message) throws TimiException {
if (bool) {
return;
}
throw new TimiException(TimiCode.ERROR, message);
}
public static void requiredTrue(boolean bool, String message, String msgKey) throws TimiException {
if (bool) {
return;
}
throw new TimiException(TimiCode.ERROR, message).msgKey(msgKey);
}
public static void requiredTrue(CallbackReturn<Boolean> callback, String message) throws TimiException {
TimiException.required(callback, "not found callback");
if (callback.handler()) {
return;
}
throw new TimiException(TimiCode.ERROR, message);
}
public static void requiredTrue(CallbackReturn<Boolean> callback, String message, String msgKey) throws TimiException {
TimiException.required(callback, "not found callback");
if (callback.handler()) {
return;
}
throw new TimiException(TimiCode.ERROR, message).msgKey(msgKey);
}
}
@@ -0,0 +1,156 @@
package com.imyeyu.java.bean.timi;
import com.imyeyu.java.bean.LanguageMsgMapping;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import java.io.Serializable;
import java.util.Map;
/**
* 通用接口返回对象
*
* @author 夜雨
* @since 2021-07-01 20:18
*/
@NoArgsConstructor
public class TimiResponse<T> implements Serializable, LanguageMsgMapping<TimiResponse<T>> {
/** 响应代码 */
@Setter
@Getter
protected Integer code;
/** 消息 */
protected String msg;
protected transient String msgKey;
protected transient Map<String, Object> msgArgs;
/** 数据体 */
@Setter
@Getter
protected T data;
/**
* 构造器
*
* @param code 代码
*/
public TimiResponse(TimiCode code) {
this(code, null);
}
/**
* 构造器
*
* @param code 代码
* @param data 数据体
*/
public TimiResponse(TimiCode code, T data) {
this(code, data, null);
}
/**
* 构造器
*
* @param code 代码
* @param data 数据体
* @param msg 消息
*/
public TimiResponse(TimiCode code, T data, String msg) {
this.code = code.getValue();
this.data = data;
this.msg = msg;
}
/** @return true 为成功,code 为 20000 段 */
public boolean isSuccess() {
return code != null && code <= 30000;
}
/** @return true 为失败,isSuccess 取反 */
public boolean isFail() {
return !isSuccess();
}
/**
* 转为通用异常
*
* @return 异常
*/
public TimiException toException() {
TimiCode code = TimiCode.fromCode(this.code);
if (code == null) {
throw new NullPointerException("unknow timi code: " + this.code);
}
return code.toException(msg);
}
/**
* 追加消息(避免和泛型字符串冲突)
*
* @param msg 消息
* @return 本对象
*/
@Override
public TimiResponse<T> msg(String msg) {
this.msg = msg;
return this;
}
/**
* 获取消息
*
* @return 消息
*/
@Override
public String getMsg() {
return msg;
}
/**
* 设置消息
*
* @param msg 消息
*/
@Override
public void setMsg(String msg) {
this.msg = msg;
}
@Override
public TimiResponse<T> msgKey(String msgKey) {
this.msgKey = msgKey;
return this;
}
@Override
public TimiResponse<T> msgKey(String msgKey, Map<String, Object> msgArgs) {
setMsgKey(msgKey, msgArgs);
return this;
}
@Override
public String getMsgKey() {
return msgKey;
}
@Override
public void setMsgKey(String msgKey) {
this.msgKey = msgKey;
}
@Override
public void setMsgKey(String msgKey, Map<String, Object> msgArgs) {
this.msgKey = msgKey;
this.msgArgs = msgArgs;
}
@Override
public Map<String, Object> getMsgArgs() {
return msgArgs;
}
}
@@ -0,0 +1,2 @@
/** 个人常用的通用类 */
package com.imyeyu.java.bean.timi;
@@ -2,12 +2,10 @@ package com.imyeyu.java.thread;
import com.imyeyu.java.bean.Callback;
import com.imyeyu.java.bean.CallbackArg;
import com.imyeyu.java.bean.ActionException;
import lombok.AllArgsConstructor;
import com.imyeyu.java.bean.timi.TimiException;
import lombok.Builder;
import lombok.Data;
import lombok.Getter;
import lombok.NoArgsConstructor;
import java.util.concurrent.TimeUnit;
@@ -42,49 +40,14 @@ public class AsyncRetryExecutor {
@Getter
private volatile boolean isRunning = false;
/**
* 任务
*
* @author 夜雨
* @since 2025-11-06 23:37
*/
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public static class Task {
/** 必填回调方法 */
private Callback callback;
/** 最大重试次数,-1 为无限重试 */
@Builder.Default
private int maxRetry = DEFAULT_MAX_RETRY;
/** 重试间隔毫秒数 */
@Builder.Default
private long retryInterval = DEFAULT_RETRY_INTERVAL;
/** 线程名前缀 */
@Builder.Default
private String threadNamePrefix = DEFAULT_THREAD_NAME_PREFIX;
/** 是否设置为守护线程 */
@Builder.Default
private boolean daemon = DEFAULT_DAEMON;
/** 重试耗尽时的异常回调 */
private CallbackArg<Exception> onRetryExhausted;
}
/**
* 根据构建器参数创建异步重试执行器
*
* @param task 构建器对象
*/
private AsyncRetryExecutor(Task task) {
ActionException.required(task, "not found task");
ActionException.required(task.getCallback(), "not found task.callback");
TimiException.required(task, "not found task");
TimiException.required(task.getCallback(), "not found task.callback");
thread = new Thread(() -> {
int retryCount = 0;
while (isRunning && !isSuccess && (task.maxRetry < 0 || retryCount <= task.maxRetry)) {
@@ -99,9 +62,7 @@ public class AsyncRetryExecutor {
}
if (0 < task.maxRetry && task.maxRetry < retryCount) {
// 超过重试次数
if (task.onRetryExhausted != null) {
task.onRetryExhausted.handler(e);
}
task.onRetryExhausted.handler(e);
break;
}
// 重试
@@ -118,13 +79,32 @@ public class AsyncRetryExecutor {
}
/**
* 使用默认参数创建执行器
* 构造器
*
* @param task 任务
* @return 执行器实例
* @author 夜雨
* @since 2025-11-06 23:37
*/
public static AsyncRetryExecutor create(Task task) {
return new AsyncRetryExecutor(task);
@Data
@Builder
public static class Task {
/** 必填回调方法 */
private Callback callback;
/** 最大重试次数,-1 为无限重试 */
private int maxRetry = DEFAULT_MAX_RETRY;
/** 重试间隔毫秒数 */
private long retryInterval = DEFAULT_RETRY_INTERVAL;
/** 线程名前缀 */
private String threadNamePrefix = DEFAULT_THREAD_NAME_PREFIX;
/** 是否设置为守护线程 */
private boolean daemon = DEFAULT_DAEMON;
/** 重试耗尽时的异常回调 */
private CallbackArg<Exception> onRetryExhausted;
}
/**