java獲取麥實現語音聊天

本文轉載自查看原文 2011-12-28 20:44 7011 Java學習

java中TargetDataLine 接口提供從目標數據行的緩沖區讀取所捕獲數據的方法，

SourceDataLine 接口提供將音頻數據寫入數據行的緩沖區中的方法。

如從音頻捕獲設備獲取其數據的數據行。

調用start方法開始執行操作。

調用stop方法停止。

package chat;

import javax.swing.JTextArea;
/**
 * @author Hello
 * 把那幾個sender、receiver又包裝了一下，供GUI調用
 */
public class Chat {
	
	private MessageReceiver massageReceiver;
	private MessageSender massageSender;
	private SoundReceiver soundReceiver;
	private SoundSender soundSender;
	
	public Chat(JTextArea textArea){
		massageSender = new MessageSender("231.0.0.1",10000,textArea);
		massageReceiver = new MessageReceiver("231.0.0.1",10000,1024,textArea);
		soundSender = new SoundSender("231.0.0.1",10001,1024);
		soundReceiver = new SoundReceiver("231.0.0.1",10001,1024);
		massageReceiver.start();
	}
	
	public void send(String message){
		massageSender.send(message);
	}
	
	
	public void soundStart(){
		soundReceiver.start();
		soundSender.start();
	}
	
	public void soundStop(){
		soundReceiver.stop();
		soundSender.stop();
	}
}

package chat;

import javax.sound.sampled.*;
/**
 * @author Hello
 * 放音部分
 */
public class SoundSender extends UDPSender implements Runnable{

	private TargetDataLine line;
	private int bufferLength;
	private Thread thread;
	private boolean isStart;
	
	public SoundSender(String groupAddress, int port, int bufferLength){
		super(groupAddress,port);
		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 (LineUnavailableException e) {
			e.printStackTrace();
		}
		this.bufferLength = bufferLength;
		isStart = false;
	}


	public void run() {
		byte[] buffer = new byte[bufferLength];
		while(isStart&&!thread.isInterrupted()){
			line.read(buffer, 0,buffer.length);//接受麥的數據寫入buffer
			send(buffer);
		}
	}
	
	public void start(){
		if(thread == null || !thread.isAlive()){
			thread = new Thread(this);
			line.start();
			thread.start();
			isStart = true;
		}
	}
	
	public void stop(){
		thread.interrupt();
		line.stop();
		isStart = false;
	}
	
}

package chat;

import javax.sound.sampled.*;
/**
 * 
 */
public class SoundReceiver extends UDPReceiver implements Runnable{
	
	private SourceDataLine line; 
	private Thread thread;
	private boolean isStart;
	
	public SoundReceiver(	String groupAddress, 
							int port, 
							int bufferSize){
		super(groupAddress, port, bufferSize);
		AudioFormat format =new AudioFormat(8000,16,2,true,true);
		DataLine.Info info = new DataLine.Info(SourceDataLine.class,format);
        try {
        	line = (SourceDataLine) AudioSystem.getLine(info);
			line.open(format, 10240); 
        } catch (LineUnavailableException e) {
        	e.printStackTrace();
        } 
    }

	public void run() {
		while(isStart&&!thread.isInterrupted()){
			byte[] data = super.receive();
			line.write(data, 0, data.length);//將data的數據轉化為音頻
		}
	}
	
	public void start(){
		if(thread == null || !thread.isAlive()){
			thread = new Thread(this);
			line.start();
			isStart = true;
			contect();
			thread.start();
		}
	}
	
	public void stop(){
		thread.interrupt();
		line.stop();
		isStart = false;
		close();
	}
}

package chat;

import java.io.IOException;
import java.net.*;

/**
 * @author chch87
 * 發送UDP報文的基類，擴展出MessageSender和SoundSender
 */

public class UDPSender {
	
	protected MulticastSocket s;
	protected InetAddress group;
	protected int port;
	protected DatagramPacket dgp;
	
	public UDPSender(String groupAddress, int port){
		this.port = port;
		try {
			s = new MulticastSocket();
			group = InetAddress.getByName (groupAddress);//group一定要是個組播組！如231.0.0.1
		} catch (IOException e) {
			e.printStackTrace();
		}
		dgp = new DatagramPacket (new byte[0], 0, group, port);
	}
	
	public void close(){
		if(s != null)
			s.close ();
	}
	
	protected void send(byte[] buffer){
		dgp.setData (buffer);
		dgp.setLength (buffer.length);
		try {
			s.send (dgp);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package chat;

import java.io.IOException;
import java.net.*;

/**
 * @author chch87
 * 接受UDP報文的基類，擴展出MessageReceiver和SoundReceiver
 */
public class UDPReceiver{
	
	protected MulticastSocket s;
	protected InetAddress group;
	protected byte[] buffer;
	protected DatagramPacket dgp;
	protected int port;
	protected int bufferSize;
	protected boolean isClose;
	
	public UDPReceiver(String groupAddress, int port, int bufferSize){
		try {
			s = new MulticastSocket(port);
			group = InetAddress.getByName(groupAddress);//group一定要是個組播組！如231.0.0.1
			s.joinGroup (group);
			//s.setLoopbackMode(true);//在局域網測試時，可以將禁止回調打開
		} catch (IOException e) {
			e.printStackTrace();
		}
		buffer = new byte[bufferSize];
		dgp = new DatagramPacket (buffer, bufferSize);
		isClose = false;
		this.port = port;
		this.bufferSize = bufferSize;
	}
	
	public void close(){
		if(s != null && group != null){
			try {
				s.leaveGroup (group);
				s.close ();
			} catch (IOException e) {
				e.printStackTrace();
			}
			isClose = true;
		}
	}
	
	public void contect(){
		if(isClose){
			try {
				s = new MulticastSocket(port);
				s.joinGroup (group);
			} catch (IOException e) {
				e.printStackTrace();
			}
			buffer = new byte[bufferSize];
			dgp = new DatagramPacket (buffer, bufferSize);
			isClose = false;
		}
	}
	
	protected byte[] receive(){
		try {
			s.receive (dgp);
		} catch (IOException e) {
			e.printStackTrace();
		}
		return buffer;
	}
	
	protected int getDgpLength(){
		return dgp.getLength();
	}
	
	protected String getIP(){
		return dgp.getAddress().toString();
	}
	
}

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 如何實現百萬級的語音聊天服務 Python實現機器人語音聊天 Unity3D 實現簡單的語音聊天 [iOS版本] 如何用java實現語音播報？ Java實現簡單聊天軟件模仿微信語音聊天功能（1）項目介紹及自定義按鈕實現 Java聊天室的設計與實現 JAVA實現webSocket網頁聊天室純java實現簡易聊天室 Java實現一個簡單的網絡聊天程序