這篇文章主要是一個應(yīng)用，使用udp傳送語音和文本等信息。在這個系統(tǒng)中沒有服務(wù)端和客戶端，相互通訊都是直接相互聯(lián)系的,能夠很好的實現(xiàn)效果。

語音獲取

要想發(fā)送語音信息，首先得獲取語音，這里有幾種方法，一種是使用DirectX的DirectXsound來錄音，我為了簡便使用一個開源的插件NAudio來實現(xiàn)語音錄取。 在項目中引用NAudio.dll

1. //------------------錄音相關(guān)-----------------------------  
2. private IWaveIn waveIn;  
3. private WaveFileWriter writer;  
4.  
5. private void LoadWasapiDevicesCombo()  
6. {  
7. var deviceEnum = new MMDeviceEnumerator();  
8. var devices = deviceEnum.EnumerateAudioEndPoints(DataFlow.Capture, DeviceState.Active).ToList();  
9. comboBox1.DataSource = devices;  
10. comboBox1.DisplayMember = "FriendlyName";  
11. }  
12. private void CreateWaveInDevice()  
13. {  
14.  
15. waveIn = new WaveIn();  
16. waveIn.WaveFormat = new WaveFormat(8000, 1);  
17. waveIn.DataAvailable += OnDataAvailable;  
18. waveIn.RecordingStopped += OnRecordingStopped;  
19. }  
20. void OnDataAvailable(object sender, WaveInEventArgs e)  
21. {  
22. if (this.InvokeRequired)  
23. {  
24. this.BeginInvoke(new EventHandler<WaveInEventArgs>(OnDataAvailable), sender, e);  
25. }  
26. else 
27. {  
28. writer.Write(e.Buffer, 0, e.BytesRecorded);  
29. int secondsRecorded = (int)(writer.Length / writer.WaveFormat.AverageBytesPerSecond);  
30. if (secondsRecorded >= 10)//最大10s  
31. {  
32. StopRecord();  
33. }  
34. else 
35. {  
36. l_sound.Text = secondsRecorded + " s";  
37. }  
38. }  
39. }  
40. void OnRecordingStopped(object sender, StoppedEventArgs e)  
41. {  
42. if (InvokeRequired)  
43. {  
44. BeginInvoke(new EventHandler<StoppedEventArgs>(OnRecordingStopped), sender, e);  
45. }  
46. else 
47. {  
48. FinalizeWaveFile();  
49. }  
50. }  
51. void StopRecord()  
52. {  
53. AllChangeBtn(btn_luyin, true);  
54. AllChangeBtn(btn_stop, false);  
55. AllChangeBtn(btn_sendsound, true);  
56. AllChangeBtn(btn_play, true);  
57.  
58. //btn_luyin.Enabled = true;  
59. //btn_stop.Enabled = false;  
60. //btn_sendsound.Enabled = true;  
61. //btn_play.Enabled = true;  
62. if (waveIn != null)  
63. waveIn.StopRecording();  
64. //Cleanup();  
65. }  
66. private void Cleanup()  
67. {  
68. if (waveIn != null)  
69. {  
70. waveIn.Dispose();  
71. waveIn = null;  
72. }  
73. FinalizeWaveFile();  
74. }  
75. private void FinalizeWaveFile()  
76. {  
77. if (writer != null)  
78. {  
79. writer.Dispose();  
80. writer = null;  
81. }  
82. }  
83. //開始錄音  
84. private void btn_luyin_Click(object sender, EventArgs e)  
85. {  
86. btn_stop.Enabled = true;  
87. btn_luyin.Enabled = false;  
88. if (waveIn == null)  
89. {  
90. CreateWaveInDevice();  
91. }  
92. if (File.Exists(soundfile))  
93. {  
94. File.Delete(soundfile);  
95. }  
96.  
97. writer = new WaveFileWriter(soundfile, waveIn.WaveFormat);  
98. waveIn.StartRecording();  
99. } 

上面的代碼實現(xiàn)了錄音，并且寫入文件p2psound_A.wav

語音發(fā)送

獲取到語音后我們要把語音發(fā)送出去

當我們錄好音后點擊發(fā)送，這部分相關(guān)代碼是

