【问题标题】:How to pass a Java string array []String to Go via cgo/JNA如何通过 cgo/JNA 将 Java 字符串数组 []String 传递给 Go
【发布时间】:2021-09-28 14:12:36
【问题描述】:

我想通过 JNA 将 Java 中的 String[] 传递给我的 Go 函数。

我的 go 函数具有以下签名:

func PredicateEval(keys, values []string, expression string) *C.char

我已将链接模式的 go 库编译为“c-shared”。我在 java 中有一个 GoString 定义为:

package predicates;
import com.ochafik.lang.jnaerator.runtime.NativeSize;
import com.sun.jna.Pointer;
import com.sun.jna.Structure;
import java.util.Arrays;
import java.util.List;
/**
 * <i>native declaration : coverage_server/predicate_jvm_bridge/lib/libtest.h</i><br>
 * This file was autogenerated by <a href="http://jnaerator.googlecode.com/">JNAerator</a>,<br>
 * a tool written by <a href="http://ochafik.com/">Olivier Chafik</a> that <a href="http://code.google.com/p/jnaerator/wiki/CreditsAndLicense">uses a few opensource projects.</a>.<br>
 * For help, please visit <a href="http://nativelibs4java.googlecode.com/">NativeLibs4Java</a> , <a href="http://rococoa.dev.java.net/">Rococoa</a>, or <a href="http://jna.dev.java.net/">JNA</a>.
 */
public class _GoString_ extends Structure {
    /** C type : const char* */
    public Pointer p;
    public NativeSize n;
    public _GoString_() {
        super();
    }
    protected List<String> getFieldOrder() {
        return Arrays.asList("p", "n");
    }
    /** @param p C type : const char* */
    public _GoString_(Pointer p, NativeSize n) {
        super();
        this.p = p;
        this.n = n;
    }
    public static class ByReference extends _GoString_ implements Structure.ByReference {
        
    };
    public static class ByValue extends _GoString_ implements Structure.ByValue {
        
    };
}

我还有一个 Go 切片定义为:

package predicates;
import com.sun.jna.Pointer;
import com.sun.jna.Structure;
import java.util.Arrays;
import java.util.List;
/**
 * <i>native declaration : coverage_server/predicate_jvm_bridge/lib/libtest.h</i><br>
 * This file was autogenerated by <a href="http://jnaerator.googlecode.com/">JNAerator</a>,<br>
 * a tool written by <a href="http://ochafik.com/">Olivier Chafik</a> that <a href="http://code.google.com/p/jnaerator/wiki/CreditsAndLicense">uses a few opensource projects.</a>.<br>
 * For help, please visit <a href="http://nativelibs4java.googlecode.com/">NativeLibs4Java</a> , <a href="http://rococoa.dev.java.net/">Rococoa</a>, or <a href="http://jna.dev.java.net/">JNA</a>.
 */
public class GoSlice extends Structure {
    /** C type : void* */
    public Pointer data;
    /** C type : GoInt */
    public long len;
    /** C type : GoInt */
    public long cap;
    public GoSlice() {
        super();
    }
    protected List<String> getFieldOrder() {
        return Arrays.asList("data", "len", "cap");
    }
    /**
     * @param data C type : void*<br>
     * @param len C type : GoInt<br>
     * @param cap C type : GoInt
     */
    public GoSlice(Pointer data, long len, long cap) {
        super();
        this.data = data;
        this.len = len;
        this.cap = cap;
    }
    public static class ByReference extends GoSlice implements Structure.ByReference {
        
    };
    public static class ByValue extends GoSlice implements Structure.ByValue {
        
    };
}

