Java实现Http多次请求复用同一连接

这篇具有很好参考价值的文章主要介绍了Java实现Http多次请求复用同一连接。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

早在HTTP/1.0时代,每次HTTP请求都要创建一个连接,而创建连接的过程需要消耗资源和时间,代价相对昂贵,为了减少资源消耗,缩短响应时间,就需要重用连接。在后来的HTTP/1.1中,引入了连接复用的机制,Http Header中加入Connection: keep-alive来告诉对方这个请求响应完成后先不忙关闭,这也是本篇文章的由来。

复用的基本条件

理论基础

OSI是Open System Interconnection的缩写,意为开放式系统互联。国际标准化组织(ISO)制定了OSI模型,该模型定义了不同计算机互联的标准,是设计和描述计算机网络通信的基本框架。也就是如下七层模型:

java循环发送http请求,http,网络协议,网络,Java,http请求,程序员

当然也有大家熟知的五层模型,也就是把会话层、表示层、应用层合称为应用层。耳熟能详的TCP、UDP属于数量稀少的传输层协议。在这之上的应用层协议百花齐放诸如:HTTP、SMTR、FTP......,然后很多中间件也自定义了通讯协议,比如Dubbo、Mysql。

读到这里大家可能就已经清醒的意识到,即使同属应用层的协议,是否支持长连接也不尽相同。笔者想要传达的一个认知:之所以能支持长连接,那是因为TCP经历三次握手建立连接之后,如果不出现其他意外是可以保证连接状态的。也就是说应用层协议是否属于长连接仅仅取决于成功建立TCP,发送一个请求之后,对该连接的处理策略:

  • 如早期的HTTP每次发送请求,Server端回复完毕之后直接关闭则是短连接
  • 如Mysql处理完一条SQL请求,然后继续执行下一个则是长连接

这其实就是我们的理论基础,HTTP有希望支持长连接的前提是TCP本身就是长连接。

现实基础

HTTP协议并非魔法,不是说新增一条规范,也不是简简单单的Header中加入Connection: keep-alive就能立马支持长连接了。想要达到这个目的需要Client、Server端共同努力。

客户端譬如Chrome浏览器,服务端譬如阿里OSS,像这样两端都支持了新的规范,HTTP才能快乐的成为长连接阵营中的一员。

获取HTTP资源常见方式

因为JDK提供了相关工具、且平台相关的第三方包也足够优秀,所以Java获取HTTP资源并非难事。

 

@Slf4j
public class SinaPicDownload {

    /* 微博上某个画师的作品 */
    static final String HTTP_URL = "https://wx3.sinaimg.cn/mw2000/006jQ3i8ly1h5k50zujydj35k0334kjo.jpg";
    /* 下载之后放在颜如玉电脑的io文件下 */
    static final String LOCAL = "/Users/admin/io/灵魂莲华-皎月.jpeg";

    public static void main(String[] args) {
        try (
            InputStream in = new URL(HTTP_URL).openStream();
            FileOutputStream out = new FileOutputStream(LOCAL)
        ) {
            byte[] buffer = new byte[1024 << 2];
            int read;
            while ((read = in.read(buffer)) > -1) {
                out.write(buffer, 0, read);
            }
            out.flush();
        } 
        catch (Throwable e) {
            log.error("获取HTTP资源失败:", e);
        }
    }

}

java循环发送http请求,http,网络协议,网络,Java,http请求,程序员

配合Java 7之后提供的try-with-resources语法糖,你甚至仅仅只需要不到二十行的代码就可以轻而易举的达到目的,但是缺点也显而易见,通过这种方法每次只能获取一个资源,用完之后只能完毕。我当时就在想,Java怎么实现一次连接多次请求呢?

Transfer-Encoding

笔者在上文提到的理论基础上推测到肯定可以使用Java提供的Socket建立TCP连接,关键问题是怎么跟Server端描述HTTP请求呢?

java循环发送http请求,http,网络协议,网络,Java,http请求,程序员

