1. 编程号首页

Java编译器_Java编译器

编程小号 • • 未分类

Java编译器_Java编译器花了一点时间，包装了下httpclient，填了常见的坑

Java编译器_Java编译器

花了一点时间，包装了下httpclient，填了常见的坑。

有兴趣的戳下方链接~~

基于apache httpclient的轻量http请求

特性

封装了httpclient, 仅暴露常用的配置, 将常见的坑填上

接口设计参考jsoup http, 十分便捷的请求让人耳目一新

支持所有的请求方式, GET,POST,PUT,DELETE,PATCH,HEAD,OPTIONS,TRACE

可以像rpc请求一样发http请求, 代码更加规范稳定, 易于管理

出参入参对json极为友好, 自动解析返回对象to pojo

当返回值为HttpResult时, 调用失败也不会抛出异常. GET请求不建议使用HttpResult, 非GET如POST/PUT/DELETE请求都建议使用HttpResult

支持返回值取jsonPath, 例如:msg.user.id/msg.user[1].id 参考测试包下com.chenxiaojie.http.invoker.test.http.test.ResultJsonPathTest

支持设计重试次数, 建议get请求都有重试机制, 参考测试包下com.chenxiaojie.http.invoker.test.http.test.RetryTest

支持上传各种类型的文件, 支持File/InputStream/byte[]/base64上传, 参考测试包下com.chenxiaojie.http.invoker.test.http.test.UploadFileTest

支持@PathVariable 如 http://.com/{key}/info -> http://.com/xiaojie.chen/info, 参考测试包下com.chenxiaojie.http.invoker.test.http.test.SimpleTest

支持请求拦截器和自定义httpclient, 参考com.chenxiaojie.http.invoker.test.http.test.CustomHttpClientTest

添加依赖

com.chenxiaojie

http-invoker

1.0.1

如果您的项目中有依赖以下包,请指定以下版本或高于以下版本

org.apache.httpcomponents

httpclient

4.5.1

org.apache.httpcomponents

httpcore

4.4.3

org.apache.httpcomponents

httpmime

4.5.1

commons-codec

commons-codec

1.9

快速入门

http-invoker-demo-web module是专门用于测试, 运行以下代码时, 请先启动这个web项目

使用HttpInvoker, 参考测试包下com.chenxiaojie.http.invoker.test.httpinvoker.HttpInvokerTest

public class HttpInvokerTest {

@Test

public void testGet() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/1”)

.data(“employeeId”, “00160041”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰1”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen1”)

.method(HttpMethod.GET)

.execute();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testGet2() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/2”)

.data(“employeeId”, “00160042”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰2”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen2”)

.get();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Rule

public ExpectedException thrown = ExpectedException.none();

@Test

public void testGet3() {

thrown.expect(HttpRequestException.class);

HttpInvoker.Response response = HttpInvoker.builder(HttpClientBuilder.builder().followRedirects(true).build())

.uri(Consts.URL + “/redirect/loop”)

.get();

response.log();

}

@Test

public void testPost() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/3”)

.data(“employeeId”, “00160043”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰3”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen3”)

.post();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testPost2() {

UserLoginModel userLoginModel = new UserLoginModel();

userLoginModel.setLoginId(5);

userLoginModel.setEmployeeId(“0016004”);

userLoginModel.setEmployeeName(“陈孝杰”);

userLoginModel.setAd(“xiaojie.chen”);

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple?employeeName=employeeName陈孝杰”)

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen3”)

.json(JSON.toJSONString(userLoginModel))

.post();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testPost3() {

InputStream in = Thread.currentThread().getClass().getResourceAsStream(“/logo.png”);

InputStream in2 = Thread.currentThread().getClass().getResourceAsStream(“/logo.png”);

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/file”)

.data(“employeeId”, “00160043”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰3”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen3”)

.data(“fileinput”, “attachment.png”, in)

.data(“fileinput2”, “attachment2.png”, in2)

.post();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testPut() {

UserLoginModel userLoginModel = new UserLoginModel();

userLoginModel.setEmployeeId(“0016004”);

userLoginModel.setEmployeeName(“陈孝杰”);

userLoginModel.setAd(“xiaojie.chen”);

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/1”)

.json(JSON.toJSONString(userLoginModel))

.put();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testPatch() {

UserLoginModel userLoginModel = new UserLoginModel();

userLoginModel.setEmployeeId(“0016004”);

userLoginModel.setEmployeeName(“陈孝杰”);

userLoginModel.setAd(“xiaojie.chen”);

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/2”)

.json(JSON.toJSONString(userLoginModel))

.patch();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testDelete() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/1”)

.data(“aa”, “陈孝杰”)