这是我尝试将 Java []String 转换为 Go string[]。

  static {
    try {
      Field field = sun.misc.Unsafe.class.getDeclaredField("theUnsafe");
      field.setAccessible(true);
      unsafe = (sun.misc.Unsafe) field.get(null);
      Class<?> clazz = ByteBuffer.allocateDirect(0).getClass();
      DIRECT_BYTE_BUFFER_ADDRESS_OFFSET = unsafe.objectFieldOffset(Buffer.class.getDeclaredField("address"));
      DIRECT_BYTE_BUFFER_CLASS = clazz;
    } catch (Exception e) {
      throw new AssertionError(e);
    }
  }

  private static long getAddress(ByteBuffer buffer) {
    assert buffer.getClass() == DIRECT_BYTE_BUFFER_CLASS;
    return unsafe.getLong(buffer, DIRECT_BYTE_BUFFER_ADDRESS_OFFSET);
  }

  public static _GoString_.ByValue JavaStringToGo(String jstr) {
    try {
      byte[] bytes = jstr.getBytes("utf-8");
      //ByteBuffer bb = ByteBuffer.wrap(bytes);
      ByteBuffer bb = ByteBuffer.allocateDirect(bytes.length);
      bb.put(bytes);
      Pointer p = new Pointer(getAddress(bb));
      _GoString_.ByValue value = new _GoString_.ByValue();

      value.n = new NativeSize(bytes.length);
      value.p = p;
      return value;
    } catch (UnsupportedEncodingException e) {
      throw new RuntimeException(e);
    }
  }
  
  public static GoSlice.ByValue JavaStringArrayToGoStringSlice(String[] strings) {
    _GoString_.ByValue[] goStrings = new _GoString_.ByValue[strings.length];
    for (int i = 0; i < strings.length; i++) {
      goStrings[i] = JavaStringToGo(strings[i]);
    }

    Memory arr = new Memory(strings.length * Native.getNativeSize(_GoString_.class));
    for (int i = 0; i < strings.length; i++) {
      System.out.println(Native.getNativeSize(_GoString_.class));
      byte[] bytes = goStrings[0].getPointer().getByteArray(0, Native.getNativeSize(_GoString_.class));
      arr.write(i*Native.getNativeSize(_GoString_.class), bytes, 0, bytes.length);
    }
    GoSlice.ByValue slice = new GoSlice.ByValue();
    slice.data = arr;
    slice.len = strings.length;
    slice.cap = strings.length;

    return slice;
  }

一切都编译了,但是当我尝试访问 Go 端的切片元素时,我得到了一个 seg 错误:

unexpected fault address 0xb01dfacedebac1e
fatal error: fault
[signal SIGSEGV: segmentation violation code=0x1 addr=0xb01dfacedebac1e pc=0x10d7d3d6f]

goroutine 17 [running, locked to thread]:

【问题讨论】:

    标签: java c go jna cgo


    【解决方案1】:

    您正在失去对实际字符串内存分配的跟踪(和控制)。

    _GoString_ 的映射仅包括分配指针(4 或 8 字节)和 NativeSize(4 或 8 字节 size_t)。此映射假定 Pointer 仍然有效:

    public class _GoString_ extends Structure {
        /** C type : const char* */
        public Pointer p;
        public NativeSize n;
        // constructors, etc.
    }
    

    但是,当您将值分配给 p 时,您只会跟踪指针的地址,而不是实际的内存分配(我已将 cmets 添加到您的代码中):

      public static _GoString_.ByValue JavaStringToGo(String jstr) {
        try {
          byte[] bytes = jstr.getBytes("utf-8");
          // 
          // Here you allocate memory for the bytes
          //
          ByteBuffer bb = ByteBuffer.allocateDirect(bytes.length);
          bb.put(bytes);
          // 
          // Here you only keep track of the pointer to the bytes
          //
          Pointer p = new Pointer(getAddress(bb));
          // 
          // You never reference bb again, it is no longer reachable
          // and its allocation can be reclaimed by the system
          //
          _GoString_.ByValue value = new _GoString_.ByValue();
    
          value.n = new NativeSize(bytes.length);
          value.p = p;
          return value;
        } catch (UnsupportedEncodingException e) {
          throw new RuntimeException(e);
        }
      }
    

    作为直接字节缓冲区,内存位置和(取消)分配机制与普通对象和 GC 不同,但基本原则适用于一旦您失去对 Java 对象(ByteBuffer)的引用,您就没有控制何时释放本机内存。 (当bb 被GC'd 时,其内部字段包括在处理时将触发释放的引用。)

    一种可能的解决方案是向您的_GoString_ 类添加一个private 字段,以保持对ByteBuffer 的强引用并防止系统回收其内存(可能添加一个ByteBuffer constrcutor)。

    另一个解决方案是使用 JNA 的 Memory 类作为字符串并将 Memory 对象(扩展 Pointer)直接存储到 p 字段。我不确定您为什么为此应用程序选择直接字节缓冲区,因此这可能不适用于您的用例,但它肯定会简化您的代码。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2018-12-31
      • 1970-01-01
      • 1970-01-01
      • 2012-10-23
      • 1970-01-01
      • 1970-01-01
      • 2023-03-26
      • 2016-10-25
      相关资源
      最近更新 更多