c#语音对讲demo

【实例简介】

开启前输入对方IP点击录音然后发送即可

【实例截图】

【核心代码】

using NAudio.CoreAudioApi;
using NAudio.Wave;
using Netframe.Core;
using Netframe.Event;
using Netframe;
using Netframe.Model;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Windows.Input;
using System.Threading;

namespace 语音
{
    public partial class Form1 : Form
    {
       // MsgTranslator tran = null;
        public Form1()
        {
            InitializeComponent();
            LoadWasapiDevicesCombo();
            CheckForIllegalCrossThreadCalls = false;
       
          //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 IWaveIn waveIn;
        private WaveFileWriter writer;
        private IWavePlayer wavePlayer;
        private WaveStream reader;
        //麦克风
        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 >= 30)//最大30s
                {
                    StopRecord();
                }
                else
                {
                    l_sound.Text = secondsRecorded 1   " s";
                }
            }
        }
        void OnRecordingStopped(object sender, StoppedEventArgs e)
        {
            if (InvokeRequired)
            {
                BeginInvoke(new EventHandler<StoppedEventArgs>(OnRecordingStopped), sender, e);
            }
            else
            {
                FinalizeWaveFile();
            }
        }
        void StopRecord()
        {
          
            if (waveIn != null)
                waveIn.StopRecording();
        }
        private void Cleanup()
        {
            if (waveIn != null)
            {
                waveIn.Dispose();
                waveIn = null;
            }
            FinalizeWaveFile();
        }
        
        private void FinalizeWaveFile()
        {
            if (writer != null)
            {
                writer.Dispose();
                writer = null;
            }
        }
        string soundfile;
        private void button1_Click(object sender, EventArgs e)
        {
             soundfile = DateTime.Now.Minute.ToString ()  DateTime .Now.Second.ToString() ".wav";
            if (wavePlayer != null)
            {
                wavePlayer.Dispose();
                wavePlayer = null;
            }
            if (waveIn == null)
            {
                CreateWaveInDevice();
            }
            if (File.Exists(soundfile))
            {
                File.Delete(soundfile);
            }

            writer = new WaveFileWriter(soundfile, waveIn.WaveFormat);
            waveIn.StartRecording();
            int i = (int)MessageBox.Show("开始录制:点击确定结束录制;点击取消取消录制.", "系统提示：", MessageBoxButtons.OKCancel);
            if (i == 1)
            {
                StopRecord();
                l_sound.Text = 0  " s";
            }
            else if(i == 2)
            {
                StopRecord();
                l_sound.Text = 0   " s";
            }
        }
  
       //---------------------------------------播放相关-----------------
        public void play_sound(string filename)
        {
            if (wavePlayer != null)
            {
                wavePlayer.Dispose();
                wavePlayer = null;
            }
            if (reader != null)
            {
                reader.Dispose();
            }
            try
            {
                reader = new MediaFoundationReader(filename, new MediaFoundationReader.MediaFoundationReaderSettings() { SingleReaderObject = true });
            

            if (wavePlayer == null)
            {

                wavePlayer = new WaveOut();
                wavePlayer.PlaybackStopped  = WavePlayerOnPlaybackStopped;
                wavePlayer.Init(reader);
            }
            wavePlayer.Play();
            }
            catch
            {
                MessageBox.Show("当前录音为空");
            }

        }
        private void WavePlayerOnPlaybackStopped(object sender, StoppedEventArgs stoppedEventArgs)
        {
            if (stoppedEventArgs.Exception != null)
            {
                MessageBox.Show(stoppedEventArgs.Exception.Message);
            }
            if (wavePlayer != null)
            {
                wavePlayer.Stop();
            }
            
        }
        private void btn_play_Click(object sender, EventArgs e)
        {          
            play_sound(soundfile);
        }



        //-----------------------发送相关-----------------
        
        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();
                }
            }
        }
   
        private delegate void MessageDelegate(string message);
        public void AddServerMessage(string message)
        {
            if (richTextBox1.InvokeRequired)//不能访问就创建委托
            {
                MessageDelegate d = new MessageDelegate(AddServerMessage);
                richTextBox1.Invoke(d, new object[] { message });
            }
            else
            {
                richTextBox1.AppendText(message   Environment.NewLine);
                richTextBox1.ScrollToCaret();
            }
        }
        string recive_soundfile;
        void tran_MessageReceived(object sender, MessageEventArgs e)
        {
            recive_soundfile = DateTime.Now.Minute.ToString()   DateTime.Now.Second.ToString()   ".wav";
            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 void button3_Click_1(object sender, EventArgs e)
        {
            if(soundfile!=null )
            {
                if (t_ip.Text == "")
                {
                    MessageBox.Show("请输入ip");
                    return;
                }
                string ip = t_ip.Text;
                UDPThread udp = new UDPThread(cfg);
                MsgTranslator tran = new MsgTranslator(udp, cfg);
                tran.MessageReceived  = tran_MessageReceived;
                IPEndPoint remote = new IPEndPoint(IPAddress.Parse(ip), 2048);
                Msg m = new Msg(remote, "猫九先森", "Name", Commands.Entry, "chat", "chat");
                m.IsRequireReceive = true;
                m.ExtendMessageBytes = FileContent(soundfile);
                m.PackageNo = Msg.GetRandomNumber();
                m.Type = Consts.MESSAGE_BINARY;
                tran.Send(m);
            }
            else
            {
                MessageBox.Show("请录入一条语音");
            }
            
        }
        Config cfg = SeiClient.GetDefaultConfig();
        private void Form1_Load(object sender, EventArgs e)
        {
            
            cfg.Port = 2048;
        }
    }
}