.delete();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testHead() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/2”)

.head();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testOptions() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/3”)

.options();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testTrace() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/4”)

.trace();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testTrace2() {

HttpRequestException httpRequestException = null;

try {

HttpInvoker.Response response = HttpInvoker.builder(HttpClientBuilder.builder().followRedirects(true).build())

.uri(Consts.URL + “/redirect/loop”)

.trace();

response.log();

} catch (HttpRequestException e) {

httpRequestException = e;

}

Assert.assertNull(httpRequestException);

}

@Test

public void testHeaders() {

HttpInvoker.Response response = HttpInvoker.builder(HttpClientBuilder.builder()

.header(“AAA”, “VVV”)

.header(HttpHeaders.USER_AGENT, “VVVVVVFSDSFSF”)

.build())

.uri(Consts.URL + “/simple/3”)

.data(“employeeId”, “00160041”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰1”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen1”)

.header(“AAA”, “BBB”)

.header(“AAA”, “BBB2”)

.headers(ImmutableMap.of(“BBB”, “CCC”))

.headers(ImmutableMap.of(HttpHeaders.USER_AGENT, “ASSSDDSDSDD”))

.get();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testCookie() {

BasicClientCookie cookie1 = new BasicClientCookie(“Auth”, “AuthAuth”);

cookie1.setPath(“/”);

cookie1.setDomain(“localhost”);

BasicClientCookie cookie2 = new BasicClientCookie(“Auth2”, “Auth2Auth2”);

cookie2.setPath(“/”);

cookie2.setDomain(“localhost”);

BasicClientCookie cookie3 = new BasicClientCookie(“Auth3”, “Auth3Auth3”);

cookie3.setPath(“/”);

cookie3.setDomain(“localhost”);

HttpInvoker.Response response = HttpInvoker.builder(HttpClientBuilder.builder()

.header(“AAA”, “VVV”)

.header(HttpHeaders.USER_AGENT, “VVVVVVFSDSFSF”)

.cookie(cookie1)

.cookies(Lists.newArrayList(cookie2, cookie3))

.build())

.uri(Consts.URL + “/simple/3”)

.data(“employeeId”, “00160041”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰1”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen1”)

.header(“AAA”, “BBB”)

.header(“AAA”, “BBB2”)

.headers(ImmutableMap.of(“BBB”, “CCC”))

.headers(ImmutableMap.of(HttpHeaders.USER_AGENT, “ASSSDDSDSDD”))

.cookie(“Auth”, “123”)

.cookies(ImmutableMap.of(“Auth5”, “Auth5Auth5”, “Auth6”, “Auth6Auth6”))

.get();

response.log();

Assert.assertTrue(response.isSuccess());

}

@Test

public void testInterceptor() {

HttpInvoker.Response response = HttpInvoker.builder()

.uri(Consts.URL + “/simple/3”)

.data(“employeeId”, “00160041”)

.data(ImmutableMap.of(“employeeName”, “陈孝杰1”))

.data(“ad”, “xiaojie.chen”, “ad”, “xiaojie.chen1”)

.header(“AAA”, “BBB”)

.header(“AAA”, “BBB2”)

.headers(ImmutableMap.of(“BBB”, “CCC”))

.headers(ImmutableMap.of(HttpHeaders.USER_AGENT, “ASSSDDSDSDD”))

.cookie(“Auth”, “123”)

.cookies(ImmutableMap.of(“Auth5”, “Auth5Auth5”, “Auth6”, “Auth6Auth6”))

.interceptor(new HttpInvoker.Interceptor() {

@Override

public boolean intercept(HttpRequestBase httpRequestBase) throws HttpRequestException {

System.out.println(httpRequestBase);

return true;

}

})

.interceptor(new BasicAuthInterceptor(“AAA”, “BBB”, “UTF-8”))

.get();

response.log();

Assert.assertTrue(response.isSuccess());

}

}

通过api的方式请求

java api

