我正在 SGS2 api v.16 上开发
我有两个应用程序：本机和 Java
从本机应用程序中，我使用 mkfifo() 函数打开一个 Unix 管道并向其写入一些字符串。
在 java 应用程序中，我试图读取字符串，但不知何故，应用程序阻塞了，我不知道为什么，logcat 中没有指示它阻塞的原因。
这两个应用程序在清单中有 android:sharedUserId="my.Id" ，并且共享肯定有效。
在 logcat 中，我可以看到“打开输入流”日志，但之后没有日志。有没有推荐的方法从 Java 中的管道文件中读取？ 注意：如果我用 open(...) 打开一个常规文件而不是使用 mkfifo(...) 我成功地从文件中读取，问题只是当我用 mkfifo() 打开一个管道文件时
这是从本机应用程序运行的函数：
jint Java_com_example_ndkfoo_NdkFooActivity_writeToPipe(JNIEnv* env, jobject javaThis) {
const char* PATH = "/data/data/com.example.ndkfoo/v_pipe8";
char* line = "Hello Pipe!";
int pipe;
errno = 0;
// open a named pipe
mode_t mode = S_IRWXU | S_IRWXG | S_IRWXO;
pipe = mkfifo(PATH, mode);
if(errno != 0) {
__android_log_write(ANDROID_LOG_ERROR, "NDK_FOO_TAG", strerror(errno));
return errno;
}
__android_log_write(ANDROID_LOG_DEBUG, "NDK_FOO_TAG", "file opened successfully");
// actually write out the data and close the pipe
int err = write(pipe, line, strlen(line));
// close the pipe
close(pipe);
return err;
}
这是尝试从管道读取的java
package com.example.secondparty;
import java.io.FileDescriptor;
import java.io.FileInputStream;
import android.os.Bundle;
import android.app.Activity;
import android.util.Log;
import android.view.Menu;
public class MainActivity extends Activity {
private static final String TAG = MainActivity.class.getSimpleName();
//public final static String PATH2 = "/sdcard/fifo9001";
public final static String PATH = "/data/data/com.example.ndkfoo/v_pipe8";
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
readFromPipe();
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
getMenuInflater().inflate(R.menu.main, menu);
return true;
}
private void readFromPipe() {
Log.i(TAG, "Attempt started");
FileInputStream fis;
String message = "";
byte buffer[] = new byte[256];
try {
Log.i(TAG, "openning input stream");
fis = new FileInputStream(PATH);
Log.i(TAG, "input stream opened");
FileDescriptor fd = fis.getFD();
int len = 0;
do {
len = fis.read(buffer);
if(len > 0) {
String newmessage = new String(buffer,0, len, "US-ASCII");
message += newmessage;
}
} while (len == buffer.length);
Log.i(TAG, "message: "+message);
fis.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}