接続サーバー(Java) - クライアント(Android)でリアルタイムにオーディオループを作ろうとしています。サーバー（PC/Java）クライアントはクライアント（モバイル/Android）にデータを送信して返します。
明確にするためにコードを入れます： -サーバー
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* This class implements a TCP Server.<p>
*/
public class GTCPServer {
public static final int SERVER_PORT = 4444; // Port number
private boolean running = true; // Boolean to control stream
private ServerSocket serverSocket;
// Input-Output streams:
private DataInputStream dis;
private DataOutputStream dos;
// Buffer:
private byte[] bytes;
private static final int BUFFER_SIZE = 512 * 4; // Size
/**
* Constructor. Starts Server.
*/
public GTCPServer() {
bytes = new byte[BUFFER_SIZE]; // Create buffer
// Put values to test:
bytes[0] = 3;
bytes[BUFFER_SIZE - 1] = 7;
try {
// Create Server Socket and wait connections.
serverSocket = new ServerSocket(SERVER_PORT);
System.out.println("Conecting...");
// Within accept methode we are waiting connection.
// When it's ready, create Client Socket:
Socket client = serverSocket.accept();
System.out.println("Receiving...");
try {
// Streams:
dis = new DataInputStream(client.getInputStream());
dos = new DataOutputStream(client.getOutputStream());
} catch (Exception e) {
System.out.println("Error.");
e.printStackTrace();
}
} catch (Exception e) {
System.out.println("Error.");
e.printStackTrace();
}
} // GTCPServer()
/**
* Send (write) a byte[] buffer within TCP.
* @param buffer - Data.
* @param offset - Position.
* @param count - Number of bytes to write.
*/
public void write(byte[] buffer, int offset, int count) {
try {
dos.write(buffer, offset, count); // Write
} catch (IOException e) {
e.printStackTrace();
}
} // write()
} // GTCPServer
クライアント:
import android.util.Log; import java.io.*; import java.net.InetAddress; import java.net.Socket; import com.appacoustic.java.g.G; public class GTCPClient_A { public static final String SERVER_IP = "192.168.1.101"; // Server IP (PC) public static final int SERVER_PORT = 4444; // Port number private boolean running = true; // Boolean to control stream // Input-output streams: private DataInputStream dis; private DataOutputStream dos; // Buffer: private byte[] bytes; private static final int BUFFER_SIZE = 512 * 4; // Size /** * Constructor. */ public GTCPClient_A() { bytes = new byte[BUFFER_SIZE]; // Create buffer } // GTCPClient_A() /** * Execute Thread. It isn't override because we are using a subclass (connectTask) wich extends AsyncTask. */ public void run() { try { // Get InetAddress (IPv4 Server) InetAddress serverAddr = InetAddress.getByName(SERVER_IP); Log.e("GTCPClient_A", "Conecting..."); // Create a Socket ti connect with Server: Socket socket = new Socket(serverAddr, SERVER_PORT); try { dis = new DataInputStream(socket.getInputStream()); dos = new DataOutputStream(socket.getOutputStream()); int lap = 0; // Para llevar la cuenta de las vueltas while (running) { dis.read(bytes); // Leemos por TCP System.out.println("IN_ini_["+lap+"]: "+bytes[0]); System.out.println("IN_fin_["+lap+"]: "+bytes[BUFFER_SIZE - 1]); G.toc = System.currentTimeMillis(); G.ticToc(); G.tic = G.toc; dos.write(bytes); // Escribimos por TCP System.out.println("OUT_ini_["+lap+"]: "+bytes[0]); System.out.println("OUT_fin_["+lap+"]: "+bytes[BUFFER_SIZE - 1]); lap++; } } catch (Exception e) { Log.e("GTCP", "SERVIDOR: Error", e); } finally { socket.close(); } } catch (Exception e) { Log.e("GTCP", "CLIENTE: Error", e); } } // run() } // GTCPClient_A
Bluetooth と TCP 経由でプログラムしましたが、良い結果が得られませんでした。遅延が長すぎます (約 5 秒)。私の驚きは、クライアントを Android ではなく Java にデプロイしようとしてもうまくいくことでした (コードはほとんど同じです)。実際、サーバーがあるコンピューターからマイクに向かって話します (JASIOHost ASIO ドライバーをスケジュールしました)。TCP データは同じ WiFi 内の別のコンピューターに移動し、サーバー コンピューターでリアルタイムの完全なスピーカーを返します。
したがって、問題はAndroidの何かにあるようです。しかし、私が望むのは、スマートフォンまたはタブレットをクライアントとして使用することです。
クライアントでもこの行でテストしました： android.os.Process.setThreadPriority(android.os.Process.THREAD_PRIORITY_URGENT_AUDIO); // 優先順位
解決策を試して失敗した摩耗月を見つけます...