diff --git a/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java b/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java index b19374c..52c525f 100644 --- a/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java +++ b/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java @@ -6,6 +6,8 @@ import lombok.Data; import org.springframework.web.reactive.socket.WebSocketMessage; import org.springframework.web.reactive.socket.WebSocketSession; import reactor.core.publisher.FluxSink; + +import java.util.Collections; import java.util.List; import java.util.ArrayList; @@ -82,6 +84,7 @@ public class BaseSession { /** * 临时记录发送给客户端resp + * 语音合成时使用 */ - List respList = new ArrayList<>(10); + List respList = Collections.synchronizedList(new ArrayList<>(10)); }