Android（Java）中MediaRecorder的LocalSocket（Unix域）客户端 – 服务器数据流问题

我没有得到的是Unix域套接字之间的数据流。

我理解Unix Domain Socket的数据流是

LocalSocket client .connect() – > LocalServerSocket server .accept()

客户端将数据发送到服务器，直到我理解。

然而，对于来自Android的MediaRecorder的流式video/音频，经过大量研究后，我看到每个使用LocalSocket代替MediaRecorder文件的例子原则如下：

https://static.foxdogstudios.com/static/presentations/keeping-it-real-time.html#/9

 LocalServerSocket server = new LocalServerSocket("some name"); receiver = new LocalSocket(); receiver.connect(server.getLocalSocketAddress()); LocalSocket sender = server.accept();//LocalSocket not LocalServerSocket as in Source link // ... // Give the MediaRecorder our fake file recorder.setOutputFile(sender.getFileDescriptor()); 

此代码如下所示：

MediaRecorder – > LocalSocket sender – >

LocalServerSocket server .accept() – > LocalSocket receiver .connect()

到底是怎么回事？？

显然，套接字数据以相反的方向流动，因此，我不明白为什么这段代码按预期工作。

请你劝告。 谢谢。

Answer 1

看来，基本上，我的想法是正确的。 我见过的例子，至少是发送者 – 接收者结构是错误的。

这是我制作的更简单的模型：

 package com.example.app; import android.app.Activity; import android.media.MediaRecorder; import android.net.LocalServerSocket; import android.net.LocalSocket; import android.net.LocalSocketAddress; import android.os.Bundle; import java.io.IOException; public class MainActivity extends Activity { private final String SOCKET_ADDRESS = "socket1"; private MediaRecorder mRecorder = new MediaRecorder(); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); class IOThread extends Thread { @Override public void run() { System.out.println("--------IO Thread------ "); LocalSocket receiver; LocalServerSocket server; try { server = new LocalServerSocket(SOCKET_ADDRESS); localServerCreated(); receiver = server.accept(); System.out.println("---------server.accept();------------- "); int ret = 0; while ((ret = receiver.getInputStream().read()) != -1) { System.out.println( "ret =" + ret); } System.out.println("ret =" + ret); } catch (IOException e) { } } } IOThread io1 = new IOThread(); io1.start(); } private void localServerCreated() { LocalSocket sender; try { sender = new LocalSocket(); sender.connect(new LocalSocketAddress(SOCKET_ADDRESS)); mRecorder.setAudioSource(MediaRecorder.AudioSource.MIC); mRecorder.setOutputFormat(MediaRecorder.OutputFormat.AAC_ADTS); mRecorder.setAudioEncoder(MediaRecorder.AudioEncoder.AAC); mRecorder.setOutputFile(sender.getFileDescriptor()); } catch (IOException e) { e.printStackTrace(); } System.out.println("------mRecorder configured--------"); try { mRecorder.prepare(); mRecorder.start(); System.out.println("------mRecorder.start()--------"); } catch (IllegalStateException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }