C#基于UDP實現(xiàn)的P2P語音聊天工具
作者：佚名
這篇文章主要是一個應用，使用udp傳送語音和文本等信息。在這個系統(tǒng)中沒有服務端和客戶端，相互通訊都是直接相互聯(lián)系的。能夠很好的實現(xiàn)效果。
這篇文章主要是一個應用，使用udp傳送語音和文本等信息。在這個系統(tǒng)中沒有服務端和客戶端，相互通訊都是直接相互聯(lián)系的。能夠很好的實現(xiàn)效果。
語音獲取
要想發(fā)送語音信息，首先得獲取語音，這里有幾種方法，一種是使用DirectX的DirectXsound來錄音，我為了簡便使用一個開源的插件NAudio來實現(xiàn)語音錄取。 在項目中引用NAudio.dll
- //------------------錄音相關(guān)-----------------------------
- private IWaveIn waveIn;
- private WaveFileWriter writer;
- private void LoadWasapiDevicesCombo()
- {
- var deviceEnum = new MMDeviceEnumerator();
- var devices = deviceEnum.EnumerateAudioEndPoints(DataFlow.Capture, DeviceState.Active).ToList();
- comboBox1.DataSource = devices;
- comboBox1.DisplayMember = "FriendlyName";
- }
- private void CreateWaveInDevice()
- {
- waveIn = new WaveIn();
- waveIn.WaveFormat = new WaveFormat(8000, 1);
- waveIn.DataAvailable += OnDataAvailable;
- waveIn.RecordingStopped += OnRecordingStopped;
- }
- void OnDataAvailable(object sender, WaveInEventArgs e)
- {
- if (this.InvokeRequired)
- {
- this.BeginInvoke(new EventHandler<WaveInEventArgs>(OnDataAvailable), sender, e);
- }
- else
- {
- writer.Write(e.Buffer, 0, e.BytesRecorded);
- int secondsRecorded = (int)(writer.Length / writer.WaveFormat.AverageBytesPerSecond);
- if (secondsRecorded >= 10)//***10s
- {
- StopRecord();
- }
- else
- {
- l_sound.Text = secondsRecorded + " s";
- }
- }
- }
- void OnRecordingStopped(object sender, StoppedEventArgs e)
- {
- if (InvokeRequired)
- {
- BeginInvoke(new EventHandler<StoppedEventArgs>(OnRecordingStopped), sender, e);
- }
- else
- {
- FinalizeWaveFile();
- }
- }
- void StopRecord()
- {
- AllChangeBtn(btn_luyin, true);
- AllChangeBtn(btn_stop, false);
- AllChangeBtn(btn_sendsound, true);
- AllChangeBtn(btn_play, true);
- //btn_luyin.Enabled = true;
- //btn_stop.Enabled = false;
- //btn_sendsound.Enabled = true;
- //btn_play.Enabled = true;
- if (waveIn != null)
- waveIn.StopRecording();
- //Cleanup();
- }
- private void Cleanup()
- {
- if (waveIn != null)
- {
- waveIn.Dispose();
- waveIn = null;
- }
- FinalizeWaveFile();
- }
- private void FinalizeWaveFile()
- {
- if (writer != null)
- {
- writer.Dispose();
- writer = null;
- }
- }
- //開始錄音
- private void btn_luyin_Click(object sender, EventArgs e)
- {
- btn_stop.Enabled = true;
- btn_luyin.Enabled = false;
- if (waveIn == null)
- {
- CreateWaveInDevice();
- }
- if (File.Exists(soundfile))
- {
- File.Delete(soundfile);
- }
- writer = new WaveFileWriter(soundfile, waveIn.WaveFormat);
- waveIn.StartRecording();
- }
上面的代碼實現(xiàn)了錄音，并且寫入文件p2psound_A.wav
#p#
語音發(fā)送
獲取到語音后我們要把語音發(fā)送出去
當我們錄好音后點擊發(fā)送，這部分相關(guān)代碼是
- MsgTranslator tran = null;
- ublic Form1()
- {
- InitializeComponent();
- LoadWasapiDevicesCombo();//顯示音頻設備
- Config cfg = SeiClient.GetDefaultConfig();
- cfg.Port = 7777;
- UDPThread udp = new UDPThread(cfg);
- tran = new MsgTranslator(udp, cfg);
- tran.MessageReceived += tran_MessageReceived;
- tran.Debuged += new EventHandler<DebugEventArgs>(tran_Debuged);
- }
- private void btn_sendsound_Click(object sender, EventArgs e)
- {
- if (t_ip.Text == "")
- {
- MessageBox.Show("請輸入ip");
- return;
- }
- if (t_port.Text == "")
- {
- MessageBox.Show("請輸入端口號");
- return;
- }
- string ip = t_ip.Text;
- int port = int.Parse(t_port.Text);
- string nick = t_nick.Text;
- string msg = "語音消息";
- IPEndPoint remote = new IPEndPoint(IPAddress.Parse(ip), port);
- Msg m = new Msg(remote, "zz", nick, Commands.SendMsg, msg, "Come From A");
- m.IsRequireReceive = true;
- m.ExtendMessageBytes = FileContent(soundfile);
- m.PackageNo = Msg.GetRandomNumber();
- m.Type = Consts.MESSAGE_BINARY;
- tran.Send(m);
- }
- private byte[] FileContent(string fileName)
- {
- FileStream fs = new FileStream(fileName, FileMode.Open, FileAccess.Read);
- try
- {
- byte[] buffur = new byte[fs.Length];
- fs.Read(buffur, 0, (int)fs.Length);
- return buffur;
- }
- catch (Exception ex)
- {
- return null;
- }
- finally
- {
- if (fs != null)
- {
- //關(guān)閉資源
- fs.Close();
- }
- }
- }
如此一來我們就把產(chǎn)生的語音文件發(fā)送出去了
語音的接收與播放
其實語音的接收和文本消息的接收沒有什么不同，只不過語音發(fā)送的時候是以二進制發(fā)送的，因此我們在收到語音后 就應該寫入到一個文件里面去，接收完成后，播放這段語音就行了。
下面這段代碼主要是把收到的數(shù)據(jù)保存到文件中去，這個函數(shù)式我的NetFrame里收到消息時所觸發(fā)的事件，在文章前面提過的那篇文章里
- void tran_MessageReceived(object sender, MessageEventArgs e)
- {
- Msg msg = e.msg;
- if (msg.Type == Consts.MESSAGE_BINARY)
- {
- string m = msg.Type + "->" + msg.UserName + "發(fā)來二進制消息!";
- AddServerMessage(m);
- if (File.Exists(recive_soundfile))
- {
- File.Delete(recive_soundfile);
- }
- FileStream fs = new FileStream(recive_soundfile, FileMode.Create, FileAccess.Write);
- fs.Write(msg.ExtendMessageBytes, 0, msg.ExtendMessageBytes.Length);
- fs.Close();
- //play_sound(recive_soundfile);
- ChangeBtn(true);
- }
- else
- {
- string m = msg.Type + "->" + msg.UserName + "說:" + msg.NormalMsg;
- AddServerMessage(m);
- }
- }
收到語音消息后，我們要進行播放，播放時仍然用剛才那個插件播放
- //--------播放部分----------
- private IWavePlayer wavePlayer;
- private WaveStream reader;
- public void play_sound(string filename)
- {
- if (wavePlayer != null)
- {
- wavePlayer.Dispose();
- wavePlayer = null;
- }
- if (reader != null)
- {
- reader.Dispose();
- }
- reader = new MediaFoundationReader(filename, new MediaFoundationReader.MediaFoundationReaderSettings() { SingleReaderObject = true });
- if (wavePlayer == null)
- {
- wavePlayer = new WaveOut();
- wavePlayer.PlaybackStopped += WavePlayerOnPlaybackStopped;
- wavePlayer.Init(reader);
- }
- wavePlayer.Play();
- }
- private void WavePlayerOnPlaybackStopped(object sender, StoppedEventArgs stoppedEventArgs)
- {
- if (stoppedEventArgs.Exception != null)
- {
- MessageBox.Show(stoppedEventArgs.Exception.Message);
- }
- if (wavePlayer != null)
- {
- wavePlayer.Stop();
- }
- btn_luyin.Enabled = true;
- }private void btn_play_Click(object sender, EventArgs e)
- {
- btn_luyin.Enabled = false;
- play_sound(soundfile);
- }
在上面演示了接收和發(fā)送一段語音消息的界面
技術(shù)總結(jié)
主要用到的技術(shù)就是UDP和NAudio的錄音和播放功能
其中用到的UDP傳輸類我放在了github上面 地址在我的博客左邊的個人介紹里有地址 項目地址 https://github.com/zhujunxxxxx/ZZNetFrame
希望這篇文章能夠提供一個思路。
責任編輯：王雪燕
來源：
碼農(nóng)網(wǎng)
