com.aliyun.alink.h2.api

Class IotHttp2Client

java.lang.Object

com.aliyun.alink.h2.api.IotHttp2Client

public class IotHttp2Client
extends java.lang.Object

iot client communicate with http2 server

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)
java.util.List<Connection>	allConnections()
Http2Headers	authHeader() generate header with authorization parameters
Connection	newConnection() create new connection to server
Connection	randomConnection() TODO support
void	removeConnectionListener(ConnectionListener listener)
void	sendRequest(Connection connection, Http2Request request, Http2StreamListener listener, CompletableListener<StreamWriteContext> completableListener) send Request interface
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 java.util.concurrent.ExecutionException,
                                java.lang.InterruptedException

create new connection to server

Returns:

connection

Throws:

java.util.concurrent.ExecutionException - executionException

java.lang.InterruptedException - interruptedException

authHeader

public 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 java.util.List<Connection> allConnections()

sendRequest

public void sendRequest(Connection connection,
                        Http2Request request,
                        Http2StreamListener listener,
                        CompletableListener<StreamWriteContext> completableListener)

send Request interface

Parameters:

connection -

request - H2 请求

listener - 下行数据监听请求

completableListener - 请求发送是否成功的回调

randomConnection

public Connection randomConnection()

TODO support

Returns: