(原创)speex与wav格式音频文件的互相转换(二)

时间:2022-02-11 16:28:22

之前写过了如何将speex与wav格式的音频互相转换,如果没有看过的请看一下连接

http://www.cnblogs.com/dongweiq/p/4515186.html

虽然自己实现了相关的压缩算法,但是发现还是与gauss的压缩比例差了一些,一部分是参数设置的问题,另外一部分是没有使用ogg的问题。

本来想研究一下gauss的ogg算法,然后将他录制的音频转为wav格式,再继续进行后面的频谱绘制之类的。

在后续的研究gauss的解码过程,他是先解了ogg的格式,然后分段,然后去掉speex的头,然后把一段段的speex数据再解码成pcm的原数据,最后使用audiotrack一段段播放出来了。audiotrack播放的时候是阻塞的,所以播了多久就解了多久。

既然他得到了一段段pcm的原数据,那我就可以去将这一段段的原数据拼起来,最后得到解码完成的整个的pcm数据,最后加上wav的头不就可以直接转换成wav格式的音频了么???

前天的时候想到这里,立马就去改了。

SpeexDecoder是gauss的demo里主要的解码类,我们复制一份,改名为SpeexFileDecoder

去掉里面跟播放相关的audiotrack变量,因为我们要得到的是解码数据,跟播放无关。