类比到现实生活中,两者能顺畅交流必然要求双方都可以听懂对方的语言。那HTTP有没有一种Client、Server都能解析的规范呢,HTTP Transfer-Encoding正是在这种背景下应运而生。通俗的来讲Transfer-Encoding就是一种双方都约定好的格式,我按照这个格式Encoding,你按照这个格式Decoding,ta大概长这个样子:java循环发送http请求,http,网络协议,网络,Java,http请求,程序员 可想而知刚刚获取那张图片资源的是时候,我们肯定是这么跟新浪微博服务端说的:

 java循环发送http请求,http,网络协议,网络,Java,http请求,程序员

声明:

  • 真实的Request Line与图中一致
  • Header其实复杂很多,配图做了简化
  • 该请求Body为空,图中略过

简略实现

先声明一些常量,以备后用

 

@Slf4j
public class ReusableHttp {
    
    /* 颜如玉公司的OSS服务域名 */
    static final String HOST = "****.oss-cn-zhangjiakou.aliyuncs.com";
    static final int PORT = 80;

    /* 颜如玉在OSS上放置的几个资源 */
    static final String[] URLS = new String[]{
        "/context/reusable/gtyj.text",
        "/context/reusable/tlyxqch.text",
        "/context/reusable/yj.text",
        "/context/reusable/ls.text"
    };
    
    /* CR = '\r'; LF = '\n'*/
    static final byte[] CRLF = new byte[]{Chars.CR, Chars.LF};
    static final String LOCAL_PATH = "/Users/admin/io/";
    
}

 建立TCP连接,然后获得输出,输入流

public static void main(String[] args) {
    try {
        try (
            Socket socket = new Socket(HOST, PORT);
            OutputStream out = socket.getOutputStream();
            InputStream in = socket.getInputStream()
        ) {
            /* 复用连接,获取资源 */
            reusable(out, in);
        }
    }
    catch (IOException e) {
        log.error("请求出现异常", e);
    }
}

写出Request Line

/**
 * Write Request Line
 *
 * RequestLine encoding规范
 *
 * **********************************************
 * * method * sp * URL * sp * version * cr * lf *
 * **********************************************
 */
static void writeRequestLine(OutputStream out, String url) throws IOException {
    /* 注意空格一定要按照规定来摆放 */
    out.write(("GET " + url + " HTTP/1.1").getBytes());
    /* 最后再写入一个回车、换行符表示Request Line结束 */
    out.write(CRLF);
}

写出Request Header

/**
 * Write Request Header
 *
 * HeaderLine encoding规范
 *
 * *******************************************
 * * header field name * : * value * cr * lf *
 * *******************************************
 * ....
 * *******************************************
 * * header field name * : * value * cr * lf *
 * *******************************************
 * ...
 * ***********
 * * cr * lf *
 * ***********
 * ***************
 * * Entity Body *
 * ***************
 */
static void writeHeaderLine(OutputStream out) throws IOException {
    out.write("Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9".getBytes());
    out.write(CRLF);

    out.write("Accept-Encoding: gzip, deflate".getBytes());
    out.write(CRLF);

    out.write("Accept-Language: zh-CN,zh;q=0.9".getBytes());
    out.write(CRLF);

    out.write("Connection: keep-alive".getBytes());
    out.write(CRLF);

    out.write("Host: kuaimai-sheji.oss-cn-zhangjiakou.aliyuncs.com".getBytes());
    out.write(CRLF);
    /* 最后再写入一个回车、换行符表示Request Header结束 */
    out.write(CRLF);
}

因为是简单的请求,所以直接省略Request Body。发出如上报文后,Server端会解析请求,然后回复。

/**
 * 1.向Server端写出请求
 * 2.接受Server端回复
 * 3.写到颜如玉本地机器的io文件夹下
 *
 * @param out 往Server端写出流
 * @param in  Server端往Client端写入流
 */
static void reusable(OutputStream out, InputStream in) throws IOException {
    for (int i = 0, s = URLS.length; i < s; i++) {
        writeRequestLine(out, URLS[i]);

        writeHeaderLine(out);

        out.flush();

        byte[] bytes = new byte[512];
        in.read(bytes);

        String file = LOCAL_PATH + i + ".text";
        try (
            FileOutputStream fo = new FileOutputStream(file)
        ) {
            fo.write(bytes);
            fo.flush();
        }
        catch (Throwable e) {
            log.error("文件写入出现异常", e);
        }
    }
}

java循环发送http请求,http,网络协议,网络,Java,http请求,程序员文章来源地址https://www.toymoban.com/news/detail-768505.html

 可以看到功能已经实现,同一连接我反复请求了四次,最终得到四个资源。

