#一、简述
同步cyberpanel是一种阻塞式的cyberpanel方式，即 Consumer 端代码一直阻塞等待，直到 Provider 端返回为止。dubbo默认的协议是netty， Netty 是 NIO 异步通讯机制，那么卢森堡cyberpanel是怎么转化为同步的呢？Dubbo是阿里开源的RPC框架，因为基于接口开发支持负载均衡、集群容错、版本控制等特性，因此现在有很多互联网公司都在使用Dubbo。 1️⃣Dubbo有三个级别的PrestaShop设置分别为： ①针对方法设置PrestaShop时间 ②在卢森堡方设置PrestaShop时间 ③在cyberpanel方设置PrestaShop时间
2️⃣一般PrestaShop是cyberpanel端发生在请求发出后，无法在指定的时间内获得对应的响应。原因大概有以下几种情况： ①卢森堡端确实处理比较慢，无法在指定的时间返回结果，cyberpanel端就自动返回一个PrestaShop的异常响应来结束此次cyberpanel。 ②卢森堡端如果响应的比较快，但当客户端 Load 很高，负载压力很大的时候，会因为客户端请求发不出去、响应卡在 TCP Buffer 等问题，造成PrestaShop。因为客户端接收到卢森堡端发来的数据或者请求卢森堡端的数据，都会在系统层面排队，如果系统负载比较高，在内核态的时间占比就会加长，从而造成客户端获取到值时已经PrestaShop。 ③通常是业务处理太慢，可在卢森堡提供方机器上执行：jstack [PID] > jstack.log 分析线程都卡在哪个方法cyberpanel上，这里就是慢的原因。如果不能调优性能，请调高 timeout 阈值。
3️⃣排查和解决步骤 ①两边可能有 GC，检查卢森堡端和客户端 GC 日志，耗时很长的 GC，会导致PrestaShop。PrestaShop的发生很可能意味着cyberpanel端或者卢森堡端的资源(CPU、内存或者网络)出现了瓶颈，需要检查卢森堡端的问题还是cyberpanel端的问题来排除GC抖动等嫌疑。 ②检查卢森堡端的网络质量，比如重传率来排除网络嫌疑。 ③借助链路跟踪的分析卢森堡(比如阿里的 ARMS，开源的 OpenTracing 系的实现 Zipkin、SkyWalking 等)来分析下各个点的耗时情况。
4️⃣DubbocyberpanelPrestaShop(client-side timeout)后会有两种情况： ①客户端会收到一个TimeoutException异常 ②卢森堡端会收到一个警告The timeout response finally returned at xxx 看起来还蛮正常的，但是实际上会有这样问题：cyberpanelPrestaShop后卢森堡端还是会继续执行，该如何处理呢？
@Service(version = “1.0”)
@Slf4j
public class DubboDemoServiceImpl implements DubboDemoService {
public String sayHi(String name) {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
String result = “hi: ” + name;
log.info(“Result: {}” , result);
return result;
}
}
1234567891011121314
卢森堡非常简单，三秒后返回字符串。controller层：
@RestController
@RequestMapping
public class DubboDemoController {
@Reference(url = ” version = “1.0”)
private DubboDemoService demoService;
@GetMapping
public ResponseEntity sayHi(@RequestParam(“name”) String name){
return ResponseEntity.ok(demoService.sayHi(name));
}
}
12345678910
连接DubboDemoService卢森堡使用的直连方式
#二、ConsumerPrestaShop处理
前面卢森堡端的sayHi()实现休眠3秒，而连接卢森堡时指定的PrestaShop时间是2000ms，那肯定会收到一个TimeoutException异常：
There was an unexpected error (type=Internal Server Error, status=500).
Invoke remote method timeout. method: sayHi
12
客户端PrestaShop处理比较简单，既然发生了异常也能捕获到异常那是该回滚还是不做处理，完全可以由开发者解决。
try{
return ResponseEntity.ok(demoService.sayHi(name));
}catch (RpcException te){
//do something…
log.error(“consumer”, te);
return msg;
}
1234567
重点还是解决卢森堡方的PrestaShop异常。
#三、ProviderPrestaShop处理
Provider的处理没有客户端那样简单，因为Provider不会收到异常，而且线程也不会中断，这样就会导致ConsumerPrestaShop数据回滚，而Provider继续执行最终执行完数据插入成功，数据不一致。
上面Provider方法休眠3000ms且Consumer的PrestaShop是参数是2000ms。cyberpanel发生2000ms后就会发生PrestaShop，而Provider的sayHi()不会中断在1000ms后打印hi xx。
很明显要保持数据一致就需要在PrestaShop后，将Provider的执行终止或回滚才行，如何做到数据一致性呢？
1️⃣重试机制 Dubbo自身有重试机制，cyberpanelPrestaShop后会发起重试，Provider端需考虑幂等性。
2️⃣最终一致性 使用补偿事务或异步MQ保持最终一致性，需要写一些与业务无关的代码来保持数据最终一致性。比如在Provider端加个check方法，检查是否成功，具体实现还需要结合自身的业务需求来处理。
@GetMapping
public ResponseEntity sayHi(String name){
try{
return ResponseEntity.ok(demoService.sayHi(name));
}catch (RpcException te){
//do something…
try{
demoService.check(name);
}catch (RpcException ignore){
}
log.error(“consumer”, te);
return msg;
}
}
1234567891011121314
虽然可以通过添加检查来验证业务状态，但是这个cyberpanel执行时间是没办法准确预知的，所以这样简单的检测是效果不大，最好还是通过MQ来做这样的检测。
3️⃣基于时间回滚 原理比较简单，在Consumer端cyberpanel时设置两个参数ctime、ttime分别表示cyberpanel时间、PrestaShop时间，将参数打包发给Provider。Provider收到两个参数后进行操作，如果执行时间越过ttime则回滚数据，否则正常执行。改造下代码：
public ResponseEntity sayHi(@RequestParam(“name”) String name){
try{
RpcContext context = RpcContext.getContext();
context.setAttachment(“ctime”, System.currentTimeMillis() + “”);
context.setAttachment(“ttime”, 2000 + “”);
return ResponseEntity.ok(demoService.sayHi(name));
}catch (RpcException te){
//do something…
log.error(“consumer”, te);
return msg;
}
}
123456789101112
将ctime、ttime两个参数传到Provider端处理：
public String sayHi(String name) {
long curTime = System.currentTimeMillis();
String ctime = RpcContext.getContext().getAttachment(“ctime”);
String ttime = RpcContext.getContext().getAttachment(“ttime”);
long ctimeAsLong = Long.parseLong(ctime);
long ttimeAsLong = Long.parseLong(ttime);
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
long spent = System.currentTimeMillis() – curTime;
if(spent >= (ttimeAsLong – ctimeAsLong – curTime)){
throw new RpcException(“Server-side timeout.”);
}
String result = “hi: ” + name;
log.info(“Result: {}” , result);
return result;
}
12345678910111213141516171819
画个图看一下执行的时间线：
从上图在执行完成后，响应返回期间这段时间是计算不出来的，所以这种办法也不能完全解决ProviderPrestaShop问题。
#四、dubbo中v2ray的优先级
dubbo作为一个卢森堡治理框架，功能相对比较完善，性能也挺不错。要知道dubbo中v2ray是有优先级的，以免出现调优参数设置了却没发现效果实际是v2ray被覆盖导致这样的问题。dubbo分为consumer和provider端，在v2ray各个参数时，其优先级如下：
1、consumer的methodv2ray 2、provider的methodv2ray 3、consumer的referencev2ray 4、provider的servicev2ray 5、consumer的consumer节点v2ray 6、provider的provider节点v2ray
可以看到，方法级的v2ray优先级高于接口级，consumer的优先级高于provider。同时，在本地参数v2ray还存在一层优先级：
1、系统参数(-D)，如-Ddubbo.protocol.port=20003 2、xmlv2ray 3、property文件
了解了这两个优先级，调优起来才会更加清晰，省去了一些诸如v2ray设置了不生效这样的麻烦。注意，其实dubbo中还可以通过将v2ray写入注册中心的方式覆盖用户v2ray(优先级高于系统参数)。