这几天一直在研究DSOUND的录音及播放，为了能实现网络音视频打基础，呵呵，在网上查找了大量的相关资料，有一定的收货，其中大量的工作用来修改从网上找出的源码，因为太多错误的了，不太适合初学者，为此我特别封装成类，供初学者学习参考，欢迎批评指正！

/*类接口文件 ISound.h*/

1. /*录音 CSoundRecord.h*/
2. #pragma once
3. #include "isound.h"
4. class CSoundRecord :
5. public ISound
6. {
7. public:
8. CSoundRecord(void);
9. ~CSoundRecord(void);
10. private:
11. LPDIRECTSOUNDCAPTURE8 m_lpCapture;
12. LPDIRECTSOUNDCAPTUREBUFFER m_lpBuffer;
13. LPDIRECTSOUNDCAPTUREBUFFER8 m_lpBuffer8;
14. LPDIRECTSOUNDNOTIFY8 m_lpNotify;
15. DSBPOSITIONNOTIFY m_NotifyPosition[NOTIFICATIONS_PORTION + 1];
16. CWinThread* pThread;
17. CWaveFile *m_pWaveFile;
18. public:
19. BOOL Record();
20. BOOL Stop();
21. protected:
22. BOOL InitializeDevice();
23. BOOL UninitializeDevice();
24. protected:
25. BOOL CreateBuffer();
26. BOOL CreateNotification();
27. void WriteData();
28. void CorrectLocksize(LONG*);
29. static UINT ThreadProc(LPVOID);
30. };

