语音获取
要想发送语音信息，首先得获取语音，这里有几种方法，一种是使用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);
}
在上面演示了接收和发送一段语音消息的界面
技术总结
主要用到的技术就是udp和naudio的录音和播放功能
希望这篇文章能够给大家提供一个思路，帮助大家实现p2p语音聊天工具。
dy("nrwz");
查看更多关于C#基于UDP实现的P2P语音聊天工具的详细内容...