我正在为TCP服务器使用SpringIntegration，它与几千个客户端保持连接。我需要服务器在负载过大的情况下限制客户端并且不丢失消息。我的服务器配置:由于连接工厂的默认任务执行器是无限的，我使用池化任务执行器来防止内存不足错误。用于负载测试的简单客户端:publicclassTCPClientTest{staticSocketsocket;staticListsl=newArrayList();staticDataOutputStreamout;publicstaticvoidmain(String[]args)throwsException{for(inti=0;i当我运行它