1. /*录音 CSoundRecord.cpp*/
2. #include "StdAfx.h"
3. #include "SoundRecord.h"
4. //#include <boost/lexical_cast.hpp>
5. //using namespace boost;
6. CSoundRecord::CSoundRecord(void)
7. {
8. m_dwBufferSize = m_dwNotifySize*NOTIFICATIONS_PORTION;
9. BOOL bResult = InitializeDevice();
10. if(!bResult)
11. {
12. return;
13. }
14. bResult = CreateBuffer();
15. if(!bResult)
16. {
17. return;
18. }
19. bResult = CreateNotification();
20. if(!bResult)
21. {
22. return;
23. }
24. pThread = AfxBeginThread((AFX_THREADPROC)CSoundRecord::ThreadProc, this);
25. m_pWaveFile = new CWaveFile;
26. }
27. CSoundRecord::~CSoundRecord(void)
28. {
29. UninitializeDevice();
30. }
31. BOOL CSoundRecord::Record()
32. {
33. if(g_strfile.empty())
34. {
35. return FALSE;
36. }
37. LPTSTR lpfile = (LPTSTR)g_strfile.c_str();
38. HRESULT hr = m_pWaveFile->Open(lpfile, &g_wformat, WAVEFILE_WRITE);
39. if(FAILED(hr))
40. {
41. m_pWaveFile->Close();
42. return FALSE;
43. }
44. m_lpBuffer8->Start(DSCBSTART_LOOPING);
45. return TRUE;
46. }
47. BOOL CSoundRecord::Stop()
48. {
49. m_lpBuffer8->Stop();
50. m_pWaveFile->Close();
51. return TRUE;
52. }
53. BOOL CSoundRecord::InitializeDevice()
54. {
55. HRESULT hr = DirectSoundCaptureCreate8(&DSDEVID_DefaultCapture, &m_lpCapture, NULL);
56. if(FAILED(hr))
57. {
58. return FALSE;
59. }
60. return TRUE;
61. }
62. BOOL CSoundRecord::UninitializeDevice()
63. {
64. if(m_pWaveFile != NULL)
65. {
66. delete m_pWaveFile;
67. }
68. if(pThread)
69. {
70. pThread->Delete();
71. }
72. m_lpCapture->Release();
73. return TRUE;
74. }
75. BOOL CSoundRecord::CreateBuffer()
76. {
77. ZeroMemory(&g_wformat, sizeof(g_wformat));
78. g_wformat.wFormatTag = WAVE_FORMAT_PCM;
79. g_wformat.nSamplesPerSec = 11025;//22050;
80. g_wformat.wBitsPerSample = 8;
81. g_wformat.nChannels = 1;
82. g_wformat.nBlockAlign = g_wformat.nChannels * (g_wformat.wBitsPerSample / 8);
83. g_wformat.nAvgBytesPerSec = g_wformat.nBlockAlign * g_wformat.nSamplesPerSec;
84. g_wformat.cbSize = 0;
85. DSCBUFFERDESC dscBufDesc;
86. ZeroMemory(&dscBufDesc, sizeof(dscBufDesc));
87. dscBufDesc.dwSize = sizeof(DSCBUFFERDESC);
88. dscBufDesc.dwFlags = 0;// | DSBCAPS_CTRLVOLUME;
89. dscBufDesc.dwBufferBytes = m_dwBufferSize;//m_wfx.nAvgBytesPerSec;
90. dscBufDesc.dwReserved = 0;
91. dscBufDesc.lpwfxFormat = &g_wformat;
92. dscBufDesc.dwFXCount = 0;
93. dscBufDesc.lpDSCFXDesc = NULL;
94. HRESULT hr = m_lpCapture->CreateCaptureBuffer(&dscBufDesc, &m_lpBuffer, NULL);
95. if(FAILED(hr))
96. {
97. return FALSE;
98. }
99. hr = m_lpBuffer->QueryInterface(IID_IDirectSoundCaptureBuffer8, (LPVOID*)&m_lpBuffer8);
100. if(FAILED(hr))
101. {
102. return FALSE;
103. }
104. m_lpBuffer->Release();
105. return TRUE;
106. }
107. BOOL CSoundRecord::CreateNotification()
108. {
109. m_hEventNotify = CreateEvent(NULL, FALSE, FALSE, NULL);
110. HRESULT hr = m_lpBuffer8->QueryInterface(IID_IDirectSoundNotify, (VOID**)&m_lpNotify);
111. if(FAILED(hr))
112. {
113. return FALSE;
114. }
115. for (int i=0; i<NOTIFICATIONS_PORTION; i++)
116. {
117. m_NotifyPosition[i].dwOffset = (i + 1)*m_dwNotifySize - 1;
118. m_NotifyPosition[i].hEventNotify = m_hEventNotify;
119. }
120. hr = m_lpNotify->SetNotificationPositions(NOTIFICATIONS_PORTION, m_NotifyPosition);
121. if(FAILED(hr))
122. {
123. return FALSE;
124. }
125. return TRUE;
126. }
127. void CSoundRecord::WriteData()
128. {
129. DWORD dwReadPos;
130. DWORD dwCapturePos;
131. LONG lgLockSize;
132. HRESULT hr = m_lpBuffer8->GetCurrentPosition(&dwCapturePos, &dwReadPos);
133. if(FAILED(hr))
134. {
135. return;
136. }
137. lgLockSize = dwReadPos - m_dwBufferOffset;
138. CorrectLocksize(&lgLockSize);
139. VOID *pbCaptureData = NULL;
140. DWORD dwCaptureLength = 0;
141. VOID *pbCaptureData2 = NULL;
142. DWORD dwCaptureLength2 = 0;
143. UINT dwDataWrote;
144. // lock
145. hr = m_lpBuffer8->Lock(m_dwBufferOffset, lgLockSize,
146. &pbCaptureData, &dwCaptureLength, &pbCaptureData2, &dwCaptureLength2,
147. 0L);
148. hr = m_pWaveFile->Write(dwCaptureLength, (BYTE*)pbCaptureData, &dwDataWrote);
149. m_dwBufferOffset+=dwCaptureLength;
150. m_dwBufferOffset%=m_dwBufferSize;
151. if(pbCaptureData2 != NULL)
152. {
153. hr = m_pWaveFile->Write(dwCaptureLength2, (BYTE*)pbCaptureData2, &dwDataWrote);
154. if(FAILED(hr))
155. return;
156. m_dwBufferOffset+=dwCaptureLength2;
157. m_dwBufferOffset%=m_dwBufferSize;
158. }
159. // unlock
160. m_lpBuffer8->Unlock(pbCaptureData, dwCaptureLength,
161. pbCaptureData2, dwCaptureLength2);
162. }
163. UINT CSoundRecord::ThreadProc(LPVOID pParam)
164. {
165. CSoundRecord* pDSoundEx = (CSoundRecord*)pParam;
166. DWORD dwResult;
167. while (TRUE)
168. {
169. dwResult = MsgWaitForMultipleObjects(1, &pDSoundEx->m_hEventNotify, FALSE, INFINITE, NULL);
170. switch(dwResult)
171. {
172. case WAIT_OBJECT_0 + 0:
173. pDSoundEx->WriteData();
174. }
175. }
176. return 0;
177. }
178. void CSoundRecord::CorrectLocksize(LONG* lpsize)
179. {
180. if(*lpsize < 0)
181. {
182. *lpsize += m_dwBufferSize;
183. }
184. //锁住内存的大小
185. //这里取模是为了使得我们读取的数据大小为g_dwNotifySize整数倍，这样buffer里剩下的也是notify的倍数
186. *lpsize -= (*lpsize%m_dwNotifySize);
187. if (*lpsize <= 0)
188. {
189. return;
190. }
191. }