学步园

java中TargetDataLine 接口提供从目标数据行的缓冲区读取所捕获数据的方法，

SourceDataLine 接口提供将音频数据写入数据行的缓冲区中的方法。

如从音频捕获设备获取其数据的数据行。

调用start方法开始执行操作。

调用stop方法停止。

package chat;</p> <p>import javax.swing.JTextArea;<br /> /**<br /> * @author Hello<br /> * 把那几个sender、receiver又包装了一下，供GUI调用<br /> */<br /> public class Chat {</p> <p> private MessageReceiver massageReceiver;<br /> private MessageSender massageSender;<br /> private SoundReceiver soundReceiver;<br /> private SoundSender soundSender;</p> <p> public Chat(JTextArea textArea){<br /> massageSender = new MessageSender("231.0.0.1",10000,textArea);<br /> massageReceiver = new MessageReceiver("231.0.0.1",10000,1024,textArea);<br /> soundSender = new SoundSender("231.0.0.1",10001,1024);<br /> soundReceiver = new SoundReceiver("231.0.0.1",10001,1024);<br /> massageReceiver.start();<br /> }</p> <p> public void send(String message){<br /> massageSender.send(message);<br /> }</p> <p> public void soundStart(){<br /> soundReceiver.start();<br /> soundSender.start();<br /> }</p> <p> public void soundStop(){<br /> soundReceiver.stop();<br /> soundSender.stop();<br /> }<br /> }<br />
package chat;</p> <p>import javax.sound.sampled.*;<br /> /**<br /> * @author Hello<br /> * 放音部分<br /> */<br /> public class SoundSender extends UDPSender implements Runnable{</p> <p> private TargetDataLine line;<br /> private int bufferLength;<br /> private Thread thread;<br /> private boolean isStart;</p> <p> public SoundSender(String groupAddress, int port, int bufferLength){<br /> super(groupAddress,port);<br /> AudioFormat format =new AudioFormat(8000,16,2,true,true);<br /> DataLine.Info info = new DataLine.Info(TargetDataLine.class,format);<br /> try {<br /> line = (TargetDataLine) AudioSystem.getLine(info);<br /> line.open(format, line.getBufferSize());<br /> } catch (LineUnavailableException e) {<br /> e.printStackTrace();<br /> }<br /> this.bufferLength = bufferLength;<br /> isStart = false;<br /> }</p> <p> public void run() {<br /> byte[] buffer = new byte[bufferLength];<br /> while(isStart&&!thread.isInterrupted()){<br /> line.read(buffer, 0,buffer.length);//接受麦的数据写入buffer<br /> send(buffer);<br /> }<br /> }</p> <p> public void start(){<br /> if(thread == null || !thread.isAlive()){<br /> thread = new Thread(this);<br /> line.start();<br /> thread.start();<br /> isStart = true;<br /> }<br /> }</p> <p> public void stop(){<br /> thread.interrupt();<br /> line.stop();<br /> isStart = false;<br /> }</p> <p>}<br />
package chat;</p> <p>import javax.sound.sampled.*;<br /> /**<br /> *<br /> */<br /> public class SoundReceiver extends UDPReceiver implements Runnable{</p> <p> private SourceDataLine line;<br /> private Thread thread;<br /> private boolean isStart;</p> <p> public SoundReceiver( String groupAddress,<br /> int port,<br /> int bufferSize){<br /> super(groupAddress, port, bufferSize);<br /> AudioFormat format =new AudioFormat(8000,16,2,true,true);<br /> DataLine.Info info = new DataLine.Info(SourceDataLine.class,format);<br /> try {<br /> line = (SourceDataLine) AudioSystem.getLine(info);<br /> line.open(format, 10240);<br /> } catch (LineUnavailableException e) {<br /> e.printStackTrace();<br /> }<br /> }</p> <p> public void run() {<br /> while(isStart&&!thread.isInterrupted()){<br /> byte[] data = super.receive();<br /> line.write(data, 0, data.length);//将data的数据转化为音频<br /> }<br /> }</p> <p> public void start(){<br /> if(thread == null || !thread.isAlive()){<br /> thread = new Thread(this);<br /> line.start();<br /> isStart = true;<br /> contect();<br /> thread.start();<br /> }<br /> }</p> <p> public void stop(){<br /> thread.interrupt();<br /> line.stop();<br /> isStart = false;<br /> close();<br /> }<br /> }<br />
package chat;</p> <p>import java.io.IOException;<br /> import java.net.*;</p> <p>/**<br /> * @author chch87<br /> * 发送UDP报文的基类，扩展出MessageSender和SoundSender<br /> */</p> <p>public class UDPSender {</p> <p> protected MulticastSocket s;<br /> protected InetAddress group;<br /> protected int port;<br /> protected DatagramPacket dgp;</p> <p> public UDPSender(String groupAddress, int port){<br /> this.port = port;<br /> try {<br /> s = new MulticastSocket();<br /> group = InetAddress.getByName (groupAddress);//group一定要是个组播组！如231.0.0.1<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> dgp = new DatagramPacket (new byte[0], 0, group, port);<br /> }</p> <p> public void close(){<br /> if(s != null)<br /> s.close ();<br /> }</p> <p> protected void send(byte[] buffer){<br /> dgp.setData (buffer);<br /> dgp.setLength (buffer.length);<br /> try {<br /> s.send (dgp);<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> }<br /> }<br />
package chat;</p> <p>import java.io.IOException;<br /> import java.net.*;</p> <p>/**<br /> * @author chch87<br /> * 接受UDP报文的基类，扩展出MessageReceiver和SoundReceiver<br /> */<br /> public class UDPReceiver{</p> <p> protected MulticastSocket s;<br /> protected InetAddress group;<br /> protected byte[] buffer;<br /> protected DatagramPacket dgp;<br /> protected int port;<br /> protected int bufferSize;<br /> protected boolean isClose;</p> <p> public UDPReceiver(String groupAddress, int port, int bufferSize){<br /> try {<br /> s = new MulticastSocket(port);<br /> group = InetAddress.getByName(groupAddress);//group一定要是个组播组！如231.0.0.1<br /> s.joinGroup (group);<br /> //s.setLoopbackMode(true);//在局域网测试时，可以将禁止回调打开<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> buffer = new byte[bufferSize];<br /> dgp = new DatagramPacket (buffer, bufferSize);<br /> isClose = false;<br /> this.port = port;<br /> this.bufferSize = bufferSize;<br /> }</p> <p> public void close(){<br /> if(s != null && group != null){<br /> try {<br /> s.leaveGroup (group);<br /> s.close ();<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> isClose = true;<br /> }<br /> }</p> <p> public void contect(){<br /> if(isClose){<br /> try {<br /> s = new MulticastSocket(port);<br /> s.joinGroup (group);<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> buffer = new byte[bufferSize];<br /> dgp = new DatagramPacket (buffer, bufferSize);<br /> isClose = false;<br /> }<br /> }</p> <p> protected byte[] receive(){<br /> try {<br /> s.receive (dgp);<br /> } catch (IOException e) {<br /> e.printStackTrace();<br /> }<br /> return buffer;<br /> }</p> <p> protected int getDgpLength(){<br /> return dgp.getLength();<br /> }</p> <p> protected String getIP(){<br /> return dgp.getAddress().toString();<br /> }</p> <p>}<br />