1. MsgTranslator tran = null;  
2. ublic Form1()  
3. {  
4. InitializeComponent();  
5. LoadWasapiDevicesCombo();//顯示音頻設(shè)備  
6.  
7. Config cfg = SeiClient.GetDefaultConfig();  
8. cfg.Port = 7777;  
9. UDPThread udp = new UDPThread(cfg);  
10. tran = new MsgTranslator(udp, cfg);  
11. tran.MessageReceived += tran_MessageReceived;  
12. tran.Debuged += new EventHandler<DebugEventArgs>(tran_Debuged);  
13. }  
14. private void btn_sendsound_Click(object sender, EventArgs e)  
15. {  
16. if (t_ip.Text == "")  
17. {  
18. MessageBox.Show("請輸入ip");  
19. return;  
20. }  
21. if (t_port.Text == "")  
22. {  
23. MessageBox.Show("請輸入端口號");  
24. return;  
25. }  
26. string ip = t_ip.Text;  
27. int port = int.Parse(t_port.Text);  
28. string nick = t_nick.Text;  
29. string msg = "語音消息";  
30.  
31. IPEndPoint remote = new IPEndPoint(IPAddress.Parse(ip), port);  
32. Msg m = new Msg(remote, "zz", nick, Commands.SendMsg, msg, "Come From A");  
33. m.IsRequireReceive = true;  
34. m.ExtendMessageBytes = FileContent(soundfile);  
35. m.PackageNo = Msg.GetRandomNumber();  
36. m.Type = Consts.MESSAGE_BINARY;  
37. tran.Send(m);  
38. }  
39. private byte[] FileContent(string fileName)  
40. {  
41. FileStream fs = new FileStream(fileName, FileMode.Open, FileAccess.Read);  
42. try 
43. {  
44. byte[] buffur = new byte[fs.Length];  
45. fs.Read(buffur, 0, (int)fs.Length);  
46.  
47. return buffur;  
48. }  
49. catch (Exception ex)  
50. {  
51. return null;  
52. }  
53. finally 
54. {  
55. if (fs != null)  
56. {  
57.  
58. //關(guān)閉資源  
59. fs.Close();  
60. }  
61. }  
62. }  

如此一來我們就把產(chǎn)生的語音文件發(fā)送出去了

語音的接收與播放

其實語音的接收和文本消息的接收沒有什么不同，只不過語音發(fā)送的時候是以二進制發(fā)送的，因此我們在收到語音后 就應(yīng)該寫入到一個文件里面去，接收完成后，播放這段語音就行了。

下面這段代碼主要是把收到的數(shù)據(jù)保存到文件中去，這個函數(shù)式我的NetFrame里收到消息時所觸發(fā)的事件，在文章前面提過的那篇文章里

1. void tran_MessageReceived(object sender, MessageEventArgs e)  
2. {  
3. Msg msg = e.msg;  
4.  
5. if (msg.Type == Consts.MESSAGE_BINARY)  
6. {  
7. string m = msg.Type + "->" + msg.UserName + "發(fā)來二進制消息!";  
8. AddServerMessage(m);  
9. if (File.Exists(recive_soundfile))  
10. {  
11. File.Delete(recive_soundfile);  
12. }  
13. FileStream fs = new FileStream(recive_soundfile, FileMode.Create, FileAccess.Write);  
14. fs.Write(msg.ExtendMessageBytes, 0, msg.ExtendMessageBytes.Length);  
15. fs.Close();  
16. //play_sound(recive_soundfile);  
17. ChangeBtn(true);  
18.  
19. }  
20. else 
21. {  
22. string m = msg.Type + "->" + msg.UserName + "說:" + msg.NormalMsg;  
23. AddServerMessage(m);  
24. }  
25. }  

收到語音消息后，我們要進行播放，播放時仍然用剛才那個插件播放

1. //--------播放部分----------  
2. private IWavePlayer wavePlayer;  
3. private WaveStream reader;  
4.  
5. public void play_sound(string filename)  
6. {  
7. if (wavePlayer != null)  
8. {  
9. wavePlayer.Dispose();  
10. wavePlayer = null;  
11. }  
12. if (reader != null)  
13. {  
14. reader.Dispose();  
15. }  
16. reader = new MediaFoundationReader(filename, new MediaFoundationReader.MediaFoundationReaderSettings() { SingleReaderObject = true });  
17.  
18. if (wavePlayer == null)  
19. {  
20.  
21. wavePlayer = new WaveOut();  
22. wavePlayer.PlaybackStopped += WavePlayerOnPlaybackStopped;  
23. wavePlayer.Init(reader);  
24. }  
25. wavePlayer.Play();  
26. }  
27. private void WavePlayerOnPlaybackStopped(object sender, StoppedEventArgs stoppedEventArgs)  
28. {  
29. if (stoppedEventArgs.Exception != null)  
30. {  
31. MessageBox.Show(stoppedEventArgs.Exception.Message);  
32. }  
33. if (wavePlayer != null)  
34. {  
35. wavePlayer.Stop();  
36. }  
37. btn_luyin.Enabled = true;  
38. }private void btn_play_Click(object sender, EventArgs e)  
39. {  
40. btn_luyin.Enabled = false;  
41. play_sound(soundfile);  
42. } 

在上面演示了接收和發(fā)送一段語音消息的界面

技術(shù)總結(jié)

主要用到的技術(shù)就是UDP和NAudio的錄音和播放功能

希望這篇文章能夠給大家提供一個思路，幫助大家實現(xiàn)P2P語音聊天工具。