到了这里,关于Java实现Http多次请求复用同一连接的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • java实现调用http请求的几种常见方式

    ------ Oracle中文开发者社区 ------ 如果你想要学习编程,关注本博客,持续获得技术支持,持续获得技术咨询 java开发·企业官方账号 Oracle中国官方账号 Java中国管理部 全网粉丝30万+ 华为云享专家 阿里专家博主 CSDN内容合伙人 CSDN原力计划作者 51CTO专家博主 CSDN博客V账号 毕业于四川

    2024年02月04日
    浏览(53)
  • Java实现HTTP请求的几种方式-CloseableHttpClient(三)

    CloseableHttpClient是在HttpClient的基础上修改更新而来的,这里还涉及到请求头token的设置(请求验证),利用fastjson转换请求或返回结果字符串为json格式,当然上面两种方式也是可以设置请求头token、json的,这里只在下面说明。 基于第一章的测试接口,建立以下程序 创建客户端

    2023年04月20日
    浏览(45)
  • Java实现HTTP请求的几种方式-HttpURLConnection(一)

    在实际开发过程中,我们经常需要调用对方提供的接口或测试自己写的接口是否合适。很多项目都会封装规定好本身项目的接口规范,所以大多数需要去调用对方提供的接口或第三方接口(短信、天气等)。 准备两个项目: 项目A: 服务提供者 项目B:服务消费者 在项目A中

    2024年02月16日
    浏览(42)
  • Java 实现 HTTP 请求的四种方式,你都学会了么?

    前言 在日常工作和学习中,有很多地方都需要发送HTTP请求,本文以Java为例,总结发送HTTP请求的多种方式 HTTP请求实现过程 GET 创建远程连接 设置连接方式(get、post、put…) 设置连接超时时间 设置响应读取时间 发起请求 获取请求数据 关闭连接 POST 创建远程连接 设置连接方

    2024年02月08日
    浏览(46)
  • java发送Http请求

    使用java 11添加的HttpClient新API发送Http(Https)请求 HTTP客户端是在Java 11中添加的。它可以用于通过网络请求HTTP资源。它支持 HTTP / 1.1和HTTP / 2(同步和异步编程模型),将请求和响应主体作为反应流处理,并遵循熟悉的构建器模式。 参考文章:https://blog.csdn.net/allway2/article/detail

    2023年04月12日
    浏览(38)
  • Java http 接口请求

    2024年02月11日
    浏览(41)
  • 【Java】HTTP请求工具类

    在工作中可能存在要去调用其他项目的接口,这篇文章我们实现在Java代码中实现调用其他项目的接口。 本章内容: 创建一个携带参数的POST请求,去请求其他项目的接口并返回数据。 附加HTTP请求工具类,包含(GET、POST、无参GET、无参POST) 导入 pom 依赖 创建一个 携带参数的

    2024年02月12日
    浏览(46)
  • 用java发送http请求

    在 Java 中发送 HTTP 请求可以使用标准的 Java 库或者第三方库。这里介绍使用 Java 标准库中的 HttpURLConnection 类来发送 HTTP 请求的方法: 首先,使用 URL 类来创建一个 URL 对象,指定要访问的 URL。 使用 URL 对象的 openConnection 方法来获取 HttpURLConnection 对象。 设置 HTTP 请求的方法

    2024年02月16日
    浏览(39)
  • java中线程池是如何实现复用的?

    Java 中线程池实现线程复用的核心机制在于通过维护一定数量的核心线程和可扩展的工作队列来处理任务。线程复用的过程可以分为以下几个步骤: 核心线程复用: 线程池会维护一定数量的核心线程,这些线程在处理任务时会一直保持存活,不会被回收。当有新任务提交时,

    2024年02月04日
    浏览(50)
  • (下篇)java通过http请求请求三方接口:设置请求头,请求体

    介绍:springcloud项目server子模块内部集成了低代码平台来配置通用列表查询,需要对低代码配置权限,低代码使用不了server模块的feign调用,只能用http请求去调用分布式项目的用户模块来获取权限,通过restTemplate调用接口,postman携带token信息可以直接调通用户中心,但是通过

    2024年02月04日
    浏览(39)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包