@ManagedObject public class HTTP2Client extends ContainerLifeCycle
HTTP2Client provides an asynchronous, non-blocking implementation
to send HTTP/2 frames to a server.
Typical usage:
// Create and start HTTP2Client.
HTTP2Client client = new HTTP2Client();
SslContextFactory sslContextFactory = new SslContextFactory();
client.addBean(sslContextFactory);
client.start();
// Connect to host.
String host = "webtide.com";
int port = 443;
FuturePromise<Session> sessionPromise = new FuturePromise<>();
client.connect(sslContextFactory, new InetSocketAddress(host, port), new ServerSessionListener.Adapter(), sessionPromise);
// Obtain the client Session object.
Session session = sessionPromise.get(5, TimeUnit.SECONDS);
// Prepare the HTTP request headers.
HttpFields requestFields = new HttpFields();
requestFields.put("User-Agent", client.getClass().getName() + "/" + Jetty.VERSION);
// Prepare the HTTP request object.
MetaData.Request request = new MetaData.Request("PUT", new HttpURI("https://" + host + ":" + port + "/"), HttpVersion.HTTP_2, requestFields);
// Create the HTTP/2 HEADERS frame representing the HTTP request.
HeadersFrame headersFrame = new HeadersFrame(request, null, false);
// Prepare the listener to receive the HTTP response frames.
Stream.Listener responseListener = new new Stream.Listener.Adapter()
{
@Override
public void onHeaders(Stream stream, HeadersFrame frame)
{
System.err.println(frame);
}
@Override
public void onData(Stream stream, DataFrame frame, Callback callback)
{
System.err.println(frame);
callback.succeeded();
}
};
// Send the HEADERS frame to create a stream.
FuturePromise<Stream> streamPromise = new FuturePromise<>();
session.newStream(headersFrame, streamPromise, responseListener);
Stream stream = streamPromise.get(5, TimeUnit.SECONDS);
// Use the Stream object to send request content, if any, using a DATA frame.
ByteBuffer content = ...;
DataFrame requestContent = new DataFrame(stream.getId(), content, true);
stream.data(requestContent, Callback.Adapter.INSTANCE);
// When done, stop the client.
client.stop();
AbstractLifeCycle.AbstractLifeCycleListenerContainer.InheritedListener, Container.ListenerLifeCycle.Listener| Constructor and Description |
|---|
HTTP2Client() |
addBean, addBean, addBean, addEventListener, addManaged, contains, destroy, doStop, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeansaddLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stopprotected void doStart()
throws Exception
ContainerLifeCycledoStart in class ContainerLifeCycleExceptionprotected SelectorManager newSelectorManager()
public Executor getExecutor()
public void setExecutor(Executor executor)
public Scheduler getScheduler()
public void setScheduler(Scheduler scheduler)
public ByteBufferPool getByteBufferPool()
public void setByteBufferPool(ByteBufferPool bufferPool)
public ClientConnectionFactory getClientConnectionFactory()
public void setClientConnectionFactory(ClientConnectionFactory connectionFactory)
public FlowControlStrategy.Factory getFlowControlStrategyFactory()
public void setFlowControlStrategyFactory(FlowControlStrategy.Factory flowControlStrategyFactory)
public ExecutionStrategy.Factory getExecutionStrategyFactory()
public void setExecutionStrategyFactory(ExecutionStrategy.Factory executionStrategyFactory)
@ManagedAttribute(value="The number of selectors") public int getSelectors()
public void setSelectors(int selectors)
@ManagedAttribute(value="The idle timeout in milliseconds") public long getIdleTimeout()
public void setIdleTimeout(long idleTimeout)
@ManagedAttribute(value="The connect timeout in milliseconds") public long getConnectTimeout()
public void setConnectTimeout(long connectTimeout)
@ManagedAttribute(value="The size of the buffer used to read from the network") public int getInputBufferSize()
public void setInputBufferSize(int inputBufferSize)
@ManagedAttribute(value="The ALPN protocol list") public List<String> getProtocols()
@ManagedAttribute(value="The initial size of session\'s flow control receive window") public int getInitialSessionRecvWindow()
public void setInitialSessionRecvWindow(int initialSessionRecvWindow)
@ManagedAttribute(value="The initial size of stream\'s flow control receive window") public int getInitialStreamRecvWindow()
public void setInitialStreamRecvWindow(int initialStreamRecvWindow)
public void connect(InetSocketAddress address, Session.Listener listener, Promise<Session> promise)
public void connect(SslContextFactory sslContextFactory, InetSocketAddress address, Session.Listener listener, Promise<Session> promise)
public void connect(SslContextFactory sslContextFactory, InetSocketAddress address, Session.Listener listener, Promise<Session> promise, Map<String,Object> context)
public void accept(SslContextFactory sslContextFactory, SocketChannel channel, Session.Listener listener, Promise<Session> promise)
protected void configure(SocketChannel channel) throws IOException
IOExceptionCopyright © 1995-2016 Webtide. All Rights Reserved.