com.aliyun.openservices.iot.api.http2

Class IotHttp2Client

java.lang.Object

com.aliyun.openservices.iot.api.http2.IotHttp2Client

public class IotHttp2Client
extends Object

iot client communicate with http2 server

Author:

brhao

Date:

16/03/2018

Field Summary

Fields

Modifier and Type	Field and Description
static int	CONNECTION_COUNT_UNLIMITED

Constructor Summary

Constructors

Constructor and Description
IotHttp2Client(Profile profile, int maxConnectionCount)

Method Summary

Modifier and Type	Method and Description
void	addConnectionListener(ConnectionListener listener)
List<Connection>	allConnections()
io.netty.handler.codec.http2.Http2Headers	authHeader() generate header with authorization parameters
Connection	newConnection() create new connection to server
Optional<Connection>	randomConnection(Predicate<Connection> predicate)
void	removeConnectionListener(ConnectionListener listener)
CompletableFuture<Http2Response>	sendRequest(Connection connection, io.netty.handler.codec.http2.Http2Headers headers, byte[] data)
void	sendRequest(Connection connection, io.netty.handler.codec.http2.Http2Headers headers, byte[] data, Http2StreamListener listener)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONNECTION_COUNT_UNLIMITED

public static final int CONNECTION_COUNT_UNLIMITED

See Also:

Constant Field Values

Constructor Detail

IotHttp2Client

public IotHttp2Client(Profile profile,
                      int maxConnectionCount)

Method Detail

newConnection

public Connection newConnection()
                         throws ExecutionException,
                                InterruptedException

create new connection to server

Returns:

connection

Throws:

ExecutionException - executionException

InterruptedException - interruptedException

authHeader

public io.netty.handler.codec.http2.Http2Headers authHeader()

generate header with authorization parameters

Returns:

Http2Header

shutdown

public void shutdown()

addConnectionListener

public void addConnectionListener(ConnectionListener listener)

removeConnectionListener

public void removeConnectionListener(ConnectionListener listener)

allConnections

public List<Connection> allConnections()

sendRequest

public void sendRequest(Connection connection,
                        io.netty.handler.codec.http2.Http2Headers headers,
                        byte[] data,
                        Http2StreamListener listener)

sendRequest

public CompletableFuture<Http2Response> sendRequest(Connection connection,
                                                    io.netty.handler.codec.http2.Http2Headers headers,
                                                    byte[] data)

randomConnection

public Optional<Connection> randomConnection(Predicate<Connection> predicate)