HystrixTimer 中的 ThreadLocal 污染导致指标归因错误,原因是线程重用不安全

我在com.netflix.hystrix.util中发现了一个地方污染问题。 HystrixTimer. (原始内容存档于2018-09-29).

HystrixTimer 使用 SextThreadPoolExecutor来再利用线程执行定时器任务. 然而,它缺乏一个在任务执行后清理 Thread Local环境的机制. 关键的是,用于TimerListener.tick ()的Javadoc明确鼓励用户在方法(190-192线)内设置线程本地化(Thread Locals),但运行(Line 96-106线)的执行并不能保证这些被清除,特别是如果出现例外或用户忘记了最后的块.

源代码位置 : // HystrixTimer.java (英语).

// 1. 误导贾瓦多克(190-192号线): /"如果你需要 Thread local set,你可以将状态存储在 Timer Listener, / 然后当勾选( ) 被调用时, 将线程本地设置为您想要的值 。"

//2. 不安全处决(96-106行): 可运行 r = 新可运行 { @ 覆盖 公有无效跑 () { 尝试{ listener.tick () (); (中文(简体) ). 捕获(例外e){ logger.error ("在勾选计时器时失败", e); {\fn黑体\fs22\bord1\shad0\3aHBE\4aH00\fscx67\fscy66\2cHFFFFFF\3cH808080}你觉得呢? // 误入: 最后屏蔽以清除/重置线程本地人或 Hystrix RequestContext {\fn黑体\fs22\bord1\shad0\3aHBE\4aH00\fscx67\fscy66\2cHFFFFFF\3cH808080}你觉得呢?

• ;

影响

1. Metric Deviation:如果Histrix RequestContent Context在同一线索上从先前的一次执行中漏出,则延迟和超时的度量衡可能记录在错误的CommandKey或CommandGroup下.

2.上下文污染:由定时器线程所执行的下游逻辑可能继承了过时的用户上下文(例如用户ID,Trace ID).

预期行为 Hystrix Timer应:

1. 对行刑前/行刑后线状状态进行无害化.

2. 或者至少Javadoc应该严格地警告用户,由于线程被再用,所以尝试最后的清理是强制性的.

实际行为 HystrixTimer 池中的线程保留了先前勾选执行的线程本地值,导致不同Hystrix命令之间的"交叉交谈".

建议的修复 更新 Runnable 包装器以确保清理, 或更新文档以警告线条集合风险 。

代码修复示例 : 可运行 r = 新可运行 { @ 覆盖 公有无效跑 () { 尝试{ listener.tick () (); (中文(简体) ). 捕获(例外e){ logger.error (...) (中文(简体) ). 终于 // 理想: Hystrix RequestContext.get Context ForCurrentThread (. shutdown (); ; ; ; / 请检查url=值 (帮助). 或明确提醒用户清理. {\fn黑体\fs22\bord1\shad0\3aHBE\4aH00\fscx67\fscy66\2cHFFFFFF\3cH808080}你觉得呢? {\fn黑体\fs22\bord1\shad0\3aHBE\4aH00\fscx67\fscy66\2cHFFFFFF\3cH808080}你觉得呢?

• ;