nepxion / discoveryagent Goto Github PK

ThreadPlugin中调用了所有ThreadLocalHook接口(需注册)中的create、before等方法, ThreadLocalHook的注册是在插件(比如DiscoveryServicePlugin)匹配到并执行对应的TransformCallback的doInTransform方法.
当项目启动时发起的第一个灰度请求是异步时

此时Task构造器先被增强,然而因为Task构造时RestStrategyContext尚未加载, 所以DiscoveryServicePlugin对应的ThreadLocalHook还未注册,Object[] objects = ThreadLocalCopier.create(), 此行代码objects结果为空, 灰度结果会异常.
然后随着灰度代码的执行, 会加载到RestStrategyContext, 然后会执行DiscoveryServicePlugin的TransformCallback的doInTransform方法, 对应的ThreadLocalHook将被注册.
下次异步调用时灰度结果正常.

目前测对Runnable可以支持，head不会丢。对需要获取返回值的情况，请问怎么处理，或者换种写法？目前使用CompletableFuture.supplyAsync(new Supplier<>())

代码地址：com/nepxion/discovery/agent/plugin/thread/ThreadPlugin.java:55 会出现问题

List<String> basePackages = StringUtil.tokenizeToStringList(baseThreadScanPackages, ThreadConstant.THREAD_SCAN_PACKAGES_DELIMITERS); List<String> customPackages = StringUtil.tokenizeToStringList(threadScanPackages, ThreadConstant.THREAD_SCAN_PACKAGES_DELIMITERS); basePackages.addAll(customPackages);
若是basePackages为emptyList，则后面的不能再用emptyList添加东西了 basePackages.addAll(customPackages);

这行可能是一个失误吧，建议删除这行代码。

我见之前alibaba也有一个类似功能的库：https://github.com/alibaba/transmittable-thread-local
这两个主要差异点可以解答下吗（仅限当前项目，不是整个nepxion平台）？

rt