修改后代码如下

  1 package com.sixin.speex;
  2 
  3 import java.io.File;
  4 import java.io.FileOutputStream;
  5 import java.io.IOException;
  6 import java.io.RandomAccessFile;
  7 import java.util.ArrayList;
  8 import java.util.List;
  9 
 10 import android.media.AudioFormat;
 11 import android.media.AudioManager;
 12 import android.media.AudioTrack;
 13 import android.os.RecoverySystem.ProgressListener;
 14 import android.util.Log;
 15 
 16 /**
 17  * 采用Jspeex方案,首先解包,从ogg里面接出来,然后使用speex decode将speex转为wav数据并进行播放
 18  * 
 19  * @author Honghe
 20  */
 21 public class SpeexFileDecoder {
 22 
 23     protected Speex speexDecoder;
 24     private String errmsg = null;
 25     private List<ProgressListener> listenerList = new ArrayList<ProgressListener>();
 26     private File srcPath;
 27     private File dstPath;
 28 
 29     public SpeexFileDecoder(File srcPath, File dstPath) throws Exception {
 30         this.srcPath = srcPath;
 31         this.dstPath = dstPath;
 32     }
 33 
 34     private void initializeAndroidAudio(int sampleRate) throws Exception {
 35         int minBufferSize = AudioTrack.getMinBufferSize(sampleRate, AudioFormat.CHANNEL_OUT_MONO, AudioFormat.ENCODING_PCM_16BIT);
 36 
 37         if (minBufferSize < 0) {
 38             throw new Exception("Failed to get minimum buffer size: " + Integer.toString(minBufferSize));
 39         }
 40     }
 41 
 42     public void addOnMetadataListener(ProgressListener l) {
 43         listenerList.add(l);
 44     }
 45 
 46     public String getErrmsg() {
 47         return errmsg;
 48     }
 49 
 50     public void decode() throws Exception {
 51         errmsg = null;
 52         byte[] header = new byte[2048];
 53         byte[] payload = new byte[65536];
 54         final int OGG_HEADERSIZE = 27;
 55         final int OGG_SEGOFFSET = 26;
 56         final String OGGID = "OggS";
 57         int segments = 0;
 58         int curseg = 0;
 59         int bodybytes = 0;
 60         int decsize = 0;
 61         int packetNo = 0;
 62         // construct a new decoder
 63         speexDecoder = new Speex();
 64         speexDecoder.init();
 65         // open the input stream
 66         RandomAccessFile dis = new RandomAccessFile(srcPath, "r");
 67         FileOutputStream fos = new FileOutputStream(dstPath);
 68 
 69         int origchksum;
 70         int chksum;
 71         try {
 72 
 73             // read until we get to EOF
 74             while (true) {
 75                 if (Thread.interrupted()) {
 76                     dis.close();
 77                     return;
 78                 }
 79 
 80                 // read the OGG header
 81                 dis.readFully(header, 0, OGG_HEADERSIZE);
 82                 origchksum = readInt(header, 22);
 83                 readLong(header, 6);
 84                 header[22] = 0;
 85                 header[23] = 0;
 86                 header[24] = 0;
 87                 header[25] = 0;
 88                 chksum = OggCrc.checksum(0, header, 0, OGG_HEADERSIZE);
 89 
 90                 // make sure its a OGG header
 91                 if (!OGGID.equals(new String(header, 0, 4))) {
 92                     System.err.println("missing ogg id!");
 93                     errmsg = "missing ogg id!";
 94                     return;
 95                 }
 96 
 97                 /* how many segments are there? */
 98                 segments = header[OGG_SEGOFFSET] & 0xFF;
 99                 dis.readFully(header, OGG_HEADERSIZE, segments);
100                 chksum = OggCrc.checksum(chksum, header, OGG_HEADERSIZE, segments);
101 
102                 /* decode each segment, writing output to wav */
103                 for (curseg = 0; curseg < segments; curseg++) {
104 
105                     if (Thread.interrupted()) {
106                         dis.close();
107                         return;
108                     }
109 
110                     /* get the number of bytes in the segment */
111                     bodybytes = header[OGG_HEADERSIZE + curseg] & 0xFF;
112                     if (bodybytes == 255) {
113                         System.err.println("sorry, don't handle 255 sizes!");
114                         return;
115                     }
116                     dis.readFully(payload, 0, bodybytes);
117                     chksum = OggCrc.checksum(chksum, payload, 0, bodybytes);
118 
119                     /* decode the segment */
120                     /* if first packet, read the Speex header */
121                     if (packetNo == 0) {
122                         if (readSpeexHeader(payload, 0, bodybytes, true)) {
123 
124                             packetNo++;
125                         } else {
126                             packetNo = 0;
127                         }
128                     } else if (packetNo == 1) { // Ogg Comment packet
129                         packetNo++;
130                     } else {
131 
132                         /* get the amount of decoded data */
133                         short[] decoded = new short[160];
134                         if ((decsize = speexDecoder.decode(payload, decoded, 160)) > 0) {
135                             //把边解边播改为写文件
136                             fos.write(ShortAndByte.shortArray2ByteArray(decoded), 0, decsize * 2);
137                         }
138                         packetNo++;
139                     }
140                 }
141                 if (chksum != origchksum)
142                     throw new IOException("Ogg CheckSums do not match");
143             }
144         } catch (Exception e) {
145             e.printStackTrace();
146         }
147         fos.close();
148         dis.close();
149     }
150 
151     /**
152      * Reads the header packet.
153      * 
154      * <pre>
155      *  0 -  7: speex_string: "Speex   "
156      *  8 - 27: speex_version: "speex-1.0"
157      * 28 - 31: speex_version_id: 1
158      * 32 - 35: header_size: 80
159      * 36 - 39: rate
160      * 40 - 43: mode: 0=narrowband, 1=wb, 2=uwb
161      * 44 - 47: mode_bitstream_version: 4
162      * 48 - 51: nb_channels
163      * 52 - 55: bitrate: -1
164      * 56 - 59: frame_size: 160
165      * 60 - 63: vbr
166      * 64 - 67: frames_per_packet
167      * 68 - 71: extra_headers: 0
168      * 72 - 75: reserved1
169      * 76 - 79: reserved2
170      * </pre>
171      * 
172      * @param packet
173      * @param offset
174      * @param bytes
175      * @return
176      * @throws Exception
177      */
178     private boolean readSpeexHeader(final byte[] packet, final int offset, final int bytes, boolean init) throws Exception {
179         if (bytes != 80) {
180             return false;
181         }
182         if (!"Speex   ".equals(new String(packet, offset, 8))) {
183             return false;
184         }
185         //        int mode = packet[40 + offset] & 0xFF;
186         int sampleRate = readInt(packet, offset + 36);
187         //        int channels = readInt(packet, offset + 48);
188         //        int nframes = readInt(packet, offset + 64);
189         //        int frameSize = readInt(packet, offset + 56);
190         //        RongXinLog.SystemOut("mode=" + mode + " sampleRate==" + sampleRate + " channels=" + channels
191         //                + "nframes=" + nframes + "framesize=" + frameSize);
192         initializeAndroidAudio(sampleRate);
193 
194         if (init) {
195             // return speexDecoder.init(mode, sampleRate, channels, enhanced);
196             return true;
197         } else {
198             return true;
199         }
200     }
201 
202     protected static int readInt(final byte[] data, final int offset) {
203         /*
204          * no 0xff on the last one to keep the sign
205          */
206         return (data[offset] & 0xff) | ((data[offset + 1] & 0xff) << 8) | ((data[offset + 2] & 0xff) << 16) | (data[offset + 3] << 24);
207     }
208 
209     protected static long readLong(final byte[] data, final int offset) {
210         /*
211          * no 0xff on the last one to keep the sign
212          */
213         return (data[offset] & 0xff) | ((data[offset + 1] & 0xff) << 8) | ((data[offset + 2] & 0xff) << 16) | ((data[offset + 3] & 0xff) << 24) | ((data[offset + 4] & 0xff) << 32)
214                 | ((data[offset + 5] & 0xff) << 40) | ((data[offset + 6] & 0xff) << 48) | (data[offset + 7] << 56);
215     }
216 
217     protected static int readShort(final byte[] data, final int offset) {
218         /*
219          * no 0xff on the last one to keep the sign
220          */
221         return (data[offset] & 0xff) | (data[offset + 1] << 8);
222     }
223 
224 }

