关闭 x
IT技术网
    技 采 号
    ITJS.cn - 技术改变世界
    • 实用工具
    • 菜鸟教程
    IT采购网 中国存储网 科技号 CIO智库

    IT技术网

    IT采购网
    • 首页
    • 行业资讯
    • 系统运维
      • 操作系统
        • Windows
        • Linux
        • Mac OS
      • 数据库
        • MySQL
        • Oracle
        • SQL Server
      • 网站建设
    • 人工智能
    • 半导体芯片
    • 笔记本电脑
    • 智能手机
    • 智能汽车
    • 编程语言
    IT技术网 - ITJS.CN
    首页 » .NET »C#基于UDP实现的P2P语音聊天工具

    C#基于UDP实现的P2P语音聊天工具

    2014-10-16 00:00:00 出处:不忘初心
    分享

    微信扫一扫:分享

    Scan me!

    微信里点“发现”,扫一下

    二维码便可将本文分享至朋友圈。

    这篇文章主要是一个应用,使用udp传送语音和文本等信息。在这个系统中没有服务端和客户端,相互通讯都是直接相互联系的。能够很好的实现效果。

    语音获取

    要想发送语音信息,首先得获取语音,这里有几种方法,一种是使用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;
     public 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);
            }

    在上面演示了接收和发送一段语音消息的界面

    技术总结

    主要用到的技术就是UDP和NAudio的录音和播放功能

    其中用到的UDP传输类我放在了github上面 地址在我的博客左边的个人介绍里有地址 项目地址 https://github.com/zhujunxxxxx/ZZNetFrame

    希望这篇文章能够提供一个思路。

    上一篇返回首页 下一篇

    声明: 此文观点不代表本站立场;转载务必保留本文链接;版权疑问请联系我们。

    别人在看

    抖音安全与信任开放日:揭秘推荐算法,告别单一标签依赖

    ultraedit编辑器打开文件时,总是提示是否转换为DOS格式,如何关闭?

    Cornell大神Kleinberg的经典教材《算法设计》是最好入门的算法教材

    从 Microsoft 下载中心安装 Windows 7 SP1 和 Windows Server 2008 R2 SP1 之前要执行的步骤

    Llama 2基于UCloud UK8S的创新应用

    火山引擎DataTester:如何使用A/B测试优化全域营销效果

    腾讯云、移动云继阿里云降价后宣布大幅度降价

    字节跳动数据平台论文被ICDE2023国际顶会收录,将通过火山引擎开放相关成果

    这个话题被围观超10000次,火山引擎VeDI如此解答

    误删库怎么办?火山引擎DataLeap“3招”守护数据安全

    IT头条

    平替CUDA!摩尔线程发布MUSA 4性能分析工具

    00:43

    三起案件揭开侵犯个人信息犯罪的黑灰产业链

    13:59

    百度三年开放2.1万实习岗,全力培育AI领域未来领袖

    00:36

    工信部:一季度,电信业务总量同比增长7.7%,业务收入累计完成4469亿元

    23:42

    Gartner:2024年全球半导体营收6559亿美元,AI助力英伟达首登榜首

    18:04

    技术热点

    iOS 8 中如何集成 Touch ID 功能

    windows7系统中鼠标滑轮键(中键)的快捷应用

    MySQL数据库的23个特别注意的安全事项

    Kruskal 最小生成树算法

    Ubuntu 14.10上安装新的字体图文教程

    Ubuntu14更新后无法进入系统卡在光标界面解怎么办?

      友情链接:
    • IT采购网
    • 科技号
    • 中国存储网
    • 存储网
    • 半导体联盟
    • 医疗软件网
    • 软件中国
    • ITbrand
    • 采购中国
    • CIO智库
    • 考研题库
    • 法务网
    • AI工具网
    • 电子芯片网
    • 安全库
    • 隐私保护
    • 版权申明
    • 联系我们
    IT技术网 版权所有 © 2020-2025,京ICP备14047533号-20,Power by OK设计网

    在上方输入关键词后,回车键 开始搜索。Esc键 取消该搜索窗口。