in src/main/java/com/alibaba/cloudapi/sdk/client/WebSocketApiClient.java [110:141]
protected void init(WebSocketClientBuilderParams params){
if(null == params){
throw new SdkException("WebSocketClientBuilderParams must not be null");
}
params.check();
appKey = params.getAppKey();
appSecret = params.getAppSecret();
deviceId = generateDeviceSum();
websocketUrl = Scheme.WEBSOCKET.getValue() + params.getHost();
if(port != 80){
websocketUrl = websocketUrl + ":" + port;
}
host = params.getHost();
scheme = Scheme.WEBSOCKET;
client = new OkHttpClient.Builder()
.readTimeout(params.getReadTimeout(), TimeUnit.MILLISECONDS)
.writeTimeout(params.getWriteTimeout(), TimeUnit.MILLISECONDS)
.connectTimeout(params.getConnectionTimeout(), TimeUnit.MILLISECONDS)
.build();
connectRequest = new Request.Builder().url(websocketUrl).build();
apiWebSocketListner = params.getApiWebSocketListner();
callbackManager = new CallbackManager(params.getCallbackThreadPoolCount() , params.getRequestExpiredTime());
callbackThread=new Thread(callbackManager);
callbackThread.start();
this.connect();
registerCommandSuccess.setObj(false);
errorMessage.setObj("");
instance = this;
isInit = true;
}