You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2025/09/24 19:51:17 UTC
(httpcomponents-core) 03/03: Removed obsolete TLS ALPN example
This is an automated email from the ASF dual-hosted git repository.
olegk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/httpcomponents-core.git
commit 34bade0fb3998603a36eec4e57b6c65e6ac6a914
Author: Oleg Kalnichevski <ol...@apache.org>
AuthorDate: Wed Sep 24 21:38:35 2025 +0200
Removed obsolete TLS ALPN example
---
.../examples/H2TlsAlpnRequestExecutionExample.java | 163 ---------------------
1 file changed, 163 deletions(-)
diff --git a/httpcore5-h2/src/test/java/org/apache/hc/core5/http2/examples/H2TlsAlpnRequestExecutionExample.java b/httpcore5-h2/src/test/java/org/apache/hc/core5/http2/examples/H2TlsAlpnRequestExecutionExample.java
deleted file mode 100644
index 5a67e0965..000000000
--- a/httpcore5-h2/src/test/java/org/apache/hc/core5/http2/examples/H2TlsAlpnRequestExecutionExample.java
+++ /dev/null
@@ -1,163 +0,0 @@
-/*
- * ====================================================================
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- * ====================================================================
- *
- * This software consists of voluntary contributions made by many
- * individuals on behalf of the Apache Software Foundation. For more
- * information on the Apache Software Foundation, please see
- * <http://www.apache.org/>.
- *
- */
-package org.apache.hc.core5.http2.examples;
-
-import java.util.List;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.Future;
-
-import org.apache.hc.core5.concurrent.FutureCallback;
-import org.apache.hc.core5.http.Header;
-import org.apache.hc.core5.http.HttpConnection;
-import org.apache.hc.core5.http.HttpHost;
-import org.apache.hc.core5.http.HttpResponse;
-import org.apache.hc.core5.http.Message;
-import org.apache.hc.core5.http.impl.bootstrap.HttpAsyncRequester;
-import org.apache.hc.core5.http.nio.AsyncClientEndpoint;
-import org.apache.hc.core5.http.nio.entity.StringAsyncEntityConsumer;
-import org.apache.hc.core5.http.nio.support.AsyncRequestBuilder;
-import org.apache.hc.core5.http.nio.support.BasicResponseConsumer;
-import org.apache.hc.core5.http2.config.H2Config;
-import org.apache.hc.core5.http2.frame.RawFrame;
-import org.apache.hc.core5.http2.impl.nio.H2StreamListener;
-import org.apache.hc.core5.http2.impl.nio.bootstrap.H2RequesterBootstrap;
-import org.apache.hc.core5.http2.ssl.H2ClientTlsStrategy;
-import org.apache.hc.core5.io.CloseMode;
-import org.apache.hc.core5.ssl.SSLContexts;
-import org.apache.hc.core5.util.Timeout;
-
-/**
- * This example demonstrates how to execute HTTP/2 requests over TLS connections.
- * <p>
- * It requires Java runtime with ALPN protocol support (such as Oracle JRE 9 or newer).
- */
-public class H2TlsAlpnRequestExecutionExample {
-
- public static void main(final String[] args) throws Exception {
- // Create and start requester
- final H2Config h2Config = H2Config.custom()
- .setPushEnabled(false)
- .build();
-
- final HttpAsyncRequester requester = H2RequesterBootstrap.bootstrap()
- .setH2Config(h2Config)
- .setTlsStrategy(new H2ClientTlsStrategy(SSLContexts.createSystemDefault(), (endpoint, sslEngine) -> {
- // IMPORTANT uncomment the following line when running Java 9 or older
- // in order to avoid the illegal reflective access operation warning
- // ====
- // return new TlsDetails(sslEngine.getSession(), sslEngine.getApplicationProtocol());
- // ====
- return null;
- }))
- .setStreamListener(new H2StreamListener() {
-
- @Override
- public void onHeaderInput(final HttpConnection connection, final int streamId, final List<? extends Header> headers) {
- for (int i = 0; i < headers.size(); i++) {
- System.out.println(connection.getRemoteAddress() + " (" + streamId + ") << " + headers.get(i));
- }
- }
-
- @Override
- public void onHeaderOutput(final HttpConnection connection, final int streamId, final List<? extends Header> headers) {
- for (int i = 0; i < headers.size(); i++) {
- System.out.println(connection.getRemoteAddress() + " (" + streamId + ") >> " + headers.get(i));
- }
- }
-
- @Override
- public void onFrameInput(final HttpConnection connection, final int streamId, final RawFrame frame) {
- }
-
- @Override
- public void onFrameOutput(final HttpConnection connection, final int streamId, final RawFrame frame) {
- }
-
- @Override
- public void onInputFlowControl(final HttpConnection connection, final int streamId, final int delta, final int actualSize) {
- }
-
- @Override
- public void onOutputFlowControl(final HttpConnection connection, final int streamId, final int delta, final int actualSize) {
- }
-
- })
- .create();
- Runtime.getRuntime().addShutdownHook(new Thread(() -> {
- System.out.println("HTTP requester shutting down");
- requester.close(CloseMode.GRACEFUL);
- }));
- requester.start();
-
- final HttpHost target = new HttpHost("https", "nghttp2.org", 443);
- final String[] requestUris = new String[] {"/httpbin/ip", "/httpbin/user-agent", "/httpbin/headers"};
-
- final CountDownLatch latch = new CountDownLatch(requestUris.length);
- for (final String requestUri: requestUris) {
- final Future<AsyncClientEndpoint> future = requester.connect(target, Timeout.ofSeconds(5));
- final AsyncClientEndpoint clientEndpoint = future.get();
- clientEndpoint.execute(
- AsyncRequestBuilder.get()
- .setHttpHost(target)
- .setPath(requestUri)
- .build(),
- new BasicResponseConsumer<>(new StringAsyncEntityConsumer()),
- new FutureCallback<Message<HttpResponse, String>>() {
-
- @Override
- public void completed(final Message<HttpResponse, String> message) {
- clientEndpoint.releaseAndReuse();
- final HttpResponse response = message.getHead();
- final String body = message.getBody();
- System.out.println(requestUri + "->" + response.getCode() + " " + response.getVersion());
- System.out.println(body);
- latch.countDown();
- }
-
- @Override
- public void failed(final Exception ex) {
- clientEndpoint.releaseAndDiscard();
- System.out.println(requestUri + "->" + ex);
- latch.countDown();
- }
-
- @Override
- public void cancelled() {
- clientEndpoint.releaseAndDiscard();
- System.out.println(requestUri + " cancelled");
- latch.countDown();
- }
-
- });
- }
-
- latch.await();
- System.out.println("Shutting down I/O reactor");
- requester.initiateShutdown();
- }
-
-}