chatconsumer.java

JMS编写的声音播放软件

package audiopanel;
import com.sun.media.jsdt.*;
import java.awt.*;
import java.applet.Applet;
import javax.media.bean.playerbean.*;
import javax.media.*;
import java.util.Vector;
import javax.media.protocol.DataSource;
import javax.media.format.*;
import javax.media.Time;
import javax.media.MediaLocator;
import javax.media.protocol.*;
import java.io.IOException;
import java.awt.Dimension;
import com.sun.media.ui.*;
import javax.media.bean.playerbean.*;
class ChatConsumer implements ChannelConsumer, ChatDebugFlags {
        protected Buffer audioBuffer=new Buffer();
        AudioFormat audioFormat;
        audioPanel myUser = null;
       public  ChatConsumer(String name,audioPanel  _chatUser) {
//    	System.out.println("\u00B4\u00B4\u00BD¨\u00D2\u00BB\u00B8\u00F6\u00CF\u00FB·\u00D1\u00D5\u00DF");
                this.myUser = _chatUser;

                //audioFormat = new AudioFormat(AudioFormat.LINEAR, 8000.0, 8,1,Format.NOT_SPECIFIED, AudioFormat.SIGNED, 8,Format.NOT_SPECIFIED,Format.byteArray);
         audioFormat= new AudioFormat(AudioFormat.LINEAR,44100,16,1,AudioFormat.BIG_ENDIAN,AudioFormat.SIGNED);
        if (ChatConsumer_Debug) {
            System.err.println("ChatConsumer: constructor.");
                   }
         }
    public synchronized void  dataReceived(Data data) {
       myUser.processData(data);

    }
    public void setAudioBuffer(Buffer buffer){
        audioBuffer=buffer;
        }
 }

    //\u00C4\u00DA\u00B2\u00BF\u00C0à LiveStream\u00B6\u00C1\u00C8\u00A1\u00CA\u00FD\u00BE\u00DD
  /* class LiveStream implements PushBufferStream, Runnable {

    protected ContentDescriptor cd = new ContentDescriptor(ContentDescriptor.RAW);
    protected int maxDataLength;
    protected byte [] data;
    protected Dimension size;
    protected RGBFormat rgbFormat;
    protected AudioFormat audioFormat;
    protected boolean started;
    protected Thread thread;
    protected float frameRate = 20f;
    protected BufferTransferHandler transferHandler;
    protected Control [] controls = new Control[0];
//    protected Buffer audioBuffer=new Buffer();
    protected boolean videoData = false;

    public LiveStream() {
            audioFormat = new AudioFormat(AudioFormat.LINEAR,
                                          44100.0,
                                          16,
                                          2,
                                          Format.NOT_SPECIFIED,
                                          AudioFormat.UNSIGNED,
                                          8,
                                          Format.NOT_SPECIFIED,
                                          Format.byteArray);
            maxDataLength = 1000;
//	Thread = new Thread(this);
                  //	 new Thread(this).start();
    }


    public ContentDescriptor getContentDescriptor() {
        return cd;
    }

    public long getContentLength() {
        return LENGTH_UNKNOWN;
    }

    public boolean endOfStream() {
        return false;
    }


    int seqNo = 0;
    double freq = 2.0;
    public void setAudioData(Buffer buffer){
        audioBuffer=buffer;
        }

    public Format getFormat() {
            return audioFormat;
    }

    public void read(Buffer buffer) {
            System.out.println("the important method " + bufdata.size());
            if(bufdata.size()>1){
        synchronized (this) {
        try{	System.out.println("\u00B6\u00C1\u00CA\u00FD\u00BE\u00DDread()");
//	    Object outdata = buffer.getData();
//	    if (outdata == null || !(outdata.getClass() == Format.byteArray) ||
//		((byte[])outdata).length < maxDataLength) {
//		outdata = new byte[maxDataLength];
//		buffer.setData(outdata);
//	    }
//
//		buffer.setFormat( audioFormat );
//		buffer.setTimeStamp( 1000000000 / 8 );
//		for (int i = 0; i < 1000; i++) {
//		    ((byte[])outdata)[i] = (byte) (Math.sin(i / freq) * 32);
//		    freq = (freq + 0.01);
//		    if (freq > 10.0)
//			freq = 2.0;
//		}
//
//	    buffer.setSequenceNumber( seqNo );
//	    buffer.setLength(maxDataLength);
//	    buffer.setFlags(0);
//	    buffer.setHeader( null );
//
//	    seqNo++;

        buffer.setData((byte[])(bufdata.firstElement()));
        bufdata.removeElementAt(0);
        System.out.println("bufdata\u00B5\u00C4\u00B4ó\u00D0\u00A1"+bufdata.size());
//        System.out.println("\u00BD\u00D3\u00CA\u00DC\u00B5\u00BD\u00B5\u00C4\u00CA\u00FD\u00BE\u00DD\u00C1÷\u00A3\u00BA");
//        System.out.println(bbyte);
//    	if(bufdata.isEmpty()==false){
//    	buffer.setData(bufdata.elementAt(0));
//    	System.out.println("\u00BD\u00D3\u00CA\u00DC\u00B5\u00BD\u00B5\u00C4\u00CA\u00FD\u00BE\u00DD\u00C1÷\u00A3\u00BA"+(byte[])(bufdata.elementAt(0)));
//    	bufdata.removeElementAt(0);
//	buffer.setFormat(audioFormat);
        buffer.setFormat((AudioFormat)bufFormat.elementAt(0));
        System.out.println("wangsong\u00BD\u00D3\u00CA\u00DC\u00B5\u00BD\u00B5\u00C4\u00CA\u00FD\u00BE\u00DD\u00B8\u00F1\u00CA\u00BD:");
        System.out.println((AudioFormat)bufFormat.elementAt(0));
            System.out.println(audioFormat);
            bufFormat.removeElementAt(0);
            buffer.setSequenceNumber(((Long)(bufSeqnum.elementAt(0))).longValue());
        bufSeqnum.removeElementAt(0);
////    	System.out.println(datavector.elementAt(2));
            buffer.setLength(((Integer)(bufLength.elementAt(0))).intValue());
            bufLength.removeElementAt(0);
//	buffer.setLength(1300);
 //   	buffer.setTimeStamp(((Long)(bufTimestamp.elementAt(0))).longValue());

//
//
            buffer.setTimeStamp(((Long)(bufTimestamp.elementAt(0))).longValue());
        bufTimestamp.removeElementAt(0);
        buffer.setHeader(bufHeader.elementAt(0));
        bufHeader.removeElementAt(0);
////	System.out.println(datavector.elementAt(6));
        buffer.setFlags(((Integer)(bufFlags.elementAt(0))).intValue());
        bufFlags.removeElementAt(0);
//	buffer=(Buffer)bufdata.firstElement();
////	bufdata.removeElementAt(0);
//	System.out.println("have buffer data");
//	buffer.setHeader(null);
//	buffer.setSequenceNumber(seqnum++);
//	seqnum++;
//	       }
        System.out.println("bufdata\u00C0\u00EF\u00C3\u00E6\u00B5\u00C4\u00D4\u00AA\u00CB\u00D8\u00CA\u00FD\u00BE\u00DD\u00B8\u00F6\u00CA\u00FD-1\u00A3\u00BA"+bufdata.size());
        }catch(Exception ee){
                System.out.println("error:"+ee);
                System.out.println(ee.getMessage());  }
        }
    }
    }

    public void setTransferHandler(BufferTransferHandler transferHandler) {
        synchronized (this) {
            this.transferHandler = transferHandler;
            notifyAll();
        }
    }

    void start(boolean started) {
        synchronized ( this ) {
            this.started = started;
            System.out.println("ready to start thread");
            if (started) {
                    System.out.println("\u00BD\u00F8\u00C8\u00EB\u00C5\u00D0\u00B6\u00CF\u00D3\u00EF\u00BE\u00E4");
                thread = new Thread(this);
                thread.start();
                System.out.println("thread started");
            }
            notifyAll();
        }
    }


    public void run() {

        while (started) {
//	    synchronized (this) {
//		while (transferHandler == null && started) {
//		    try {
//			wait(1000);
//		    } catch (InterruptedException ie) {
//		    }
//		} // while
//	    }

            if (started && transferHandler != null) {
                transferHandler.transferData(this);
                try {
                    Thread.currentThread().sleep( 50 );
                } catch (InterruptedException ise) {
                }
            }
        } // while (started)

    } // run

    // Controls
    public void ableread(){
        transferHandler.transferData(this);
        }

    public Object [] getControls() {
        return controls;
    }

    public Object getControl(String controlType) {
       try {
          Class  cls = Class.forName(controlType);
          Object cs[] = getControls();
          for (int i = 0; i < cs.length; i++) {
             if (cls.isInstance(cs[i]))
                return cs[i];
          }
          return null;

       } catch (Exception e) {   // no such controlType or such control
         return null;
       }
    }
 }
 class dataSource extends PushBufferDataSource {

    protected Object [] controls = new Object[0];
    protected boolean started = false;
    protected String contentType = "raw";
    protected boolean connected = false;
    protected Time duration = DURATION_UNKNOWN;
    protected LiveStream [] streams = null;
    protected LiveStream stream = null;

    public dataSource() {
    }

    public String getContentType() {
        if (!connected){
            System.err.println("Error: dataSource not connected");
            return null;
        }
        return contentType;
    }

    public void connect() throws IOException {
         if (connected)
            return;
         connected = true;
    }

    public void disconnect() {
        try {
            if (started)
                stop();
        } catch (IOException e) {}
        connected = false;
    }

    public void start() throws IOException {
        // we need to throw error if connect() has not been called
        if (!connected)
            throw new java.lang.Error("dataSource must be connected before it can be started");
        if (started)
            return;
        started = true;
        stream.start(true);
    }

    public void stop() throws IOException {
        if ((!connected) || (!started))
            return;
        started = false;
        stream.start(false);
    }

    public Object [] getControls() {
        return controls;
    }

    public Object getControl(String controlType) {
       try {
          Class  cls = Class.forName(controlType);
          Object cs[] = getControls();
          for (int i = 0; i < cs.length; i++) {
             if (cls.isInstance(cs[i]))
                return cs[i];
          }
          return null;

       } catch (Exception e) {   // no such controlType or such control
         return null;
       }
    }

    public Time getDuration() {
        return duration;
    }

    public PushBufferStream [] getStreams() {
        if (streams == null) {
            streams = new LiveStream[1];
            stream = streams[0] = new LiveStream();
        }
        return streams;
    }

}


}
*/