capture.java

jmf的入门级小程序

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

/**
 * Title: VoiceChat Description: 音频捕捉（录音程序） Copyright: Copyright (c) 2001
 * Company:
 * 
 * @author 你猜！
 * @version 1.0
 */

class Capture implements Runnable {

	TargetDataLine line; // 从音频捕获设备获取其数据的数据行
	Thread thread;
	Socket s;
	BufferedOutputStream captrueOutputStream;
//	AMAudioFormat sd=new AMAudioFormat();

	Capture(Socket s) {// 构造器 取得socket以获得网络输出流
		this.s = s;
	}

	public void start() {

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

	public void stop() {
		thread = null;
	}

	public void run() {

		try {
			captrueOutputStream = new BufferedOutputStream(s.getOutputStream());// 建立输出流
																				// 此处可以加套压缩流用来压缩数据
		} catch (IOException ex) {
			return;
		}

		AudioFormat format = new AudioFormat(8000, 16, 2, true, true);
		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();
		}
	}
}