chat.java

Java实现的语音聊天源代码

import java.io.*;
import javax.sound.sampled.*;
import java.net.*;
import java.awt.*;
import javax.swing.*;

public class Chat{
	public static void main(String[]args){
		JFrame jf=new JFrame();
		host();
	}
	private static void host(){
		boolean b=false;
		ServerSocket server=null;
		Socket s=null;
			try{
				server=new ServerSocket(5000);
			}catch(IOException e){
				System.out.println(e);
				System.exit(0);
			}
		try{
			s=server.accept();
		}catch(IOException e){}
		(new Capture(s)).start();
		(new Playback(s)).start();
	}
	private static void client(){
		boolean b=false;
		Socket s=null;
		String ip;
		BufferedReader br;
		do{
			try{
				b=false;
				br=new BufferedReader(new InputStreamReader(System.in));
				ip=br.readLine();
				System.out.println(ip);
			  if(ip!=null)s=new Socket(ip,5000);
		  }catch(IOException e){System.out.println(e);b=true;}
		}while(b);
		(new Capture(s)).start();
		(new Playback(s)).start();
	}
}

class Playback implements Runnable {

final int bufSize = 16384;
SourceDataLine line;
Thread thread;
InputStream in;

Playback(Socket s){//构造器 取得socket以获得网络输入流
try{
	in=s.getInputStream();
}catch(IOException e){System.out.println(e);}
}

public void start() {
thread = new Thread(this);
thread.setName("Playback");
thread.start();

}

public void stop() {
thread = null;
}

public void run() {
try{
	thread.sleep(100);
}catch(Exception e){System.out.println(e);}
AudioFormat format=new AudioFormat(8000,16,2,true,true);//AudioFormat(float sampleRate, int sampleSizeInBits, int channels, boolean signed, boolean bigEndian）
BufferedInputStream playbackInputStream;

playbackInputStream=new BufferedInputStream(new AudioInputStream(in,format,2147483647));//封装成音频输出流，如果网络流 是经过压缩的需在此加套解压流

DataLine.Info info = new DataLine.Info(SourceDataLine.class,format);

try {
line = (SourceDataLine) AudioSystem.getLine(info);
line.open(format, bufSize);
} catch (LineUnavailableException ex) {
return;
}

byte[] data = new byte[16];//此处数组的大小跟实时性关系不大，可根据情况进行调整
int numBytesRead = 0;
line.start();

while (thread != null) {
try{
numBytesRead = playbackInputStream.read(data);
line.write(data, 0,numBytesRead);
} catch (IOException e) {
break;
}
}

if (thread != null) {
line.drain();
}

line.stop();
line.close();
line = null;
}
}

class Capture implements Runnable {

TargetDataLine line;
Thread thread;
OutputStream out;
BufferedOutputStream captrueOutputStream;

Capture(Socket s){
try{
	out=s.getOutputStream();
}catch(IOException e){System.out.println(e);}
}

public void start() {

thread = new Thread(this);
thread.setName("Capture");
thread.start();
}

public void stop() {
thread = null;
}

public void run() {
captrueOutputStream=new BufferedOutputStream(out);//建立输出流 此处可以加套压缩流用来压缩数据

AudioFormat format =new AudioFormat(8000,16,2,true,true);//AudioFormat(float sampleRate, int sampleSizeInBits, int channels, boolean signed, boolean bigEndian）
DataLine.Info info = new DataLine.Info(TargetDataLine.class,format);

try {
line = (TargetDataLine) AudioSystem.getLine(info);
line.open(format, line.getBufferSize());
} catch (Exception ex) {
return;
}

byte[] data = new byte[1024];//此处的1024可以情况进行调整，应跟下面的1024应保持一致
int numBytesRead=0;
line.start();

while (thread != null) {
numBytesRead = line.read(data, 0,1024);//取数据（1024）的大小直接关系到传输的速度，一般越小越快，
try {
captrueOutputStream.write(data, 0, numBytesRead);//写入网络流
}
catch (Exception ex) {
break;
}
}

line.stop();
line.close();
line = null;

try {
captrueOutputStream.flush();
captrueOutputStream.close();
} catch (IOException ex) {
ex.printStackTrace();
}
}
}