--no commit message

app/resource/src/main/java/com/zrqx/resource/commons/util/WebTTSWSUtil.java

@@ -44,7 +44,7 @@ public class WebTTSWSUtil {
     private static final String apiKey = "793094b3d3f8dd4c4f57193499d6cc5a";//到控制台-语音合成页面获取
     public static final Gson json = new Gson();
 	private static final Logger logger = LoggerFactory.getLogger(WebTTSWSUtil.class);
-    public static String textToAudio(String text,String filePath,String fileName) throws Exception {
+    public static synchronized String textToAudio(String text,String filePath,String fileName) throws Exception {
         // 构建鉴权url
         String authUrl = getAuthUrl(hostUrl, apiKey, apiSecret);
         OkHttpClient client = new OkHttpClient.Builder().build();
@@ -65,7 +65,7 @@ public class WebTTSWSUtil {
         FileOutputStream os = new FileOutputStream(f);
         WebSocket webSocket = client.newWebSocket(request, new WebSocketListener() {
             @Override
-            public void onOpen(WebSocket webSocket, Response response) {
+            public synchronized void onOpen(WebSocket webSocket, Response response) {
                 super.onOpen(webSocket, response);
                 try {
                     System.out.println(response.body().string());
@@ -104,7 +104,7 @@ public class WebTTSWSUtil {
                 webSocket.send(frame.toString());
             }
             @Override
-            public void onMessage(WebSocket webSocket, String text) {
+            public synchronized void onMessage(WebSocket webSocket, String text) {
                 super.onMessage(webSocket, text);
                 //处理返回数据
                 logger.error("receive=>" + text);
@@ -144,21 +144,21 @@ public class WebTTSWSUtil {
                 }
             }
             @Override
-            public void onMessage(WebSocket webSocket, ByteString bytes) {
+            public synchronized void onMessage(WebSocket webSocket, ByteString bytes) {
                 super.onMessage(webSocket, bytes);
             }
             @Override
-            public void onClosing(WebSocket webSocket, int code, String reason) {
+            public synchronized void onClosing(WebSocket webSocket, int code, String reason) {
                 super.onClosing(webSocket, code, reason);
                 System.out.println("socket closing");
             }
             @Override
-            public void onClosed(WebSocket webSocket, int code, String reason) {
+            public synchronized void onClosed(WebSocket webSocket, int code, String reason) {
                 super.onClosed(webSocket, code, reason);
                 System.out.println("socket closed");
             }
             @Override
-            public void onFailure(WebSocket webSocket, Throwable t, Response response) {
+            public synchronized void onFailure(WebSocket webSocket, Throwable t, Response response) {
                 super.onFailure(webSocket, t, response);
                 System.out.println("connection failed");
             }