Передача звука по сети

package jAudioTransmitter;
 
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;
 
import javax.sound.sampled.AudioFormat;
import javax.sound.sampled.AudioSystem;
import javax.sound.sampled.DataLine;
import javax.sound.sampled.LineUnavailableException;
import javax.sound.sampled.TargetDataLine;
 
public class Main {
    static List<Sender> senderList = new ArrayList<Sender>();
    static MicrophoneReader mr;
    static volatile Integer sendersCreated = 0;
    static volatile Integer numBytesRead;
    static volatile Integer senderNotReady = 0;
    static volatile byte[] data;
    static final Object monitor = new Object();
    
    public static void main(String[] args) {
        try {
            mr = new MicrophoneReader();
            mr.start();
            
            ServerSocket ss = new ServerSocket(7373);
            
            Scanner sc = new Scanner(System.in);
            
            //while (!sc.next().equals("quit")) {
            while (true) {
                Socket s = ss.accept();
                
                Sender sndr = new Sender(s);
                senderList.add(sndr);
                sndr.start();
            }
            
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            mr.setFinishFlag();
            for (Sender sndr: senderList) {
                sndr.setFinishFlag();
            }
        }
    }
 
    static class Sender extends Thread {
        Socket s;
        volatile boolean finishFlag;
        int position;
        int senderNumber;
    
        public Sender(Socket s) {
            this.s = s;
            finishFlag = false;
            System.out.print("Sender started: #");
            senderNumber = ++sendersCreated;
            System.out.println(senderNumber);
        }
        
        public void setFinishFlag() {
            finishFlag = true;
        }
        
        public void run() {
            try {
                OutputStream os = s.getOutputStream();
                
                while (!finishFlag) {
                    synchronized (monitor) {
                        senderNotReady++;
                    
                        monitor.wait();
                        
                        os.write(data, 0, numBytesRead);
                        os.flush();
                
                        senderNotReady--;
                    }
                    System.out.print("Sender #");
                    System.out.print(senderNumber);
                    System.out.print(": ");
                    System.out.print(numBytesRead);
                    System.out.println(" bytes sent");
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
    
    static class MicrophoneReader extends Thread {
        volatile boolean finishFlag;
        
        AudioFormat format = new AudioFormat(16000.0f, 16, 2, true, false);
        //AudioFormat format = new AudioFormat(8000.0f, 8, 1, true, false);
        int CHUNK_SIZE = 10240;
        TargetDataLine microphone;
        
        public MicrophoneReader() {
            finishFlag = false;
            System.out.println("Microphone reader started");
        }
 
        public void setFinishFlag() {
            finishFlag = true;
        }
        
        public void run() {
            try {
                microphone = AudioSystem.getTargetDataLine(format);
                
                DataLine.Info info = new DataLine.Info(TargetDataLine.class, format);
                microphone = (TargetDataLine) AudioSystem.getLine(info);
                microphone.open(format);
                
                
                data = new byte[CHUNK_SIZE];
                microphone.start();
                                
                while (!finishFlag) {
                    synchronized (monitor) {
                        if (senderNotReady==sendersCreated) {
                            monitor.notifyAll();
                            continue;
                        }
                        
                        numBytesRead = microphone.read(data, 0, CHUNK_SIZE);    
                    }
 
                    System.out.print("Microphone reader: ");
                    System.out.print(numBytesRead);
                    System.out.println(" bytes read");
                }
            } catch (LineUnavailableException e) {
                e.printStackTrace();
            }
        }
    }
}

package jAudioReceiver;
 
import java.io.InputStream;
import java.net.InetAddress;
import java.net.Socket;
 
import javax.sound.sampled.AudioFormat;
import javax.sound.sampled.AudioSystem;
import javax.sound.sampled.DataLine;
import javax.sound.sampled.SourceDataLine;
 
public class Main {
 
    public static void main(String[] args) {
        String host = "localhost";
        
        if (args.length>0) {
            host = args[0];
        }
        
        AudioFormat format = new AudioFormat(16000.0f, 16, 2, true, false);
        //AudioFormat format = new AudioFormat(8000.0f, 8, 1, true, false);
        SourceDataLine speakers;
        
        try {
            InetAddress ipAddr = InetAddress.getByName(host);
        
            Socket s = new Socket(ipAddr, 7373);
            InputStream is = s.getInputStream();
            
            DataLine.Info dataLineInfo = new DataLine.Info(SourceDataLine.class, format);
            speakers = (SourceDataLine) AudioSystem.getLine(dataLineInfo);
            speakers.open(format);
            speakers.start();
            
            int numBytesRead;
            
            byte[] data = new byte[204800];
            
            while (true) {
                numBytesRead = is.read(data);
                speakers.write(data, 0, numBytesRead);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}