Android: проблема класса AudioRecord: обратный вызов никогда не вызывается

Я считаю, что проблема в том, что вам все еще нужно выполнить цикл чтения. Если вы настроите обратные вызовы, они сработают, когда вы прочитаете количество кадров, указанное для обратных вызовов. Но читать все равно нужно. Я пробовал это, и обратные вызовы вызываются просто отлично. Установка маркера вызывает обратный вызов, когда с начала записи было считано это количество кадров. Другими словами, вы можете установить маркер далеко в будущее, после многих ваших прочтений, и тогда он сработает. Вы можете установить период на большее количество кадров, и этот обратный вызов будет срабатывать каждый раз, когда будет прочитано это количество кадров. Я думаю, что они делают это, чтобы вы могли выполнять низкоуровневую обработку необработанных данных в тесном цикле, а затем время от времени ваш обратный вызов может выполнять обработку сводного уровня. Вы можете использовать маркер, чтобы было проще решить, когда остановить запись (вместо подсчета в цикле чтения).

Вот мой код, используемый для поиска среднего шума. Обратите внимание, что он основан на уведомлениях прослушивателя, поэтому он экономит заряд батареи устройства. Это определенно основано на примерах выше. Этот пример сэкономил мне много времени, спасибо.

private AudioRecord recorder;
private boolean recorderStarted;
private Thread recordingThread;
private int bufferSize = 800;
private short[][] buffers = new short[256][bufferSize];
private int[] averages = new int[256];
private int lastBuffer = 0;

protected void startListenToMicrophone() {
    if (!recorderStarted) {

        recordingThread = new Thread() {
            @Override
            public void run() {
                int minBufferSize = AudioRecord.getMinBufferSize(8000, AudioFormat.CHANNEL_CONFIGURATION_MONO,
                        AudioFormat.ENCODING_PCM_16BIT);
                recorder = new AudioRecord(AudioSource.MIC, 8000, AudioFormat.CHANNEL_CONFIGURATION_MONO,
                        AudioFormat.ENCODING_PCM_16BIT, minBufferSize * 10);
                recorder.setPositionNotificationPeriod(bufferSize);
                recorder.setRecordPositionUpdateListener(new OnRecordPositionUpdateListener() {
                    @Override
                    public void onPeriodicNotification(AudioRecord recorder) {
                        short[] buffer = buffers[++lastBuffer % buffers.length];
                        recorder.read(buffer, 0, bufferSize);
                        long sum = 0;
                        for (int i = 0; i < bufferSize; ++i) {
                            sum += Math.abs(buffer[i]);
                        }
                        averages[lastBuffer % buffers.length] = (int) (sum / bufferSize);
                        lastBuffer = lastBuffer % buffers.length;
                    }

                    @Override
                    public void onMarkerReached(AudioRecord recorder) {
                    }
                });
                recorder.startRecording();
                short[] buffer = buffers[lastBuffer % buffers.length];
                recorder.read(buffer, 0, bufferSize);
                while (true) {
                    if (isInterrupted()) {
                        recorder.stop();
                        recorder.release();
                        break;
                    }
                }
            }
        };
        recordingThread.start();

        recorderStarted = true;
    }
}

private void stopListenToMicrophone() {
    if (recorderStarted) {
        if (recordingThread != null && recordingThread.isAlive() && !recordingThread.isInterrupted()) {
            recordingThread.interrupt();
        }
        recorderStarted = false;
    }
}

Теперь я реализовал запись с помощью «OnRecordPositionUpdateListener». Это выглядит очень многообещающе, и это правильный способ сделать это в соответствии с SDK Docs. Кажется, все работает (открытие аудиоустройства, чтение () данных и т. д.), но Listner никогда не вызывается.

Кто-нибудь знает, почему?

Я обнаружил, что OnRecordPositionUpdateListener игнорируется до тех пор, пока вы не сделаете свой первый .read().

Другими словами, я обнаружил, что если я настроил все в соответствии с документами, мой Listener никогда не вызывался. Однако, если бы я сначала вызывал .read() сразу после выполнения моего первоначального .start(), то прослушиватель вызывался бы - при условии, что я делал .read() каждый раз, когда вызывался слушатель.

Другими словами, похоже, что событие Listener подходит только один раз за .read() или что-то в этом роде.

