XXL-TOOL v1.4.0 发布 | Java 工具类库

Release Notes

• 1 、 [新增] JsonRpc 模块：一个轻量级、跨语言远程过程调用实现，基于 json 、http 实现（从 XXL-JOB 底层通讯组件提炼抽象）。
• 2 、 [新增] Concurrent 模块：一系列并发编程工具，具备良好的线程安全、高并发及高性能优势，包括 CyclicThread （循环线程）、MessageQueue （高性能内存队列，30W+ TPS ）等。
• 3 、 [新增] Auth 模块：一系列权限认证相关工具，包括 JwtTool 等。
• 4 、 [强化] 已有工具能力完善，包括 CollectionTool 、MapTool 、HttpTool 等；
• 5 、 [升级] 升级依赖版本，包括 slf4j 、poi 、spring 、gson 、junit 等。

简介

XXL-TOOL 是一个 Java 工具类库，致力于让 Java 开发更高效。包含 “集合、字符串、缓存、IO 、并发、Excel 、Emoji 、Response 、Pipeline 、Http 、Json 、JsonRpc 、Encrypt 、Auth……” 等数十个模块。

文档地址

• 中文文档：https://www.xuxueli.com/xxl-tool/
• Github：https://github.com/xuxueli/xxl-tool

组件列表

代码示例：JsonRpc 用法

一个轻量级、跨语言远程过程调用实现，基于 json 、http 实现。

第一步：RPC 业务服务开发

public interface UserService {
    public ResultDTO createUser(UserDTO userDTO);
    public UserDTO loadUser(String name);
    ... ...
}

第二步：JsonRpc 服务端配置

// a 、JsonRpcServer 初始化
JsonRpcServer jsonRpcServer = new JsonRpcServer();

// b 、业务服务注册（支持多服务注册）
jsonRpcServer.register("userService", new UserServiceImpl());

// c 、Web 框架集成，该入口为 RPC 统一流量入口（ springmvc 集成；理论上支持任意 web 框架集成，其他框架参考集成）
@RequestMapping("/openapi")
@ResponseBody
public String api(@RequestBody(required = false) String requestBody){
	// 核心代码：Http 请求的 RequestBody 作为入参；业务响应作为输出；
    return jsonRpcServer.invoke(requestBody);
}

第三步：JsonRpc 客户端配置

// 方式 1：代理方式使用 （针对接口构建代理，通过代理对象实现远程调用；）
UserService userService = new JsonRpcClient("http://localhost:8080/jsonrpc", 3000).proxy("userService", UserService.class);

// 发起 RPC 请求；
UserDTO result = userService.loadUser("zhangsan");

代码示例：MessageQueue （高性能内存队列）

高性能内存队列，单机支持 30W+ TPS ，具备良好的性能及高并发优势，支持生产消费模型。

// a 、定义队列：指定 消费者数量、批量消费数量、消费者逻辑等
MessageQueue<String> messageQueue = new MessageQueue<>(
	"demoQueue",
	messages -> {			
		// 消费逻辑
		System.out.println("Consume: " + messages);
	},
	10,	// 自定义消费者线程
	20	// 自定义批量消费数量
);

// b 、生产消息
messageQueue.produce("test-" + i);

代码示例：TimeWheel （时间轮）

时间轮算法实现，具备高精度、多任务、以及线程安全等优势。

// a 、时间轮定义，自定义时间轮刻度、间隔等
TimeWheel timeWheel = new TimeWheel(60, 1000);

// b 、提交时间轮任务（定时任务）
timeWheel.submitTask(System.currentTimeMillis() + 3000, () -> {
    System.out.println("Task delay " + waitTime + "ms executed at: " );
});

代码示例：Jwt 权限认证

JWT 工具，提供 JWT 生成及解析能力

// a 、JwtTool 初始化，自定义 Signer 和 Verifier
JwtTool jwtTool = new JwtTool(SECRET);    // 默认使用 MACSigner/MACVerifier ，支持多构造方法自定义实现；

// b 、创建 token
String token = jwtTool.createToken(
                {用户标识},
                {自定义声明数据，map 形式},
                {自定义过期时间}
        );
        
// c 、验证 token
boolean isValid = jwtTool.validateToken(token);   
// d 、获取 claim
Object userId = jwtTool.getClaim(token, {自定义声明数据 key});
// e 、获取过期时间
Date expirationTime = jwtTool.getExpirationTime(token);