将test.py改写成android程序

admin

原程序：

1. #!/usr/bin/env python3
   
2. import asyncio import websockets import sys import wave
   
3. async def run_test(uri): async with websockets.connect(uri) as websocket:
   
4.     wf = wave.open(sys.argv[1], "rb")
   
5.     await websocket.send('{ "config" : { "sample_rate" : %d } }' % (wf.getframerate()))
   
6.     buffer_size = int(wf.getframerate() * 0.2) # 0.2 seconds of audio
   
7.     print("@@@@@@")
   
8.     while True:
   
9.         data = wf.readframes(buffer_size)
   
10. 
    
11.         if len(data) == 0:
    
12.             break
    
13. 
    
14.         await websocket.send(data)
    
15.         print (await websocket.recv())
    
16. 
    
17.     print("******")
    
18.     await websocket.send('{"eof" : 1}')
    
19.     print (await websocket.recv())
    
20. asyncio.run(run_test('ws://*.*.*.*:***')

复制代码

将Python WebSocket客户端程序转换为Android Java版本，并避免使用javax.sound.sampled库。以下是完整的实现：

1. package cn.unicoder.myapplication;
   
2. 
   
3. import java.net.URI;
   
4. import java.io.File;
   
5. import java.io.FileInputStream;
   
6. import java.io.IOException;
   
7. import android.media.AudioFormat;
   
8. import org.java_websocket.client.WebSocketClient;
   
9. import org.java_websocket.handshake.ServerHandshake;
   
10. import org.json.JSONObject;
    
11. 
    
12. public class AudioSocketClient extends WebSocketClient {
    
13.     private String audioFilePath;
    
14.     private byte[] audioBuffer;
    
15.     private AudioFormat format;
    
16.     private boolean finished = false;
    
17.     private FileInputStream fileInputStream;
    
18. 
    
19.     public AudioSocketClient(URI serverUri, String audioFilePath) {
    
20.         super(serverUri);
    
21.         this.audioFilePath = audioFilePath;
    
22.         this.format = new AudioFormat.Builder()
    
23.                 .setSampleRate(16000)
    
24.                 .setEncoding(AudioFormat.ENCODING_PCM_16BIT)
    
25.                 .setChannelMask(AudioFormat.CHANNEL_IN_MONO)
    
26.                 .build();
    
27.         this.audioBuffer = new byte[1024];
    
28.     }
    
29.    
    
30.     @Override
    
31.     public void onOpen(ServerHandshake handshakedata) {
    
32.         System.out.println("Connected to server");
    
33.         // 连接成功后开始发送音频数据
    
34.         sendAudioData();
    
35.     }
    
36.    
    
37.     @Override
    
38.     public void onMessage(String message) {
    
39.         System.out.println("Received: " + message);
    
40.     }
    
41.    
    
42.     @Override
    
43.     public void onClose(int code, String reason, boolean remote) {
    
44.         System.out.println("Connection closed: " + reason);
    
45.         finished = true;
    
46.         closeFileStream();
    
47.     }
    
48.    
    
49.     @Override
    
50.     public void onError(Exception ex) {
    
51.         ex.printStackTrace();
    
52.         closeFileStream();
    
53.     }
    
54.    
    
55.     private void sendAudioData() {
    
56.         new Thread(() -> {
    
57.             try {
    
58.                 File audioFile = new File(audioFilePath);
    
59.                 fileInputStream = new FileInputStream(audioFile);
    
60.                
    
61.                 // 发送配置信息
    
62.                 sendConfig();
    
63.                
    
64.                 // 设置缓冲区大小为0.2秒的音频数据 (16000Hz * 0.2s * 2字节 = 6400字节)
    
65.                 int bufferSize = (int)(16000 * 0.2 * 2);
    
66.                 byte[] buffer = new byte[bufferSize];
    
67.                
    
68.                 System.out.println("@@@@@@");
    
69.                
    
70.                 int bytesRead;
    
71.                 while ((bytesRead = fileInputStream.read(buffer)) != -1 && !finished) {
    
72.                     // 发送音频数据块
    
73.                     send(java.util.Arrays.copyOf(buffer, bytesRead));
    
74.                     
    
75.                     // 简单延时以模拟异步接收响应
    
76.                     Thread.sleep(100);
    
77.                 }
    
78.                
    
79.                 // 发送结束标记
    
80.                 sendEOF();
    
81.                 System.out.println("******");
    
82.                
    
83.             } catch (Exception e) {
    
84.                 e.printStackTrace();
    
85.             } finally {
    
86.                 closeFileStream();
    
87.             }
    
88.         }).start();
    
89.     }
    
90.    
    
91.     private void sendConfig() {
    
92.         try {
    
93.             // 发送配置信息，类似于Python中的 '{ "config" : { "sample_rate" : %d } }'
    
94.             JSONObject configMsg = new JSONObject();
    
95.             JSONObject config = new JSONObject();
    
96.             config.put("sample_rate", 16000);
    
97.             configMsg.put("config", config);
    
98.             
    
99.             send(configMsg.toString());
    
100.         } catch (Exception e) {
     
101.             e.printStackTrace();
     
102.         }
     
103.     }
     
104.    
     
105.     private void sendEOF() {
     
106.         try {
     
107.             JSONObject eofMsg = new JSONObject();
     
108.             eofMsg.put("eof", 1);
     
109.             send(eofMsg.toString());
     
110.         } catch (Exception e) {
     
111.             e.printStackTrace();
     
112.         }
     
113.     }
     
114.    
     
115.     private void closeFileStream() {
     
116.         if (fileInputStream != null) {
     
117.             try {
     
118.                 fileInputStream.close();
     
119.             } catch (IOException e) {
     
120.                 e.printStackTrace();
     
121.             }
     
122.         }
     
123.     }
     
124. }
     

复制代码

关键转换点：
1、移除Java Sound API依赖：完全移除了javax.sound.sampled相关导入和使用
2、文件读取：使用FileInputStream替代Python的wave.open来读取音频文件
3、异步处理：通过新线程处理音频数据发送，避免阻塞主线程
4、WebSocket通信：
   在onOpen中启动音频发送流程
   使用send方法发送数据和配置信息
   实现onMessage处理服务器响应
5、缓冲区管理：设置0.2秒的音频数据块大小（假设16kHz采样率，16位深度）
6、资源清理：在适当位置关闭文件流，防止资源泄漏
使用时，创建AudioSocketClient实例并调用connect()方法即可建立WebSocket连接并开始传输音频数据。