Jetty HTTP client

2020-07-08  本文已影响0人  大宫城

一、简介(内容基于9.4.30.v20200611)

    The Jetty HTTP client模块提供了方便易用的API,来执行HTTP或HTTPS请求,由于采用异步非阻塞的设计,可以大大提高线程的利用率,适用于需要高性能的场景,当然,它也提供了 同步的方法来执行请求,并且Jetty HTTP client支持HTTP/1.1和HTTP/2。

    Jetty HTTP客户端提供的现成功能包括:

    1、支持重定向,对302、303的转发状态码自动遵循。

    2、支持cookies

    3、认证支持, HTTP "Basic" and "Digest",其他认证可以扩展

    4、转发代理支持-HTTP代理和SOCKS4代理。

二、应用

1、HttpClient

org.eclipse.jetty.client.HttpClient.是我们要使用的主类,非常重要,为了使用jetty http client,我需要创建一个HttpClient的实例,并启动,可以把这个HttpClient实例看成一个浏览器,可以用它发送不通的请求,还会帮你管理cookie、认证、请求转发。

// 创建实例HttpClient
httpClient = new HttpClient();
//配置是否允许转发
httpClient.setFollowRedirects(false);
// 启动
HttpClient httpClient.start();

当然,这样的实例只能发送HTTP请求,如果要支持HTTPS的话:

SslContextFactory.Client sslContextFactory = new SslContextFactory.Client();

HttpClient httpClient = new HttpClient(sslContextFactory);

httpClient.start();

以上创建了Httpclient实例,并启动,通常在应用结束的时候,也需要调用stop方法来关闭。

httpClient.stop();

以下的内容都默认使用已经创建好的httpclient对象

2、Blocking APIs(阻塞方式)

简单Demo:

ContentResponse response = httpClient.GET("http://domain.com/path?query");

只有请求完成,才会返回,如果服务器响应慢的话,会一直阻塞在这里。

ContentResponse对象包含HTTP响应信息:状态代码,header以及可能的内容。默认情况下,内容长度限制为2 MiB.

定制请求:

Request request = httpClient.newRequest("http://domain.com/path?query");

//设置请求方法:GET,POST,PUT,DELETE 等
request.method(HttpMethod.GET);

// 设置header中的User-Agent
request.agent("Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:17.0) Gecko/Firefox/17.0");

//设置请求超时时间
 request.timeout(5, TimeUnit.SECONDS);

//添加URI查询参数,也就是URL后缀的参数。该值是UTF-8 URL编码的 request.param("name", "value");

//添加请求头,如果值为NULL,则删除
request.header("time", "1594190777");

//发送请求
ContentResponse response = request.send();

//获取返回的状态码
int status = response.getStatus();
//获取返回的内容,并转成string
String json = response2.getContentAsString()
//另外ContentResponse还有如:getEncoding、getHeaders、getMediaType等方法
//这些方法一看名字就知道是做什么的,所以不做多余的介绍了

3、Non-Blocking APIs

Request request = httpClient.newRequest("url");
request.timeout(4000, TimeUnit.MILLISECONDS); //设置超时时间
/** 设置请求内容 */
//1、写入字节数组
byte[] content = new byte[] {1,2,3};
request.content(new BytesContentProvider(content));
//2、输入流作为传输内容
InputStream inputStream = Files.newInputStream(Paths.get("")); request.content(new InputStreamContentProvider(inputStream,4096)); //第二个参数为缓冲区大小
//3、写入字符串
request.content(new StringContentProvider("内容"));
//4、把文件内容当做传输内容
request.content(new PathContentProvider(Paths.get("路径")));
//5、表单提交
MultiPartContentProvider p= new MultiPartContentProvider();
p.addFieldPart("field", new StringContentProvider("foo"), null);
p.addFilePart("icon", "img.png", new PathContentProvider(Paths.get("/tmp/img.png")), null);
p.close();
request.content(p);
/** 处理返回 */

上一篇下一篇

猜你喜欢

热点阅读