本地方法中printf如何傳給java--java系統(tǒng)級(jí)命名管道

摘自：https://blog.csdn.net/dog250/article/details/6007301?

2010年11月13日 19:24:00閱讀數(shù)：3929

遇到很多人，都想知道在調(diào)試jni的時(shí)候怎么得到c語言printf的輸出，這個(gè)問題其實(shí)有多種解決方法，其中最直觀的就是不用printf，直接定義一個(gè)本地方法，返回一個(gè)jstring，這樣在java需要得到信息的時(shí)候自己去取就可以了，或者通過c操作java虛擬機(jī)的方式，用c代碼得到j(luò)ava對(duì)象，然后調(diào)用其方法把字符串送給java。這兩種方式一種是取一種是送，感覺都少不了兩者的直接參與，如果能實(shí)現(xiàn)一個(gè)管道，那就好了！
???? java好像不支持命名管道，這樣java的管道類就只能在同一個(gè)java虛擬機(jī)實(shí)例中實(shí)現(xiàn)線程間通信，并且這種管道不是系統(tǒng)級(jí)別的，它只是jvm中的，除非使用套接字。既然java沒有內(nèi)置的命名管道，能否自己定義一個(gè)呢？有了它就可以實(shí)現(xiàn)跨虛擬機(jī)實(shí)例的java線程間通信了，并且還可以和c/c++等本地語言編寫的進(jìn)程進(jìn)行通信。實(shí)際上，此問題就是這樣被引出的，java通過jni調(diào)用了c程序，然而c的printf卻無法被java捕獲，除非使用文件或者套接字等重定向方案，然而如果系統(tǒng)級(jí)管道可用的話，那就再好不過了，這里不需要命名的管道，匿名的就可以，因?yàn)閷?shí)現(xiàn)jni的動(dòng)態(tài)庫和java程序是在一個(gè)jvm實(shí)例中的，因此在一個(gè)進(jìn)程空間內(nèi)，因此動(dòng)態(tài)庫中的printf重定向到該管道即可，要想使用原生的系統(tǒng)級(jí)管道，必然需要拿到一個(gè)文件的描述符，查遍了java的API。發(fā)現(xiàn)有一個(gè)FileDescriptor類可用，看了它的java源碼，貌似它有一個(gè)fd字段，該字段不可設(shè)置，是private的，而且它還有一個(gè)standardStream私有方法，可以傳入一個(gè)fd描述符：
public final class FileDescriptor {
???? private int fd;
??? private long handle;
??? public FileDescriptor() {
??? ...
??? }
??? private FileDescriptor(int fd) {
??? this.fd = fd;
??????? handle = -1;
??? }
??? static {
??????? initIDs();
??? }
??? public static final FileDescriptor in = standardStream(0);
??? public static final FileDescriptor out = standardStream(1);
??? public static final FileDescriptor err = standardStream(2);
??? ...
??? private static FileDescriptor standardStream(int fd) {
??????? FileDescriptor desc = new FileDescriptor();
??????? desc.handle = set(fd);
??????? return desc;
??? }
}
這個(gè)FileDescriptor類顯得很完備，但是卻不好用，其實(shí)這是一個(gè)低層的類，java根本不希望有人直接使用它，說實(shí)話它是在File類之下的，不想linux上，文件是個(gè)描述符，windows上文件是個(gè)句柄(二者都是內(nèi)核資源數(shù)組的索引)，在java中，File是一個(gè)對(duì)象，而FileDescriptor是對(duì)應(yīng)于操作系統(tǒng)的“文件描述符”，它是和系統(tǒng)相關(guān)的，而系統(tǒng)相關(guān)的東西，java是不希望用戶直接使用的哦！你能從一個(gè)File對(duì)象中g(shù)etFD，然而卻不能set，也不能通過FileDescriptor構(gòu)造一個(gè)File對(duì)象。
???? 既然該提供的都提供了，那就想辦法設(shè)置它的fd，將之設(shè)置成一個(gè)系統(tǒng)級(jí)管道的fd?，F(xiàn)在問題來了，在哪里創(chuàng)建管道呢？既然java不提供系統(tǒng)級(jí)管道的創(chuàng)建方法并且java的FileDescriptor類的fd還是私有的，那么肯定在本地方法中設(shè)置了，首先展示出了下面的本地方法，創(chuàng)建了管道并且設(shè)置了FileDescriptor的fd字段，本地方法可以完全繞開java虛擬機(jī)的限制，它和jvm是并列的，甚至可以操作jvm本身：
int fdw; //用于后續(xù)的本地方法中的輸出。
JNIEXPORT jobject JNICALL Java_test_pipe_1for_1read (JNIEnv * env, jclass cls)
{
??? jobject fdsc;
??? jclass cls;
??? jmethodID cons_mid;
??????? jfieldID field;
??????? cls = (*env)->FindClass(env, "java/io/FileDescriptor");
??? pipe(fds);
??? fdw = fds[1];
??????? cons_mid = (*env)->GetMethodID(env, cls, "<init>", "()V");
??????? fdsc = (*env)->NewObject(env, cls, cons_mid);
??????? field = (*env)->GetFieldID(env, cls, "fd", "I");
??????? (*env)->SetIntField(env, ret, field, fds[0]);
??????? return fdsc;
}
然后看一下java的調(diào)用：
public class test {
??????? public native void Wrapper_main();
??????? public native static FileDescriptor pipe_for_read();
??????? public FileInputStream in;
??????? static {
??????????????? System.loadLibrary("stunnel");
??????? }
??????? public test() {
??????????????? FileDescriptor? pipe = pipe_for_read();
??????????????? this.in = new FileInputStream(pipe);
??????? }
??????? public static void main(String[] args) throws IOException {
??????????????? final test t = new test();
??????????????? new Thread(){
??????????????????????? public void run(){
??????????????????????????????? t.Wrapper_main();
??????????????????????? }
??????????????? }.start();
??????????????? while (true) {
??????????????????????? System.out.println(t.in.read());
??????????????? }
??? }
}
本地方法Wrapper_main的實(shí)現(xiàn)：
JNIEXPORT void JNICALL Java_test_Wrapper_1main (JNIEnv *env, jobject obj)
{
??? ...
??? write(fdw, buf, 1);
??? ...
}
現(xiàn)在就是fdw如何得到的問題了，可以使用全局變量，但是前提是實(shí)現(xiàn)Wrapper_main的庫必須和pipe_for_read是同一個(gè)，如果不是同一個(gè)，那么只能在進(jìn)程這個(gè)層次上查找對(duì)應(yīng)的文件描述符了--它們畢竟屬于同一個(gè)進(jìn)程，如果再?zèng)]有建立其它管道的話，可以通過/proc/pid/fd目錄下的描述符查找，或者使用system函數(shù)執(zhí)行l(wèi)sof命令來找到它...，另外你可以直接使用dup2系統(tǒng)調(diào)用將stdout重定向到fdw，但是這樣的話你在java中就不能使用System.out了，否則會(huì)循環(huán)的(因?yàn)槟阋呀?jīng)重定向了標(biāo)準(zhǔn)輸出)，不管怎樣都沒有創(chuàng)建一個(gè)命名管道更方便，只要有名字就可以了，不在乎在那個(gè)動(dòng)態(tài)庫中。既然可以在本地方法中創(chuàng)建匿名管道并將fd交給java的FileDscriptor類，那肯定可以創(chuàng)建命名管道，只需要將pipe函數(shù)改為mkfifo和open即可，需要的無非是提供一個(gè)操作系統(tǒng)級(jí)別的文件描述符罷了，并且如果管道名稱如果從java中傳來的話，還需要將jstring轉(zhuǎn)化為char*。
????? 事情做到這一步，再進(jìn)一步就是為java封裝一個(gè)命名/匿名管道的類了，這樣便于以后使用，這難免要寫本地方法，但是對(duì)于每一個(gè)平臺(tái)寫一個(gè)本地庫就可以了，以后可以直接使用這個(gè)封裝好的java管道類，一勞永逸！這個(gè)管道不是java自帶的管道，它可是系統(tǒng)級(jí)別的管道哦：
1.編寫NamedPipeStream.java，封裝一個(gè)NamedPipeStream類，用于支持命名/匿名管道，這里沒有使用包：
import java.io.*;
public class NamedPipeStream {
??????? public native static FileDescriptor[] get_named(String name);
??????? public native static FileDescriptor[] get_anony();
??????? private FileInputStream in;
??????? private FileOutputStream out;
??????? static {
??????????????? System.loadLibrary("pipe");
??????? }
??????? public NamedPipeStream(String name) {?
??????????????? FileDescriptor fd[];
??????????????? if (name != null)
??????????????????????? fd = get_named(name);
??????????????? else
??????????????????????? fd = get_anony();
??????????????? this.in = new FileInputStream(fd[0]);
??????????????? this.out = new FileOutputStream(fd[1]);
??????? }
??????? public NamedPipeStream() {
??????????????? this(null);
??????? }?
??????? public int read()throws Exception {
??????????????? return this.in.read();
??????? }
??????? public int read(byte[] b)throws Exception? {
??????????????? return this.in.read(b);?
??????? }
??????? public int read(byte[] b, int off, int len)throws Exception {
??????????????? return this.in.read(b, off, len);
??????? }

??????? public void write(int b)throws Exception {
??????????????? this.out.write(b);
??????? }
??????? public void write(byte[] b)throws Exception? {
??????????????? this.out.write(b);?
??????? }
??????? public void write(byte[] b, int off, int len)throws Exception {
??????????????? this.out.write(b, off, len);
??????? }
}
2.編寫pipe.c的實(shí)現(xiàn)文件，用于創(chuàng)建管道并且返回java的FileDescriptor對(duì)象：
#include <jni.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
char* convert(JNIEnv* env, jstring str)
{
?????? ...
}?
JNIEXPORT jobjectArray JNICALL Java_InputNamedPipeStream_get_1named (JNIEnv *env, jclass cls, jstring str)
{
??????? jfieldID field_fd;
??????? jmethodID const_fdesc;
??????? jclass class_fdesc, class_ioex;
??????? jobject ret[2];
??????? int fds[2];
??????? //這里需要想辦法導(dǎo)出兩個(gè)描述符，否則就需要全局變量了
??????? if (str) { //創(chuàng)建命名管道
??????????????? char name = convert(env, str); //將jstring轉(zhuǎn)為char*
??????????????? /*
??????????????????????? 1.mkfifo(name, ...);
??????????????????????? 2.open出一個(gè)寫的為fds[1];
??????????????????????? 3.open出一個(gè)讀的為fds[0];
??????????????? */
??????? } else {? //創(chuàng)建匿名管道
??????????????? int rv = pipe(fds);
??????? }
??????? class_ioex = (*env)->FindClass(env, "java/io/IOException");
??????? class_fdesc = (*env)->FindClass(env, "java/io/FileDescriptor");
??????? const_fdesc = (*env)->GetMethodID(env, class_fdesc, "<init>", "()V");
??????? ret[0] = (*env)->NewObject(env, class_fdesc, const_fdesc);
??????? ret[1] = (*env)->NewObject(env, class_fdesc, const_fdesc);
??????? field_fd = (*env)->GetFieldID(env, class_fdesc, "fd", "I");
??????? //(*env)->SetIntField(env, ret, field_fd, [根據(jù)讀或者寫將fds的不同元素置于此]);
??????? (*env)->SetIntField(env, ret[0], field_fd, fds[0]);
??????? (*env)->SetIntField(env, ret[0], field_fd, fds[1]);
??????? return ret;
}
JNIEXPORT jobjectArray JNICALL Java_InputNamedPipeStream_get_1anony (JNIEnv *env, jclass cls)
{
??????? return Java_InputNamedPipeStream_get_1named(env, cls, NULL);
}
3.使用NamedPipeStream類(略)。
PS：java的初衷在于讓你避開系統(tǒng)，可以避開系統(tǒng)直接處理業(yè)務(wù)，可是我卻一而再再而三的使用java來接近系統(tǒng)底層，這是一種十分愚蠢的返祖行為！

轉(zhuǎn)載于:https://www.cnblogs.com/LiuYanYGZ/p/9371047.html

總結(jié)

以上是生活随笔為你收集整理的本地方法中printf如何传给java--java系统级命名管道的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。