Форум РадиоКот

Код: Выделить всё

import pyaudio
import socket
from threading import Thread

frames = []

def udpStream(CHUNK):

    udp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    udp.bind(("192.168.0.124", 4210))

    while True:
        soundData, addr = udp.recvfrom(CHUNK)
        frames.append(soundData)

    udp.close()

def play(stream, CHUNK):
    BUFFER = 10
    while True:
            if len(frames) == BUFFER:
                while True:
                    stream.write(frames.pop(0))

if __name__ == "__main__":
    FORMAT = pyaudio.paInt8
    CHUNK = 1024
    CHANNELS = 1
    RATE = 8000

    p = pyaudio.PyAudio()

    stream = p.open(format=FORMAT,
                    channels = CHANNELS,
                    rate = RATE,
                    output = True,
                    frames_per_buffer = CHUNK,
                    )

    Ts = Thread(target = udpStream, args=(CHUNK,))
    Tp = Thread(target = play, args=(stream, CHUNK,))
    Ts.setDaemon=True
    Tp.setDaemon=True
    Ts.start()
    Tp.start()
    Ts.join()
    Tp.join()

Код: Выделить всё

void loop()
{
  Udp.beginPacket("192.168.0.124", 4210);

  for(int i=0; i<1024;i++){
    int old=micros();

    float analog = analogRead(A0);
    if (analog > 255) {
      analog = 255;
    }
    else if (analog < 0){
      analog = 0;
    }
    Udp.write(int(analog));
   // Serial.print(int(analog));
   // Serial.print(",");
    while(micros()-old<125); // 90uSec = 1Sec/11111Hz - 3uSec para los otros procesos
  }
  //Serial.print(";;;;;");
  Udp.endPacket();
  delay(5);
}

Код: Выделить всё

public void RecvAudio()

{
    Thread thrd = new Thread(new Runnable() {
		@Override
        public void run() 
        {
            Log.e(LOG_TAG, "start2 recv thread, thread id: "
                + Thread.currentThread().getId());
    
            AudioTrack track = new AudioTrack(AudioManager.STREAM_MUSIC, 
                    SAMPLE_RATE, AudioFormat.CHANNEL_OUT_MONO, 
                    AudioFormat.ENCODING_PCM_8BIT, BUF_SIZE, 
                    AudioTrack.MODE_STREAM);
            track.play();
            DatagramSocket sock = null;
    

            try
            {
                sock = new DatagramSocket(AUDIO_PORT);
                byte[] buf = new byte[BUF_SIZE];
    
                while(Server_aktiv)
                {
                    DatagramPacket pack = new DatagramPacket(buf, BUF_SIZE);
                    sock.receive(pack);
                    Log.d(LOG_TAG, "recv pack: " + pack.getLength());
                    buf=pack.getData();
                    //track.write(pack.getData(), 0, pack.getLength());
                  track.write(buf, 0, buf.length);
                }
            }
            catch (SocketException se)
            {
                Log.e(LOG_TAG, "SocketException: " + se.toString());
            }
            catch (IOException ie)
            {
                Log.e(LOG_TAG, "IOException" + ie.toString());
            }
            
            finally 
            {
              if (sock != null) 
              {
            	  sock.close();
            		 Toast toast = Toast.makeText(getApplicationContext(), 
  						   "Сервер UDP остановлен. Пора покормить кота!", Toast.LENGTH_SHORT); 
  						toast.show(); 
              }
            }
        } // end run
    });
    thrd.start();
}

Код: Выделить всё

            
AudioTrack track = new AudioTrack(AudioManager.STREAM_MUSIC,
SAMPLE_RATE, AudioFormat.CHANNEL_OUT_MONO,
AudioFormat.ENCODING_PCM_8BIT, BUF_SIZE,
AudioTrack.MODE_STREAM);
track.play();


track.write(buf, 0, buf.length);

Код: Выделить всё

            try
            {
                sock = new DatagramSocket(AUDIO_PORT);
                byte[] buf = new byte[BUF_SIZE];
   
                while(Server_aktiv)
                {
                    DatagramPacket pack = new DatagramPacket(buf, BUF_SIZE);
                    sock.receive(pack);
                    Log.d(LOG_TAG, "recv pack: " + pack.getLength());
                    buf=pack.getData();
                    //track.write(pack.getData(), 0, pack.getLength());
                  track.write(buf, 0, buf.length);
                }
            }

Код: Выделить всё

            try
            {
                sock = new DatagramSocket(AUDIO_PORT);
                byte[] buf = new byte[BUF_SIZE];
                DatagramPacket pack = new DatagramPacket(buf, buf.length);
 
                while(Server_aktiv)
                {
                    sock.receive(pack);
                    //Log.d(LOG_TAG, "recv pack: " + pack.getAddress(); // IP String
                    //Log.d(LOG_TAG, "recv pack: " + pack.getPort();       // port int
                    Log.d(LOG_TAG, "recv pack: " + pack.getLength());    // len int
                    
                    //buf=pack.getData();
                    //track.write(pack.getData(), 0, pack.getLength());
                   track.write(buf, 0, buf.length);
                }
            }

Код: Выделить всё

            int buffersize = AudioRecord.getMinBufferSize(11025,
                    AudioFormat.CHANNEL_CONFIGURATION_MONO,
                    AudioFormat.ENCODING_PCM_16BIT);

           AudioRecord arec = new AudioRecord(
                    MediaRecorder.AudioSource.MIC, 11025,
                    AudioFormat.CHANNEL_CONFIGURATION_MONO,
                    AudioFormat.ENCODING_PCM_16BIT, buffersize);

            byte[] buffer = new byte[buffersize];
            arec.startRecording();
         //arec.read(buffer, 0, buffersize);

Код: Выделить всё

            int buffersize = AudioRecord.getMinBufferSize(11025,
                    AudioFormat.CHANNEL_CONFIGURATION_MONO,
                    AudioFormat.ENCODING_PCM_16BIT);

            AudioTrack aTrack = new AudioTrack(
                    AudioManager.STREAM_VOICE_CALL, 11025,
                    AudioFormat.CHANNEL_CONFIGURATION_MONO,
                    AudioFormat.ENCODING_PCM_16BIT, buffersize,
                    AudioTrack.MODE_STREAM);
           
                    byte[] buffer = new byte[buffersize];
                   
                    aTrack.write(buffer, 0, buffer.length);