注意上面因为speex解码出来的是160个short类型的数组,而java写文件要求写入的是byte数组,所以我们还是用到了short转byte数组的方法shortArray2ByteArray,我封装了一个类。也贴在下边

 1 package com.sixin.speex;
 2 
 3 public class ShortAndByte {
 4     /** 
 5     * @功能 短整型与字节的转换 
 6     * @param 短整型 
 7     * @return 两位的字节数组 
 8     */
 9     public static byte[] shortToByte(short number) {
10         int temp = number;
11         byte[] b = new byte[2];
12         for (int i = 0; i < b.length; i++) {
13             b[i] = new Integer(temp & 0xff).byteValue();// 将最低位保存在最低位  
14             temp = temp >> 8; // 向右移8位  
15         }
16         return b;
17     }
18 
19     /** 
20      * @功能 字节的转换与短整型 
21      * @param 两位的字节数组 
22      * @return 短整型 
23      */
24     public static short byteToShort(byte[] b) {
25         short s = 0;
26         short s0 = (short) (b[0] & 0xff);// 最低位  
27         short s1 = (short) (b[1] & 0xff);
28         s1 <<= 8;
29         s = (short) (s0 | s1);
30         return s;
31     }
32 
33     /** 
34      * @说明 主要是为解析静态数据包,将一个字节数组转换为short数组 
35      * @param b 
36      */
37     public static short[] byteArray2ShortArray(byte[] b) {
38         int len = b.length / 2;
39         int index = 0;
40         short[] re = new short[len];
41         byte[] buf = new byte[2];
42         for (int i = 0; i < b.length;) {
43             buf[0] = b[i];
44             buf[1] = b[i + 1];
45             short st = byteToShort(buf);
46             re[index] = st;
47             index++;
48             i += 2;
49         }
50         return re;
51     }
52 
53     /** 
54      * @说明 主要是为解析静态数据包,将一个short数组反转为字节数组 
55      * @param b 
56      */
57     public static byte[] shortArray2ByteArray(short[] b) {
58         byte[] rebt = new byte[b.length * 2];
59         int index = 0;
60         for (int i = 0; i < b.length; i++) {
61             short st = b[i];
62             byte[] bt = shortToByte(st);
63             rebt[index] = bt[0];
64             rebt[index + 1] = bt[1];
65             index += 2;
66         }
67         return rebt;
68     }
69 }

读出来的原数据我们放入到了dstPath的文件,再来看看是怎么操作的呢?其中我还是修改了gauss的speexplayer方法。

