当前位置: 首页 > 知识库问答 >
问题:

如何通过TLS使用HTTP/2发送HTTP请求?(Java 11 HttpClient)

卢涵畅
2023-03-14
private void obtainResponse(Socket socket, IHttpRequest req, String uri) {

        HttpClient client = null;
        if (req.isSSL()) {
            SSLContext sslContext = ((SecureConnectionHandler)connHandler).createSSLContext( req.getHost() );
            client = HttpClient.newBuilder()
                    .connectTimeout(Duration.ofSeconds(30))
                    .priority(1)
                    .version(HttpClient.Version.HTTP_2)
                    .followRedirects(Redirect.NORMAL)
                    .sslContext( sslContext )
                    .build();
        }
        else
            client = HttpClient.newBuilder()
                    .connectTimeout(Duration.ofSeconds(30))
                    .priority(1)
                    .version(HttpClient.Version.HTTP_2)
                    .followRedirects(Redirect.NORMAL)
                    .build();

        String protocolAndHost = ((req.isSSL()) ? "https://" : "http://") + req.getHost();

        if (uri == null)
            uri = protocolAndHost + req.getRequestedResource();
        else {
            if (uri.startsWith("/"))
                uri = protocolAndHost + uri;
            System.out.println("Aqui:" + uri);
        }

        HttpRequest.Builder preRequest=null;
        if (req.getMethod().equalsIgnoreCase("GET")) {
            preRequest = HttpRequest.newBuilder()  // GET request!
                .uri(URI.create( uri ))
                .GET();
        }
        else if (req.getMethod().equalsIgnoreCase("POST")) {
            preRequest = HttpRequest.newBuilder()  // POST request!
            .uri(URI.create( uri ))
            .POST(BodyPublishers.ofString(req.getBody()));
        }

        for (Header header : req.getHeaders()) {
            if (!header.getKey().equalsIgnoreCase("Host") &&
                !header.getKey().equalsIgnoreCase("Connection") &&
                !header.getKey().equalsIgnoreCase("Content-Length") &&
                !header.getKey().equalsIgnoreCase("Upgrade") ) 
            {
                preRequest.setHeader(header.getKey(), header.getValues());
            }
        }
        HttpRequest request = preRequest.build();

        System.err.println("Request to: " + uri);

        HttpResponse<byte[]> response;
        try {
            response = client.sendAsync(request, BodyHandlers.ofByteArray())
                             .join();   
        } catch (CompletionException ce) {
            System.err.println("Address " + uri + " is unreachable!");
            return ;
        }

        HttpHeaders httpHeaders = response.headers();

        Optional<String> locationHeader = httpHeaders.firstValue("Location"); // When resource has been permanently moved

        if ( !locationHeader.isEmpty() ) {
            System.out.println("Moved permanently to " + locationHeader.get());
            obtainResponse( socket, req, locationHeader.get() );
        }
        else {
            Map<String, List<String>> headers = httpHeaders.map();

            String protocol = response.version().toString().replace("_", ".").replaceFirst("\\.", "/");

            int code = response.statusCode();

            String reasonPhrase = HttpStatus.getStatusText( code );

            var crlf = "\r\n";

            var responseString = protocol + " " + code + " " + reasonPhrase + crlf;

            for (String key : headers.keySet()) {
                responseString += key + ":";
                for (String valor : headers.get(key)) {
                    responseString += " " + valor;
                }
                responseString += crlf;
            }

            responseString += crlf; // espacio cabeceras y cuerpo

            writeResponse(socket, response.body(), responseString);
        }
    }


private void writeResponse(Socket socket, byte[] streamResponse, String responseHeaders) {
        OutputStream outputStream = null;
        try {
            outputStream = socket.getOutputStream(); 

            outputStream.write(responseHeaders.getBytes());
            outputStream.write(streamResponse);
            outputStream.flush();

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            try {
                if (!socket.isOutputShutdown()) {
                    socket.shutdownOutput();
                }
                outputStream.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

        }
    }

(↓↓正文↓↓)

<\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\"Ums 5wè[$#k'éífowwrnic's-+'ééó'ééá1•'\\\\\

<<以及更多字节形式的信息>>

你在我的代码里看到什么奇怪的吗?我知道HTTP/2压缩帧中的标头,但我假定是HTTPClient在内部完成的...

如果您需要更多信息,请告诉我:)

提前谢谢你。

暂时还没有答案

 类似资料:
  • 问题内容: 似乎urllib2默认发送HTTP / 1.1请求? 问题答案: urllib2在后台使用httplib进行连接。您可以将其更改为http 1.0,如下所示。我已包含我的apache服务器访问日志,以显示http连接如何更改为1.0 码 访问日志

  • 我正在尝试让客户端/服务器程序通过ssl交换http消息。首先,我创建了使用DefaultHttpRequest成功交换http请求的客户端和服务器程序。发送请求的代码如下所示: 客户端管道工厂包含以下内容: 服务器管道工厂包含以下内容: .... 到目前为止一切顺利。客户端发送请求,服务器接收并解码请求。使用正确的数据调用我的处理程序上的messageReceived方法。 为了启用 SSL,我

  • 问题内容: 我是Android的新手,所以关于android的知识还不是很多,好的,请讲到重点,我需要通过用户名和密码进行 登录 ,因为我必须通过JSON进行http requset并返回响应也将以JSON格式提供。所以任何人都可以帮助我。谢谢。 问题答案: 试试这个代码

  • 很多时候我们需要在页面打开的时候,读取远程的内容,然后在当前页面显示. 这就需要用到 http请求了. vue页面调用http请求 vuejs 内置了对发送http请求的支持. 只需要在对应页面的script 标签内加上对应的代码就好. 例如: 我们新增一个页面,叫 "博客列表页" : src/components/BlogList.vue, 内容如下: <template> <div >

  • 我正试图使用Guzzle6 http客户端发送一个post请求。我发送了两个请求,一个内容类型为(Guzzle),另一个为(Guzzle)。 我将客户机初始化如下(分别为和): 我收到的响应没有相同的数据/正文: :的输出 但是为什么我首先问这个问题是因为我面临签名不匹配的问题。 当我发送请求时,我添加了一个带有签名的头,签名是。因此,当以和的形式发送数据时,我得到了不同的签名(因为在的情况下,接

  • 问题内容: 我在这里尝试做的是获取给定URL的标头,以便确定MIME类型。我希望能够查看是否http://somedomain/foo/将返回例如HTML文档或JPEG图像。因此,我需要弄清楚如何发送HEAD请求,以便无需下载内容就可以读取MIME类型。有人知道这样做的简单方法吗? 问题答案: 使用。 还有一个getheader(name)获取特定的标头。