Я также обнаружил, что если я запрошу для чтения любые сэмплы меньше, чем buffSize/2, слушатель не будет вызван. Таким образом, кажется, что слушатель вызывается только ПОСЛЕ .read() по крайней мере половины размера буфера. Чтобы продолжать использовать обратный вызов прослушивателя, необходимо вызывать read каждый раз при запуске прослушивателя. (Другими словами, поместите вызов read в код прослушивателя.)

Однако прослушиватель, похоже, вызывается в то время, когда данные еще не готовы, что приводит к блокировке.

Кроме того, если ваш период или время уведомления больше половины вашего bufferSize, похоже, они никогда не будут вызваны.

ОБНОВИТЬ:

По мере того, как я продолжаю копать глубже, я обнаружил, что обратный вызов, кажется, вызывается ТОЛЬКО, когда заканчивается .read() ......!

Не знаю, баг это или фича. Моя первоначальная мысль заключалась в том, что я хочу получить обратный вызов, когда придет время читать. Но, возможно, у разработчиков Android была идея наоборот, где вы просто поместите while(1){xxxx.read(...)} в поток отдельно, и чтобы избавить вас от необходимости отслеживать каждый раз, когда read() завершено, обратный вызов может по существу сказать вам когда чтение закончилось.

Ой. Может, меня просто осенило. И я думаю, что другие указывали на это до меня здесь, но это не дошло: обратный вызов позиции или точки должен работать с байтами, которые уже были прочитаны...

Я думаю, может быть, я застрял с использованием потоков.

В этом стиле можно было бы иметь поток, непрерывно вызывающий read(), как только он возвращается, поскольку чтение блокируется и терпеливо ждет возврата достаточного количества данных.

Затем, независимо, обратный вызов будет вызывать указанную вами функцию через каждые x отсчетов.

Для тех, кто записывает аудио через службу Intent, они также могут столкнуться с этой проблемой обратного вызова. В последнее время я работал над этой проблемой и придумал простое решение, в котором вы вызываете свой метод записи в отдельном потоке. Это должно вызывать метод onPeriodicNotification во время записи без каких-либо проблем.

Что-то вроде этого:

public class TalkService extends IntentService {
...
@Override
protected void onHandleIntent(Intent intent) {
Context context = getApplicationContext();
tRecord = new Thread(new recordAudio());
tRecord.start();
...
while (tRecord.isAlive()) {
    if (getIsDone()) {
        if (aRecorder.getRecordingState() == AudioRecord.RECORDSTATE_STOPPED) {
            socketConnection(context, host, port);
        }
    }
} }
...
class recordAudio implements Runnable {

        public void run() {
            try {
                OutputStream osFile = new FileOutputStream(file);
                BufferedOutputStream bosFile = new BufferedOutputStream(osFile);
                DataOutputStream dosFile = new DataOutputStream(bosFile);

                aRecorder = new AudioRecord(MediaRecorder.AudioSource.MIC,
                        sampleRate, channelInMode, encodingMode, bufferSize);

                data = new short[bufferSize];

                aRecorder.setPositionNotificationPeriod(sampleRate);
                aRecorder
                        .setRecordPositionUpdateListener(new AudioRecord.OnRecordPositionUpdateListener() {
                            int count = 1;

                            @Override
                            public void onPeriodicNotification(
                                    AudioRecord recorder) {
                                Log.e(WiFiDirect.TAG, "Period notf: " + count++);

                                if (getRecording() == false) {
                                    aRecorder.stop();
                                    aRecorder.release();
                                    setIsDone(true);
                                    Log.d(WiFiDirect.TAG,
                                            "Recorder stopped and released prematurely");
                                }
                            }

                            @Override
                            public void onMarkerReached(AudioRecord recorder) {
                                // TODO Auto-generated method stub

                            }
                        });

                aRecorder.startRecording();
                Log.d(WiFiDirect.TAG, "start Recording");
                aRecorder.read(data, 0, bufferSize);
                for (int i = 0; i < data.length; i++) {
                    dosFile.writeShort(data[i]);
                }

                if (aRecorder.getRecordingState() == AudioRecord.RECORDSTATE_RECORDING) {
                    aRecorder.stop();
                    aRecorder.release();
                    setIsDone(true);
                    Log.d(WiFiDirect.TAG, "Recorder stopped and released");
                }

            } catch (Exception e) {
                // TODO: handle exception
            }
        }
    }