public interface SimpleHttpApi {

@RequestMapping(“/simple/{loginId}”)

Response queryByLoginId(@PathVariable(“loginId”) int loginId);

@RequestMapping(“/simple/{loginId}”)

HttpResult> queryHttpResultByLoginId(@PathVariable(“loginId”) int loginId);

@RequestMapping(value = “/simple/{loginId}”, method = HttpMethod.GET)

Response getByLoginId(@PathVariable(“loginId”) int loginId,

@RequestParam(value = “employeeId”) String employeeId,

@RequestParam(value = “employeeName”) String employeeName,

@RequestParam(value = “ad”) String ad);

@RequestMapping(value = “/simple/{loginId}”, method = HttpMethod.POST)

Response addByLoginId(@PathVariable(“loginId”) int loginId,

@RequestParam(value = “employeeId”) String employeeId,

@RequestParam(value = “employeeName”) String employeeName,

@RequestParam(value = “ad”) String ad);

@RequestMapping(value = “/simple”, method = HttpMethod.POST)

Response addUser(UserLoginModel userLoginModel);

@RequestMapping(value = “/simple”, method = HttpMethod.POST)

HttpResult> addUser2(@RequestBody UserLoginModel userLoginModel);

@RequestMapping(value = “/simple”, method = HttpMethod.POST)

HttpResult> addUser3(String userLoginModel);

@RequestMapping(value = “/simple”, method = HttpMethod.POST)

HttpResult> addUser4(@RequestBody String userLoginModel);

@RequestMapping(value = “/{path}”, method = HttpMethod.POST)

HttpResult> addUser5(@RequestBody UserLoginModel userLoginModel,

@PathVariable(“path”) String path,

@RequestParam(value = “employeeId”) String employeeId,

@RequestParam(value = “employeeId”) String employeeId2,

@RequestParam(value = “employeeId”) String employeeId3,

@RequestParam(value = “employeeName”) String employeeName,

@RequestParam(value = “ad”) String ad);

@RequestMapping(value = “/simple/{loginId}”, method = HttpMethod.PUT)

HttpResult> updateUser(@RequestBody UserLoginModel userLoginModel,

@PathVariable(“loginId”) int loginId,

@RequestParam(value = “employeeId”) String employeeId,

@RequestParam(value = “employeeId”) String employeeId2,

@RequestParam(value = “employeeId”) String employeeId3,

@RequestParam(value = “employeeName”) String employeeName,

@RequestParam(value = “ad”) String ad);

@RequestMapping(value = “/simple/{loginId}”, method = HttpMethod.PATCH)

HttpResult> patchUser(@RequestBody UserLoginModel userLoginModel,

@PathVariable(“loginId”) int loginId,

@RequestParam(value = “employeeId”) String employeeId,

@RequestParam(value = “employeeId”) String employeeId2,

@RequestParam(value = “employeeId”) String employeeId3,

@RequestParam(value = “employeeName”) String employeeName,

@RequestParam(value = “ad”) String ad);

@RequestMapping(value = “/simple/{loginId}”, method = HttpMethod.DELETE)

HttpResult deleteUser(@RequestBody UserLoginModel userLoginModel,

@PathVariable(“loginId”) int loginId,

@RequestParam(value = “employeeId”) String employeeId,

@RequestParam(value = “employeeId”) String employeeId2,

@RequestParam(value = “employeeId”) String employeeId3,

@RequestParam(value = “employeeName”) String employeeName,

@RequestParam(value = “ad”) String ad);

}

通过java 请求

HttpInvocationHandler httpInvocationHandler = new HttpInvocationHandler();

httpInvocationHandler.setRequestUrlPrefix(Consts.URL);

SimpleHttpApi simpleHttpApi = (SimpleHttpApi) Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(),

new Class[]{SimpleHttpApi.class},

httpInvocationHandler);

UserLoginModel userLoginModel = new UserLoginModel();

userLoginModel.setLoginId(1);

userLoginModel.setEmployeeId(“0016004”);

userLoginModel.setEmployeeName(“陈孝杰”);

userLoginModel.setAd(“xiaojie.chen”);

Response response = simpleHttpApi.addUser(userLoginModel);

System.out.println(response.getData());

通过spring xml

xmlns=”http://www.springframework.org/schema/beans”

xsi:schemaLocation=”http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd”>

测试类请参考com.chenxiaojie.http.invoker.test.http.test.SimpleTest

建议

如果请求量比较大, 请尽量自定义httpclient, 否则全局共享一个默认的httpclient

如果请求量比较大, 请将http请求详细日志重置到其他位置或者关闭

日志位置重置

log4j2.xml

/data/applogs/http-invoker-demo/logs

%d{yyyy-MM-dd HH:mm:ss.SSS} %level [%t] [%c] %msg%xEx%n

filePattern=”${log-path}/http.log.%d{yyyy-MM-dd}”>

关闭日志 spring xml

xmlns=”http://www.springframework.org/schema/beans”

xsi:schemaLocation=”http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd”>

init-method=”init”>

打包命令

mvn clean install -DskipTests -Dmaven.javadoc.skip=true

维护

有任何问题请随时联系:陈孝杰, qq:3262515, email: 3262515@qq.com

今天的文章Java编译器_Java编译器分享到此就结束了，感谢您的阅读。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
如需转载请保留出处：https://bianchenghao.cn/77999.html

赞 (0)
编程小号编程小号
0

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注