我们复制speexPlayer方法,改名为SpeexFileDecoderHelper,按照如下方法修改

  1 /**
  2  * 
  3  */
  4 package com.sixin.speex;
  5 
  6 import java.io.File;
  7 
  8 import android.os.Handler;
  9 
 10 /**
 11  * @author honghe
 12  * 
 13  */
 14 public class SpeexFileDecoderHelper {
 15     private String srcName = null;
 16     private String dstName = null;
 17     private SpeexFileDecoder speexdec = null;
 18     private OnSpeexFileCompletionListener speexListener = null;
 19     private static final int speexdecode_completion = 1001;
 20     private static final int speexdecode_error = 1002;
 21 
 22     public Handler handler = new Handler() {
 23         public void handleMessage(android.os.Message msg) {
 24             int what = msg.what;
 25             switch (what) {
 26             case speexdecode_completion:
 27                 if (speexListener != null) {
 28                     speexListener.onCompletion(speexdec);
 29                 } else {
 30                     System.out.println("司信---------null===speexListener");
 31                 }
 32                 break;
 33             case speexdecode_error:
 34                 if (speexListener != null) {
 35                     File file = new File(SpeexFileDecoderHelper.this.srcName);
 36                     if (null != file && file.exists()) {
 37                         file.delete();
 38                     }
 39                     speexListener.onError(null);
 40                 }
 41                 break;
 42             default:
 43                 break;
 44             }
 45         };
 46     };
 47 
 48     public SpeexFileDecoderHelper(String fileName,String dstName, OnSpeexFileCompletionListener splistener) {
 49         this.speexListener = splistener;
 50         this.srcName = fileName;
 51         this.dstName = dstName;
 52         try {
 53             speexdec = new SpeexFileDecoder(new File(this.srcName),new File(this.dstName));
 54         } catch (Exception e) {
 55             e.printStackTrace();
 56             File file = new File(SpeexFileDecoderHelper.this.srcName);
 57             if (null != file && file.exists()) {
 58                 file.delete();
 59             }
 60         }
 61     }
 62 
 63     public void startDecode() {
 64         RecordDecodeThread rpt = new RecordDecodeThread();
 65         Thread th = new Thread(rpt);
 66         th.start();
 67     }
 68 
 69     public boolean isDecoding = false;
 70 
 71     class RecordDecodeThread extends Thread {
 72 
 73         public void run() {
 74             try {
 75                 if (speexdec != null) {
 76                     isDecoding = true;
 77                     speexdec.decode();
 78                     if (null != speexdec.getErrmsg()) {
 79                         throw new Exception(speexdec.getErrmsg());
 80                     }
 81                 }
 82                 System.out.println("RecordPlayThread   文件转换完成");
 83                 if (isDecoding) {
 84                     handler.sendEmptyMessage(speexdecode_completion);
 85                 } 
 86                 isDecoding = false;
 87             } catch (Exception t) {
 88                 t.printStackTrace();
 89                 System.out.println("RecordPlayThread   文件转换出错");
 90                 handler.sendEmptyMessage(speexdecode_error);
 91                 isDecoding = false;
 92             }
 93         }
 94     }
 95 
 96     /**
 97      * 结束播放
 98      */
 99     public void stopDecode() {
100         isDecoding = false;
101     }
102 
103     public String getSpxFileName() {
104         return this.srcName;
105     };
106 }

这个方法是开启了一个现成去解码,然后解码完成后会发送handler,调用回调方法,通知解码失败还是成功。OnSpeexFileCompletionListener这个很简单,我需要贴吗?还是贴上吧,省的被骂娘。

 1 package com.sixin.speex;
 2 
 3 /**
 4  * Speex音频解码完成监听
 5  * @author honghe
 6  *
 7  */
 8 public interface OnSpeexFileCompletionListener {
 9     void onCompletion(SpeexFileDecoder speexdecoder);
10     void onError(Exception ex);
11 }

到此代码都贴出来了。什么?!还不会用?哦,我还没写怎么加wav头呢,那再写个方法吧

 1 /**
 2      * 语音转换
 3      * 
 4      * @param name
 5      * @param srcFileName spx文件名
 6      * @param dstFileName 转换后得到文件的文件名
 7      */
 8     public static void decodeSpx(Context context, String srcFileName, final String dstFileName) {
 9         final String temppath = AudioFileFunc.getFilePathByName("temp.raw");
10         try {
11             // 如果是speex录音
12             if (srcFileName != null && srcFileName.endsWith(".spx")) {
13                 if (mSpeexFileDecoderHelper != null && mSpeexFileDecoderHelper.isDecoding) {
14                     stopMusic(context);
15                 } else {
16                     muteAudioFocus(context, true);
17                     mSpeexFileDecoderHelper = new SpeexFileDecoderHelper(srcFileName, temppath, new OnSpeexFileCompletionListener() {
18 
19                         @Override
20                         public void onError(Exception ex) {
21                             System.out.println("转换错误");
22                         }
23 
24                         @Override
25                         public void onCompletion(SpeexFileDecoder speexdecoder) {
26                             System.out.println("转换完成");
27                             WaveJoin.copyWaveFile(temppath, dstFileName);
28                         }
29                     });
30                     mSpeexFileDecoderHelper.startDecode();
31                 }
32             } else {
33                 System.out.println("音频文件格式不正确");
34             }
35 
36         } catch (Exception e) {
37             e.printStackTrace();
38         }
39     }


copyWaveFile这个方法在哪里?去看开头的那个链接吧,上面有。不过在加wav头的时候要注意,加的头要和你录制音频的时候设置的参数一致,比如samplerate,声道数,framesize这些,我就设置错了一次,gauss录制音频的时候使用的是单声道,我加入的wav头的channel设置成了2,结果放出来的声音老搞笑了,就跟快放一样。有兴趣你可以试试。

代码已更新

代码链接如下:

https://github.com/dongweiq/study/tree/master/Record

我的github地址:https://github.com/dongweiq/study

欢迎关注,欢迎star o(∩_∩)o 。有什么问题请邮箱联系 dongweiqmail@gmail.com qq714094450