java工具库
- kong-bom 版本管理
- kong-core 简单的util
- kong-http 基于okhttp的http请求工具
- kong-json 基于jackson的json工具类
- kong-socket 基于Java NIO的高性能网络服务器工具包
- kong-ai 大模型工具封装
- kong-db 基于jdbc的数据库操作工具
- kong-bus 类似git操作的轻量级eventbus
- kong-bus-springboot-starter bus的springboot-starter
- kong-spring spring相关工具
public class ObjTest {
@Test
void test1() throws Exception {
//自定义请求创建
Req.of().method(Method.GET).url("http://localhost:8080/get");
//基本的http请求
Req.get("http://localhost:8080/get");
Req.post("http://localhost:8080/post");
Req.delete("http://localhost:8080/delete");
Req.put("http://localhost:8080/put");
Req.patch("http://localhost:8080/patch");
Req.head("http://localhost:8080/head");
Req.options("http://localhost:8080/options");
Req.trace("http://localhost:8080/trace");
Req.connect("http://localhost:8080/connect");
//特殊http请求
//application/x-www-form-urlencoded
Req.formUrlencoded("http://localhost:8080/formUrlencoded");
//multipart/form-data
Req.multipart("http://localhost:8080/multipart");
//ws协议请求创建
Req.ws("http://localhost:8080/ws");
//sse协议请求创建
Req.sse("http://localhost:8080/sse");
}
}url添加有两种方式，可以混合使用，如果url和构建函数里面都有值，按构建函数里面为主
- 直接使用url方法
public class UrlTest {
@Test
void test1() throws Exception {
Res res = Req.get("http://localhost:8080/get/one/two").ok();
Assertions.assertEquals("ok", res.str());
}
@Test
void test2() {
// http://localhost:8080/get/one/two
Res res = Req.of()
.scheme("http")
.host("localhost")
.port(8080)
.path("get")
.path("one")
.path("two")
.ok();
Assertions.assertEquals("ok", res.str());
}
@Test
void test3() throws Exception {
// http://localhost:8080/get/one/two
Res res = Req.get("/get")
.scheme("http")
.host("localhost")
.port(8080)
.path("one")
.path("two")
.ok();
Assertions.assertEquals("ok", res.str());
}
}public class UrlQueryTest {
@Test
void test1() throws Exception {
//http://localhost:8080/get/one/two?q=1&k1=v1&k2=1&k2=2&k3=v3&k4=v4
Res res = Req.get("http://localhost:8080/get/one/two?q=1")
.query("k1", "v1")
.query("k2", Arrays.asList("1", "2"))
.query(new HashMap<String, Object>() {{
put("k3", "v3");
put("k4", "v4");
}})
.ok();
//服务端接受{q=[1], k1=[v1], k2=[1, 2], k3=[v3], k4=[v4]}
}
}设置请求头内容，cookie等
public class HeaderTest {
@Test
void test1() throws Exception {
final Res res = Req.get("http://localhost:8080/header")
//contentype
.contentType(ContentType.JSON.v())
//charset
.charset(StandardCharsets.UTF_8)
//user-agent
.ua(UA.Mac.chrome.v())
//authorization
.auth("auth qwe")
//authorization bearer
.bearer("qqq")
//header
.header("name", "value")
//headers
.headers(new HashMap<>() {{
put("name1", "value1");
put("name2", "value2");
}})
//cookie
.cookie("k", "v")
//cookies
.cookies(new HashMap<>() {{
put("k1", "v1");
put("k2", "v2");
}})
.ok();
Assertions.assertEquals("ok", res.str());
//headers = {Cookie=[k1=v1; k2=v2; k=v;], Accept-encoding=[gzip], Authorization=[Bearer qqq], Content-type=[application/json;charset=UTF-8], Connection=[Keep-Alive], Host=[localhost:8080], User-agent=[Mozilla/5.0 (Macintosh; Intel Mac OS X 10_7_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/27.0.1453.93 Safari/537.36], Name1=[value1], Name=[value], Name2=[value2]}
}
}get和head请求就算添加了请求体也不会携带在请求 post请求体必须有个请求体，默认会传入空字符串
public class BodyTest {
User user = new User().setAge(12).setHobby(new String[]{"a", "b", "c"}).setName("kkk");
String json = """
{
"age": 12,
"name": "kkk",
"hobby": ["a", "b", "c"]
}
""";
@Test
public void test1() throws Exception {
Res res = Req.post("http://localhost:8080/post_body")
//自动会将对象转成json字符串，使用jackson
.json(user)
.ok();
Assertions.assertEquals(json, res.body());
}
@Test
public void test2() throws Exception {
Res res = Req.post("http://localhost:8080/post_body")
//自动会将对象转成json字符串，使用jackson
.body("text", ContentType.TEXT_PLAIN.v())
.ok();
System.out.println("res.str() = " + res.str());
}
}可发送application/x-www-form-urlencoded表单请求，如果需要上传文件则使用multipart/form-data
public class FormTest {
@Test
public void testForm() throws IOException {
//application/x-www-form-urlencoded
Res ok = Req.formUrlencoded("http://localhost:8080/post_form")
.form("a", "1")
.form(new HashMap<>() {{
put("b", "2");
}})
.ok();
Assertions.assertEquals("ok", ok.str());
//{a=[1], b=[2]}
}
@Test
public void test2() throws Exception {
//multipart/form-data
Res ok = Req.multipart("http://localhost:8080/post_mul_form")
.file("test", "test.txt", Files.readAllBytes(Paths.get("C:", "test", "test.txt")))
.form("a", "1")
.form(new HashMap<>() {{
put("b", "2");
}})
.ok();
Assertions.assertEquals("ok", ok.str());
//params = {a=[1], b=[2]}
//files = {test=[io.github.kongweiguang.http.server.core.UploadFile@6231d793]}
}
}异步请求返回的是future，也可以使用join()或者get()方法等待请求执行完，具体使用请看CompletableFuture（异步编排） 请求错误的时候不会抛出异常，而是会调用fail回调方法，res内容是空的
public class AsyncTest {
@Test
public void test1() throws Exception {
CompletableFuture<Res> future = Req.get("http://localhost:8080/get")
.query("a", "1")
.success(r -> System.out.println(r.str()))
.fail(t -> System.out.println("error"))
.okAsync();
future.get(3, TimeUnit.MINUTES);
}
@Test
public void test2() throws Exception {
CompletableFuture<Res> future = Req.get("http://localhost:8080/error")
.query("a", "1")
.success(r -> System.out.println(r.str()))
.fail(t -> System.out.println("error"))
.okAsync();
Res res = future.get(3, TimeUnit.MINUTES);
System.out.println(res);
}
}public class TimeoutTest {
@Test
void test1() throws Exception {
Res res = Req.get("http://localhost:8080/timeout")
.timeout(Duration.ofSeconds(1))
// .timeout(10, 10, 10)
.ok();
System.out.println(res.str());
}
}public class ResTest {
@Test
void testRes() {
Res res = Req.get("http://localhost:80/get_string")
.query("a", "1")
.query("b", "2")
.query("c", "3")
.ok();
//返回值
String str = res.str();
byte[] bytes = res.bytes();
User obj = res.obj(User.class);
List<User> obj1 = res.obj(new TypeRef<List<User>>() {
}.type());
List<String> list = res.list();
Map<String, String> map = res.map();
JSONObject jsonObject = res.jsonObj();
InputStream stream = res.stream();
Integer i = res.rInt();
Boolean b = res.rBool();
//响应头
String ok = res.header("ok");
Map<String, List<String>> headers = res.headers();
//状态
int status = res.code();
//原始响应
Response response = res.raw();
}
}重试可以实现同步重试和异步重试，重试的条件可自定义实现
public class RetryTest {
@Test
public void testRetry() {
Res res = Req.get("http://localhost:8080/error")
.query("a", "1")
.retry(retry -> retry.maxAttempts(3)
.delay(Duration.ofSeconds(2)))
.ok();
System.out.println("res = " + res.str());
}
@Test
public void testRetry2() {
Res res = Req.get("http://localhost:8080/error")
.query("a", "1")
.retry(retry -> retry.maxAttempts(3)
.delay(Duration.ofSeconds(2))
.predicate((r, t) -> {
String str = r.str();
if (str.length() > 10) {
return Pair.of(false, r);
}
return Pair.of(true, r);
}))
.ok();
System.out.println("res.str() = " + res.str());
}
@Test
public void testRetry3() {
//异步重试
CompletableFuture<Res> res = Req.get("http://localhost:8080/error")
.query("a", "1")
.retry(r -> r.maxAttempts(3))
.okAsync();
System.out.println("res.join().str() = " + res.join().str());
}
}代理默认是http，可以设置socket代理
public class ProxyTest {
@Test
void test1() throws Exception {
Config.proxy("127.0.0.1", 80);
Config.proxy(Type.SOCKS, "127.0.0.1", 80);
Config.proxyAuthenticator("k", "pass");
Res res = Req.get("http://localhost:8080/get/one/two")
.query("a", "1")
.ok();
}
}public class DowTest {
@Test
void testDow() {
Res ok = Req.get("http://localhost:8080/xz").ok();
try {
ok.file("C:\\test\\k.txt");
} catch (IOException e) {
throw new KongHttpRuntimeException(e);
}
}
}public class LogTest {
@Test
public void test() throws Exception {
Req.get("http://localhost:8080/get/one/two")
.log(ReqLog.console, HttpLoggingInterceptor.Level.BODY)
.timeout(Duration.ofMillis(1000))
.ok()
.then(r -> {
System.out.println(r.code());
System.out.println("ok -> " + r.isOk());
})
.then(r -> {
System.out.println("redirect -> " + r.isRedirect());
});
}
}ws请求返回的res对象为null
public class WsTest {
@Test
public void test() {
WSListener listener = new WSListener() {
@Override
public void open(WSReqBuilder req, Res res) {
this.ws.send("123");
}
@Override
public void msg(WSReqBuilder req, String text) {
System.out.println(text);
}
@Override
public void closed(WSReqBuilder req, int code, String reason) {
System.out.println(reason);
}
};
WebSocket ws = Req.ws("ws://localhost:8889/ws")
.query("k", "v")
.header("h", "v")
.wsListener(listener)
.ok();
Threads.sleep(1000);
for (int i = 0; i < 100; i++) {
Threads.sleep(1000);
ws.send("123");
}
Threads.sync(this);
}
}sse请求返回的res对象为null
public class SseTest {
@Test
void test() throws InterruptedException {
SSEListener listener = new SSEListener() {
@Override
public void event(SSEReqBuilder req, SseEvent msg) {
System.out.println("sse -> " + msg.id());
System.out.println("sse -> " + msg.type());
System.out.println("sse -> " + msg.data());
if (Objects.equals(msg.data(), "done")) {
closeCon();
}
}
@Override
public void open(SSEReqBuilder req, Res res) {
System.out.println(req);
System.out.println(res);
}
@Override
public void fail(SSEReqBuilder req, Res res, Throwable t) {
System.out.println("fail" + t);
}
@Override
public void closed(SSEReqBuilder req) {
System.out.println("close");
}
};
EventSource es = Req.sse("http://localhost:8080/sse")
.sseListener(listener)
.ok();
Request request = es.request();
Threads.sync(this);
}
}public class ConfigTest {
@Test
void test1() throws Exception {
//设置代理
OK.conf()
.proxy("127.0.0.1", 80)
.proxy(Type.SOCKS, "127.0.0.1", 80)
.proxyAuthenticator("k", "pass")
//设置拦截器
.addInterceptor(new Interceptor() {
@NotNull
@Override
public Response intercept(@NotNull Chain chain) throws IOException {
System.out.println(1);
return chain.proceed(chain.request());
}
})
//设置连接池
.connectionPool(new ConnectionPool(10, 10, TimeUnit.MINUTES))
//设置异步调用的线程池
.exec(Executors.newCachedThreadPool());
}
}public class SingingConfigTest {
@Test
public void test1() throws Exception {
Res res = Req.get("http://localhost:80/get_string")
.config(c -> c.followRedirects(false).ssl(false))
.ok();
}
}public class ServerTest {
public static void main(String[] args) {
JavaServer.of()
.executor(Executors.newCachedThreadPool())
//设置静态web地址，默认寻找index.html
.web("static", "C:\\dev\\js\\xm\\vite-dev\\dist", "index.html")
.get("/get", (req, res) -> {
res.send("ok");
})
.get("/get_string", (req, res) -> {
System.out.println("req = " + req.query());
System.out.println("req = " + req.params());
res.send("ok");
})
.post("/post_json", (req, res) -> {
Map<String, List<String>> params = req.params();
System.out.println("params = " + params);
System.out.println("req.str() = " + req.str());
res.send("\"{\"key\":\"i am post res\"}\"");
})
.get("/get/one/two", (req, res) -> {
System.out.println("req = " + req.path());
System.out.println("params" + req.params());
res.send("ok");
})
.get("/header", (req, res) -> {
Map<String, List<String>> headers = req.headerMap();
System.out.println("headers = " + headers);
res.send("ok");
})
//接受post请求
.post("/post_body", ((req, res) -> {
String str = req.str();
System.out.println("str = " + str);
res.send(str);
}))
.post("/post_form", ((req, res) -> {
System.out.println(req.params());
res.send("ok");
}))
//上传
.post("/post_mul_form", (req, res) -> {
Map<String, List<String>> params = req.params();
System.out.println("params = " + params);
Map<String, List<UploadFile>> files = req.fileMap();
System.out.println("files = " + files);
res.send("ok");
})
.get("/error", ((req, res) -> {
System.out.println("req.str() = " + req.str());
throw new KongHttpRuntimeException("error");
}))
.get("/timeout", ((req, res) -> {
Threads.sleep(5000);
res.send("ok");
}))
//下载文件
.get("/xz", (req, res) ->
res.file("k.txt", Files.readAllBytes(Paths.get("C:\\test\\test.txt"))))
//sse响应
.sse("/sse", new SSEHandler() {
@Override
public void handler(HttpReq req, HttpRes res) {
for (int i = 0; i < 10; i++) {
Threads.sleep(500);
send(SseEvent.of()
.id(UUID.randomUUID().toString())
.type("eventType")
.data(new Date().toString())
);
}
//完成
send(SseEvent.of()
.id(UUID.randomUUID().toString())
.type("eventType")
.data("done")
);
//关闭
close(res);
}
})
.ok(8080);
}
}public class JsonBuilderTest {
User u = new User().setAge(1).setName("kong").setHobby(new String[]{"j", "n"});
/**
* {
* "a" : "b",
* "c" : [ "d1", "d2" ],
* "e" : "f",
* "g" : [ "1", "2", "3", "4", "4" ],
* "u1" : "{\"name\":\"kong\",\"age\":1,\"hobby\":[\"j\",\"n\"]}",
* "u2" : {
* "name" : "kong",
* "age" : 1,
* "hobby" : [ "j", "n" ]
* },
* "i" : "1"
* }
* 4
*
* @throws Exception
*/
@Test
void testJsonObj() throws Exception {
String str = JsonObj.of()
.put("a", "b")
.putAry("c", o -> o.add("d1").add("d2"))
.put("e", "f")
.putAry("g", c -> c.addColl(Arrays.asList(1, 2, 3, 4, 4)))
.put("u1", u)
.putObj("u2", u)
.put("i", 1)
.toPrettyJson();
System.out.println(str);
System.out.println(Json.toNode(str).get("g").get(3).asInt());
}
/**
* ["1","2","3",{"name":"kong","age":1,"hobby":["j","n"]},{"a":"a","b":"b"},["6","7"],"0","0"]
* [1, 2, 3, {name=kong, age=1, hobby=[j, n]}, {a=a, b=b}, [6, 7], 0, 0]
*
* @throws Exception
*/
@Test
void testJsonAry() throws Exception {
String ary = JsonAry.of()
.add(1)
.add(2)
.add(3)
.addObj(u)
.addObj(c -> c.put("a", "a").put("b", "b"))
.addAry(c -> c.add(6).add(7))
.addColl(Arrays.asList(0, 0))
.toJson();
System.out.println(ary);
List<Object> list = Json.toList(ary, Object.class);
System.out.println(list);
}
/**
* {1=true}
* {"1":"true"}
*
* @throws Exception
*/
@Test
void test1() throws Exception {
JsonObj jsonObj = Json.obj().put("1", "true");
System.out.println(jsonObj.toMap());
System.out.println(jsonObj.toJson());
}
/**
* ["1","2",["66","888"],{"name":"kong","age":1,"hobby":["j","n"]}]
*
* @throws Exception
*/
@Test
void test2() throws Exception {
String json = Json.ary().add(1).add(new BigDecimal(2)).addAry(e -> e.add(66).add(888)).addObj(u).toJson();
System.out.println(json);
}
/**
* {
* "1" : null
* }
*
* @throws Exception
*/
@Test
void test3() throws Exception {
System.out.println(Json.obj().put("1", null).toPrettyJson());
}
}@Test
public void test4() throws Exception {
String json = "[{\"name\":\"kong\",\"age\":1,\"hobby\":[\"j\",\"n\"]}]";
List<User> users = Json.mapper().readValue(json, new TypeReference<List<User>>() {
});
System.out.println(users);
}
@Test
public void test5() throws Exception {
String json = "{\"name\":[\"j\",\"n\"],\"age\":[\"j\",\"n\"],\"hobby\":[\"j\",\"n\"]}";
Map<String, List<String>> map = Json.toMap(json, new TypeReference<Map<String, List<String>>>() {
});
System.out.println("map = " + map);
}
@Test
public void test6() throws Exception {
String json = "{\"name\":[\"j\",\"n\"],\"age\":[\"j\",\"n\"],\"hobby\":[\"j\",\"n\"]}";
JsonNode node = Json.toNode(json);
Map<String, List<String>> map = Json.toMap(node, new TypeReference<Map<String, List<String>>>() {
});
System.out.println("map = " + map);
}
@Test
public void test7() throws Exception {
String json = "{\"name\":\"kong\",\"age\":1,\"hobby\":[\"j\",\"n\"]}";
User node = Json.toObj(json, User.class);
System.out.println("node = " + node);
Person obj = Json.toObj(node, Person.class);
System.out.println("obj = " + obj);
}
@Test
public void test8() throws Exception {
String json = "name";
String obj = Json.toObj(json, String.class);
System.out.println("obj = " + obj);
}
@Test
public void test9() throws Exception {
String json = "{\"name\":\"kong\",\"age\":1,\"hobby\":[\"j\",\"n\"]}";
User node = Json.toObj(json, User.class);
JsonNode node1 = Json.toNode(node);
System.out.println("node1 = " + node1);
JsonNode node2 = Json.toNode(json);
System.out.println("node2 = " + node2);
}
@Test
public void test10() throws Exception {
String json = "[{\"name\":\"kong\",\"age\":1,\"hobby\":[\"j\",\"n\"]}]";
List<Object> list = Json.toList(json, Object.class);
System.out.println("list = " + list);
List<User> list1 = Json.toList(json, User.class);
System.out.println("list1 = " + list1);
List<Person> list2 = Json.toList(json, new TypeReference<List<Person>>() {
});
System.out.println("list2 = " + list2);
List<Person> list3 = Json.toList(list1, Person.class);
System.out.println("list3 = " + list3);
}
@Test
public void test11() throws Exception {
String json = "{\"name\":\"kong\",\"age\":1,\"hobby\":[\"j\",\"n\"]}";
Map<Object, Object> map = Json.toMap(json, Object.class, Object.class);
}/**
* NIO服务器示例类
* 展示如何使用NioServer工具类创建和配置NIO服务器
*/
public class ServerTest {
public static void main(String[] args) {
// 创建自定义配置
NioServerConfig config = NioServerConfig.of()
.bossThreads(1)
.workerThreads(4)
.bufferSize(8192);
// 创建服务器实例
NioServer.of(config)
// .socketHandler(new DefaultRequestHandler())
.socketHandler(new EchoSocketHandler())
.bind(8888)
.bind("localhost", 8887);
System.out.println("服务器已启动，监听端口: 8888, 8887");
LockSupport.park();
}
}/**
* NIO客户端示例类
* 展示如何使用NioClient工具类创建和配置NIO客户端
*/
public class ClientTest {
public static void main(String[] args) {
// 创建客户端实例并连接
NioClient client = NioClient.of(c -> c.bufferSize(100))
.socketHandler((response, channel) -> {
//打印响应
byte[] data = new byte[response.remaining()];
response.get(data);
System.out.println("收到响应: " + new String(data, StandardCharsets.UTF_8));
return null;
})
.connect("localhost", 8888);
System.out.println("客户端已启动，连接到服务器: localhost:8888");
// 等待连接建立
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Scanner scanner = new Scanner(System.in);
System.out.println("请输入要发送的消息:");
while (scanner.hasNextLine()) {
String request = scanner.nextLine();
if (request != null && !request.trim().isEmpty()) {
System.out.println("request = " + request);
client.send(request);
}
}
}
}