C#基于UDP實現的P2P語音聊天工具

2020-01-24 01:26:56

字體：大中小

來源：轉載

供稿：網友

語音獲取

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

//------------------錄音相關-----------------------------     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();     }

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

語音發送

獲取到語音后我們要把語音發送出去

當我們錄好音后點擊發送，這部分相關代碼是

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)         {            //關閉資源           fs.Close();         }       }     }

如此一來我們就把產生的語音文件發送出去了

語音的接收與播放

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

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

void tran_MessageReceived(object sender, MessageEventArgs e)     {       Msg msg = e.msg;        if (msg.Type == Consts.MESSAGE_BINARY)       {         string m = msg.Type + "->" + msg.UserName + "發來二進制消息!";         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);     }