测试中想要多次获得onMessage(String message) 的message信息

admin

要在测试中捕获多次 onMessage 调用，需要修改回调处理机制。以下是几种解决方案：
方案一：修改回调接口以收集所有消息

1. // 修改 RecognitionCallback 接口
   
2. interface RecognitionCallback {
   
3.     void onGettingMsg(String result);
   
4.     void onError(String error);
   
5.     void onMessageReceived(String message); // 新增方法用于捕获所有消息
   
6. }
   
7. 
   
8. // 修改 MyRecognitionCallback 实现
   
9. class MyRecognitionCallback implements RecognitionCallback {
   
10.     private static final String tag = "AudioSocketCallback";
    
11.     private List<String> receivedMessages = new ArrayList<>(); // 存储所有接收到的消息
    
12. 
    
13.     @Override
    
14.     public void onGettingMsg(String result) {
    
15.         Log.d(tag, "Recognition result: " + result);
    
16.     }
    
17. 
    
18.     @Override
    
19.     public void onError(String error) {
    
20.         Log.e(tag, "Recognition error: " + error);
    
21.     }
    
22.    
    
23.     @Override
    
24.     public void onMessageReceived(String message) {
    
25.         receivedMessages.add(message);
    
26.         Log.d(tag, "Message received: " + message);
    
27.     }
    
28.    
    
29.     public List<String> getReceivedMessages() {
    
30.         return receivedMessages;
    
31.     }
    
32. }
    

复制代码

二：在 AudioSocketClient 中修改 onMessage 方法

1. @Override
   
2. public void onMessage(String message) {
   
3.     Log.i(tag, "Received message: " + message);
   
4.    
   
5.     // 通知回调所有接收到的消息
   
6.     if (mCallBack != null) {
   
7.         // 如果回调实现了新方法，则调用
   
8.         try {
   
9.             RecognitionCallback callback = (RecognitionCallback) mCallBack;
   
10.             callback.onMessageReceived(message);
    
11.         } catch (Exception e) {
    
12.             // 忽略，保持原有逻辑
    
13.         }
    
14.     }
    
15.    
    
16.     // 检查是否为EOF回执
    
17.     if (message.contains("eof") || message.contains("result")) {
    
18.         if (mCallBack != null) {
    
19.             mCallBack.onGettingMsg(message);
    
20.         }
    
21.     } else {
    
22.         // 处理其他消息
    
23.         if (message.contains("text") || message.contains("partial")){
    
24.             if (mCallBack != null) {
    
25.                 mCallBack.onGettingMsg(message);
    
26.             }
    
27.         }
    
28.     }
    
29. }
    

复制代码

方案三：在测试中直接设置回调处理

1. // 在测试代码中
   
2. List<String> receivedMessages = new ArrayList<>();
   
3. CountDownLatch messageLatch = new CountDownLatch(1);
   
4. 
   
5. client.setRecognitionCallback(new MyRecognitionCallback() {
   
6.     @Override
   
7.     public void onGettingMsg(String result) {
   
8.         super.onGettingMsg(result);
   
9.         receivedMessages.add(result);
   
10.         // 如果收到期望的结果，计数器减1
    
11.         if (result.contains("nine oh two one oh")) {
    
12.             messageLatch.countDown();
    
13.         }
    
14.     }
    
15.    
    
16.     @Override
    
17.     public void onError(String error) {
    
18.         super.onError(error);
    
19.         Log.e("Test", "Error: " + error);
    
20.     }
    
21. });
    
22. 
    
23. client.connect();
    
24. // 等待特定消息或超时
    
25. messageLatch.await(60, TimeUnit.SECONDS);
    
26. // 检查收集到的所有消息
    
27. Log.e("Test", "All received messages: " + receivedMessages);
    

复制代码

推荐使用方案三，因为它不需要修改现有代码结构，只需要在测试中自定义回调处理逻辑即可。