通过开源链路追踪客户端获取异常信息
} } } private static Map,Object>errorLogs(Throwable throwable){ Map,Object>errorLogs=new HashMap();errorLogs.put("event",Tags.ERROR.getKey());errorLogs.put("error.object",throwable);errorLogs.put("error.kind",throwable....
通过开源链路追踪客户端获取异常信息
} } } private static Map,Object>errorLogs(Throwable throwable){ Map,Object>errorLogs=new HashMap();errorLogs.put("event",Tags.ERROR.getKey());errorLogs.put("error.object",throwable);errorLogs.put("error.kind",throwable....
文件上传
本文描述上传文件到物...client即初始化获得的IStreamSender实现实例 client.disconnect(new CompletableListener(){@Override public void complete(Object o){ }@Override public void completeExceptionally(Throwable throwable){ } });
Android端接入SDK
Throwable throwable){ }@Override public void w(String s){ }@Override public void w(String s,Throwable throwable){ }@Override public void v(String s){ }@Override public void v(String s,Throwable throwable){ } });设置apk下载...
开源客户端首次连接配置
}@Override public void connectionLost(Throwable throwable){/连接断开回调，建议打印日志方便定位问题。}@Override public void messageArrived(String topic,MqttMessage mqttMessage)throws Exception {/收到消息的回调，此次不要阻塞...
常用类及其方法
CheckedFunction<Throwable,R>fallbackFunction,String resource,EntryType trafficType,int resourceType)throws Exception public static<R>R executeWithFallback(Callable<R>func,CheckedFunction<Throwable,R>fallbackFunction,String...
常用类及其方法
CheckedFunction<Throwable,R>fallbackFunction,String resource,EntryType trafficType,int resourceType)throws Exception public static<R>R executeWithFallback(Callable<R>func,CheckedFunction<Throwable,R>fallbackFunction,String...
接口说明
Callback callback=new Callback(){@Override public void onCompletion(WriteResult result,List<Record>list,Throwable throwable){ if(throwable!null){/写入失败 if(throwable instanceof LindormTSDBException){ LindormTSDBException...
基本设置相关接口
} 代码示例 public static void registerWarnLog(){ AmsLogger.addListener(new LoggerListener(){@Override public void d(String TAG,String msg,Throwable tr,int flag){ }@Override public void i(String TAG,String msg,Throwable tr,...
Android 客户端诊断
void warn(String tag,String msg,Throwable tr);void error(String tag,String msg);void error(String tag,Throwable t);void error(String tag,String msg,Throwable t);void print(String tag,String msg);void print(String tag,...
API 说明
void onException(Throwable throwable)dealDataInValid 检测升级返回的升级信息有效时被调用。void dealDataInValid(Activity activity,ClientUpgradeRes result)dealHasNoNewVersion 检测升级返回的升级信息无效时被调用。void ...
配置触发规则后的逻辑
默认配置中，可以通过 BlockException.isBlockException(Throwable t);方法判断是否为流控降级异常。若默认配置不能满足您的需求，可通过以下几种方式配置应用触发流控、降级或系统规则后的逻辑：注解方式：适用于使用自定义埋点的Spring ...
收发事务消息
public class TransProducer { static void processCommitRollError(Throwable e){ if(e instanceof AckMessageException){ AckMessageException errors=(AckMessageException)e;System.out.println("Commit/Roll transaction error,...
输出错误日志示例
public static abstract class RetryLogger {/*当RestClient发生重试前的回调函数*@param e*错误异常*@param retryCount*重试计数*@param retrySleepTime*下次需要的重试时间*/public abstract void onRetryLog(Throwable e,long ...
服务端订阅
}@Override public void onInboundMessage(JmsInboundMessageDispatch envelope){}@Override public void onSessionClosed(Session session,Throwable cause){}@Override public void onConsumerClosed(MessageConsumer consumer,Throwable...
SDK集成常见问题
public interface OnCrashCaughtListener {/*错误捕捉回调*@param thread*发生异常的Thread*@param exception*发生异常的Throwable对象*@param arg*Usertrack SDK解析以后形成的Arg对象(其中对应上传到服务端的数据)*@return null:SDK用旧...
使用 API 开启事务
GTS提供一种非Spring框架下直接使用API开启事务的方式。获取单例的全局事务操作对象 TxcTransaction...} catch(Throwable rollbackFailed){/打印回滚异常并记录xid以备数据核验 logger.error("Failed to rollback:"+xid,rollbackFailed);} } }
Java SDK 接入
} catch(Throwable throwable){ throwable.printStackTrace();} } private static CreateOpenSingleDataRequest constructSingleRequest(){ CreateOpenSingleDataRequest singleRequest=new CreateOpenSingleDataRequest();必要属性*/mPaaS...
错误编码：HSF-0029
return 对端业务响应或业务异常*@throws HSFException*如果本侧或对端HSF层出现错误，则抛出HSFException*@throws Throwable*如果服务端业务出现异常，则抛出Exception*/public Object invoke(String methodName,String[]parameterTypes,...
通过Native SDK连接并访问时序引擎
Throwable throwable=ExceptionUtils.getRootCause(ex);if(throwable instanceof LindormTSDBException){ LindormTSDBException e=(LindormTSDBException)throwable;System.out.println("Caught an LindormTSDBException,which means your ...
订阅数据示例
}@Override public void connectionLost(Throwable throwable){ throwable.printStackTrace();}@Override public void messageArrived(String s,MqttMessage mqttMessage)throws Exception {/*消费消息的回调接口，需要确保该接口不抛异常...
教程：通过Java Native SDK连接并使用Lindorm时序引擎
Throwable throwable=ExceptionUtils.getRootCause(ex);if(throwable instanceof LindormTSDBException){ LindormTSDBException e=(LindormTSDBException)throwable;System.out.println("Caught an LindormTSDBException,which means your ...
自定义 Filter
if(ret instanceof Throwable){ LOGGER.error("server biz error:{}",(Throwable)ret);}else{ LOGGER.info("echo response:{}",response.getAppResponse());} } return response;} } 自定义 Filter 类生效方式 自定义 Filter 类支持如下...
客户端连接常见问题
}@Override public void connectionLost(Throwable throwable){ throwable.printStackTrace();}@Override public void messageArrived(String s,MqttMessage mqttMessage)throws Exception {/*消费消息的回调接口，需要确保该接口不抛异常...
服务器端加密
public class Demo { public static void main(String[]args)throws Throwable {/Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。String endpoint="https://oss-cn-hangzhou.aliyuncs.com";从环境变量中获取访问凭证。运行本...
Paho-MQTT Android接入示例
mqttAndroidClient.setCallback(new MqttCallback(){@Override public void connectionLost(Throwable cause){ Log.i(TAG,"connection lost");}@Override public void messageArrived(String topic,MqttMessage message)throws Exception {...
AMQP客户端接入
}@Override public void onInboundMessage(JmsInboundMessageDispatch envelope){}@Override public void onSessionClosed(Session session,Throwable cause){}@Override public void onConsumerClosed(MessageConsumer consumer,Throwable...
收发普通消息
} } catch(Throwable e){/消息发送失败，需要进行重试处理，可重新发送这条消息或持久化这条数据进行补偿处理。System.out.println(new Date()+"Send mq message failed.Topic is:"+topic);e.printStackTrace();} mqClient.close();} } ...
请求者付费模式
} catch(Throwable ce){ System.out.println("Caught an ClientException,which means the client encountered"+"a serious internal problem while trying to communicate with OSS,"+"such as not being able to access the network.");...
资源组
public class Demo { public static void main(String[]args)throws Throwable {/Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。String endpoint="https://oss-cn-hangzhou.aliyuncs.com";从环境变量中获取访问凭证。运行本...
通过SQL连接并使用搜索引擎
} catch(Throwable e){ e.printStackTrace();} finally {/清理Statement和连接/注意：在实际环境中尽量通过连接池来避免频繁创建和释放连接，以便提升性能。try { if(stmt!null){ stmt.close();} if(pconn!null){ pconn.close();} } catch...
打印UDF日志
} private String getStackTrace(Throwable t){ StringWriter sw=new StringWriter();t.printStackTrace(new PrintWriter(sw));return sw.toString();} } 在UDF的代码中引入已创建的Logger类。以创建一个MyUdf类为例，其功能为将表中的...
图片处理
public class Demo { public static void main(String[]args)throws Throwable {/Endpoint以华东1（杭州）为例，其它Region请按实际情况填写。String endpoint="https://oss-cn-hangzhou.aliyuncs.com";从环境变量中获取访问凭证。运行本...
DataSource 埋点接入
} catch(Throwable throwable){ resultMap.put("success",false);resultMap.put("error",throwable.getMessage());} return resultMap;} } 运行工程 可以将 SOFABoot 工程导入到 IDE 中，工程编译正确后，运行工程里面中的 main 方法启动...
通过视频点播API上传媒体文件
} catch(Throwable ce){ System.out.println("Caught an ClientException,which means the client encountered"+"a serious internal problem while trying to communicate with OSS,"+"such as not being able to access the network.");...
通过OpenTelemetry接入Android Trace数据
try(Scope scope=span.makeCurrent()){/do stuff } catch(Throwable throwable){ span.setStatus(StatusCode.ERROR,"Something bad happened!span.recordException(throwable)} finally { span.end();} 传播上下文信息 OpenTelemetry...
收发顺序消息
} } catch(Throwable e){/消息发送失败，需要进行重试处理，可重新发送这条消息或持久化这条数据进行补偿处理。System.out.println(new Date()+"Send mq message failed.Topic is:"+topic);e.printStackTrace();} mqClient.close();} } ...
通过JDBC方式访问Presto
创建了包含Presto服务的集群后，如果您需要进行复杂的数据查询、分析和处理操作...} catch(Throwable t){/No-ops } } } 相关文档 如果您只是进行简单的数据查询操作，建议使用命令行的方式访问Presto，详情请参见 通过命令行方式访问Presto。
通过HTTPS协议连接ClickHouse
} catch(Throwable e){ e.printStackTrace();} } 说明 如果通过IP地址连接，连接源和 云数据库ClickHouse 集群需属于同一个VPC且 SSL Mode 取值为 none。示例如下。public void run()throws InterruptedException { final ...
收发定时消息和延时消息
} } catch(Throwable e){/消息发送失败，需要进行重试处理，可重新发送这条消息或持久化这条数据进行补偿处理。System.out.println(new Date()+"Send mq message failed.Topic is:"+topic);e.printStackTrace();} mqClient.close();} } ...
- 产品推荐
- 这些文档可能帮助您