多线程日志场景下StringBuffer无法存储完整数据求助

核心问题分析 #

你的代码存在致命问题：静态ThreadLocal变量被多线程重复初始化覆盖。

看Messages类的实现细节：

• static ThreadLocal<StringBuffer> msg是静态类变量，所有线程共享这个变量引用。
• 每个线程调用Messages.init()时，都会创建新的ThreadLocal实例并赋值给msg。这就会出现线程A刚初始化完ThreadLocal，线程B调用init时直接把msg替换成自己创建的实例，后续线程A调用addMsg时，实际操作的是线程B创建的ThreadLocal里的StringBuffer，线程A自己的初始缓冲区彻底丢失，最终表现为日志条目缺失。

你尝试的StringBuilder替换、给addMsg加锁都无效，因为问题根本不是append操作的线程安全（ThreadLocal本身就保证每个线程持有独立实例，append不需要锁），而是ThreadLocal实例本身被多线程覆盖了。

修复方案 #

1. 修正ThreadLocal的初始化方式 #

把ThreadLocal的初始化改为静态初始化块，确保它只被初始化一次，不会被多线程重复覆盖：

public abstract class Messages {

    // 静态初始化ThreadLocal，整个类生命周期只初始化一次
    private static final ThreadLocal<StringBuffer> msg = new ThreadLocal<StringBuffer>() {
        @Override
        protected StringBuffer initialValue() {
            return new StringBuffer();
        }
    };

    // 移除原来的init方法，避免误调用覆盖ThreadLocal
    // 如果需要重置当前线程的日志缓冲区，新增reset方法
    public static void reset() {
        msg.set(new StringBuffer());
    }

    public static void addMsg(String content) {
        // 原代码参数名msg和静态变量重名，容易混淆，改为content
        msg.get().append(content + "\n");
        System.out.println(content);
    }

    // 新增获取完整日志的方法，用于同步到Kibana
    public static String getFullLog() {
        return msg.get().toString();
    }
}

2. 修改调用逻辑 #

在CallingClass中，不需要再调用Messages.init()，如果每次测试用例执行前需要清空日志缓冲区，调用reset()即可：

public class CallingClass {
    public void callingMethod(String threadName){
       Messages.reset(); // 每次测试前重置当前线程的日志缓冲区
       Messages.addMsg("Hi");
       Messages.addMsg("This");
       Messages.addMsg("Is");
       Messages.addMsg("Testing");
       Messages.addMsg("For");
       Messages.addMsg("Multi");
       Messages.addMsg("Thread");
       Messages.addMsg("UI");
       Messages.addMsg(threadName + "!!");
       
       // 获取完整日志同步到Kibana
       String fullLog = Messages.getFullLog();
       // 执行同步逻辑...
    }
}

为什么之前的尝试无效 #

• StringBuilder代替StringBuffer：ThreadLocal已经保证每个线程持有独立的缓冲区实例，append操作本身不存在线程安全问题，换StringBuilder解决不了ThreadLocal被覆盖的核心问题。
• 给addMsg加同步锁：锁只能保证append操作的原子性，但无法阻止其他线程覆盖静态ThreadLocal变量，因此对日志丢失问题无济于事。

内容的提问来源于stack exchange，提问作者Siva Sai Phalguna Kaipa