Трансляция звука

[vlad1280]

Возникла проблема, нужно передать звук с микрофона на сервере всем клиентам, сделать своего рода радио.
Как выглядит само получение массива байтов с микрофона и последующее его прочтение с воспроизведением ?

Пробовал написать, но не работает ничего. Вот код работающий без передачи.

  
System.out.println("Прослушивание приёма звука с микрофона");
DataLine.Info micInfo = new DataLine.Info(TargetDataLine.class, format);
TargetDataLine mic = (TargetDataLine) AudioSystem.getLine(micInfo);
mic.open(format);
byte tmpBuff[] = new byte[1024*format.getFrameSize()];
mic.start();
while(outVoice) {
  int count = mic.read(tmpBuff,0,tmpBuff.length);
  if (count > 0) baos.write(tmpBuff, 0, count);
}
mic.drain();
mic.close();
System.out.println("Стоп");

//код метода для задания формата
private AudioFormat getAudioFormat() {
    float sampleRate = 44100.0F;
    int sampleSizeBits = 16;
    int channels = 2;
    boolean signed = true;
    boolean bigEndian = false;
    return (new AudioFormat(sampleRate, sampleSizeBits, channels, signed, bigEndian));
}

System.out.println("Прослушивание передачи звука");
DataLine.Info speakerInfo = new DataLine.Info(SourceDataLine.class, format);
SourceDataLine speaker = (SourceDataLine) AudioSystem.getLine(speakerInfo);
speaker.open(format);
speaker.start();
while(inVoice) { 
  byte[] data = baos.toByteArray();
  baos.reset();
  ByteArrayInputStream bais = new ByteArrayInputStream(data);
  AudioInputStream ais = new AudioInputStream(bais,format,data.length);
  int numBytesRead = format.getFrameSize()*1024;
  if ((numBytesRead = ais.read(data)) != -1) speaker.write(data, 0, numBytesRead);
  ais.close();
  bais.close();
}
  speaker.drain();
  speaker.close();
  System.out.println("Стоп");

Коды после того как сделал передачу с сервера клиентам:
Клиент

...
ObjectOutputStream oos = new ObjectOutputStream(client.getOutputStream());
ObjectInputStream ois = new ObjectInputStream(client.getInputStream());
            
DataLine.Info speakerInfo = new DataLine.Info(SourceDataLine.class, format);
SourceDataLine speaker = (SourceDataLine) AudioSystem.getLine(speakerInfo);
speaker.open(format);
speaker.start();
while(inVoice) { 
  byte[] data = baos.toByteArray();
  ByteArrayInputStream bais = new ByteArrayInputStream(data);
                
  AudioInputStream ais = new AudioInputStream(bais,format,data.length);
  int numBytesRead = format.getFrameSize()*1024;
  if ((numBytesRead = ois.read(data)) != -1) 
    speaker.write(data, 0, numBytesRead);
  ais.close();
  bais.close();
}
speaker.drain();
speaker.close();
System.out.println("Стоп");
ois.close();
oos.close();

Сервер:

ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
	   
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());

System.out.println("Прослушивание приёма звука");
DataLine.Info micInfo = new DataLine.Info(TargetDataLine.class, format);
TargetDataLine mic = (TargetDataLine) AudioSystem.getLine(micInfo);
mic.open(format);

byte tmpBuff[] = new byte[1024*format.getFrameSize()];
mic.start();
while(outVoice) {
  int count = mic.read(tmpBuff,0,tmpBuff.length);
  if (count > 0) oos.write(tmpBuff, 0, count);
}

mic.drain();
mic.close();
ois.close();
oos.close();
socket.close();

[vlad1280]

Всё исправил, работает, было пару тупейших ошибок.

[surkis]

сам задал вопрос, сам ответил )))