# 安裝：pip install jython

from java.util import ArrayList

# 創(chuàng)建 Java ArrayList
java_list = ArrayList()
java_list.add("Java元素")
java_list.add(123)

# 調(diào)用 Java 方法
print(java_list.size())  # 輸出: 2

# 繼承 Java 類
from javax.swing import JFrame

class MyFrame(JFrame):
    def __init__(self):
        self.setTitle("Jython 示例")
        self.setSize(300, 200)
        self.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE)

frame = MyFrame()
frame.setVisible(True)

# 安裝：pip install JPype1

import jpype

# 啟動 JVM（指定 jvm.dll 路徑）
jpype.startJVM(jpype.getDefaultJVMPath(), 
              "-ea",
              "-Djava.class.path=/path/to/your.jar")

# 導(dǎo)入 Java 類
ArrayList = jpype.JClass("java.util.ArrayList")
System = jpype.JClass("java.lang.System")

# 使用 Java 對象
java_list = ArrayList()
java_list.add("測試數(shù)據(jù)")
System.out.println(java_list)  # 輸出: [測試數(shù)據(jù)]

# 調(diào)用靜態(tài)方法
Collections = jpype.JClass("java.util.Collections")
Collections.sort(java_list)

# 關(guān)閉 JVM（程序結(jié)束前調(diào)用）
jpype.shutdownJVM()

// 添加 Maven 依賴
// <dependency>
//   <groupId>net.sf.py4j</groupId>
//   <artifactId>py4j</artifactId>
//   <version>0.10.9.5</version>
// </dependency>

import py4j.GatewayServer;

public class MathService {
    public int add(int a, int b) {
        return a + b;
    }
    
    public static void main(String[] args) {
        GatewayServer server = new GatewayServer(new MathService());
        server.start();
        System.out.println("Gateway Server Started");
    }
}

# 安裝：pip install py4j

from py4j.java_gateway import JavaGateway

gateway = JavaGateway()                   # 連接默認網(wǎng)關(guān)
math_service = gateway.entry_point        # 獲取Java對象

result = math_service.add(10, 20)
print(result)  # 輸出: 30

# 回調(diào)示例
class PythonListener:
    def __init__(self, gateway):
        self.gateway = gateway
    
    def notify(self, message):
        print("Java回調(diào):", message)
        return "Python已處理"

listener = PythonListener(gateway)
gateway.jvm.System.setProperty("python.listener", 
                              gateway.jvm.py4j.GatewayServer.DEFAULT_PYTHON_PROXY_PORT)

syntax = "proto3";

service DataProcessor {
  rpc Process (DataRequest) returns (DataResponse);
}

message DataRequest {
  string content = 1;
  int32 priority = 2;
}

message DataResponse {
  bool success = 1;
  string result = 2;
}

# Python 端
python -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. data.proto

# Java 端（Maven配置）
<build>
  <extensions>
    <extension>
      <groupId>kr.motd.maven</groupId>
      <artifactId>os-maven-plugin</artifactId>
      <version>1.6.2</version>
    </extension>
  </extensions>
  <plugins>
    <plugin>
      <groupId>org.xolstice.maven.plugins</groupId>
      <artifactId>protobuf-maven-plugin</artifactId>
      <version>0.6.1</version>
      <configuration>
        <protocArtifact>com.google.protobuf:protoc:3.19.2:exe:${os.detected.classifier}</protocArtifact>
        <pluginId>grpc-java</pluginId>
        <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.47.0:exe:${os.detected.classifier}</pluginArtifact>
      </configuration>
      <executions>
        <execution>
          <goals>
            <goal>compile</goal>
            <goal>compile-custom</goal>
          </goals>
        </execution>
      </executions>
    </plugin>
  </plugins>
</build>

public class DataServiceImpl extends DataProcessorGrpc.DataProcessorImplBase {
    @Override
    public void process(DataRequest request, 
                       StreamObserver<DataResponse> responseObserver) {
        System.out.println("收到請求: " + request.getContent());
        
        DataResponse response = DataResponse.newBuilder()
            .setSuccess(true)
            .setResult("Processed: " + request.getContent().toUpperCase())
            .build();
        
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}

// 啟動服務(wù)器
Server server = ServerBuilder.forPort(50051)
    .addService(new DataServiceImpl())
    .build()
    .start();

import grpc
import data_pb2
import data_pb2_grpc

channel = grpc.insecure_channel('localhost:50051')
stub = data_pb2_grpc.DataProcessorStub(channel)

response = stub.Process(data_pb2.DataRequest(
    content="hello grpc",
    priority=1
))

print(response.result)  # 輸出: Processed: HELLO GRPC

public class NativeBridge {
    static {
        System.loadLibrary("nativebridge");
    }
    
    public native String processData(String input);
}

javac -h . NativeBridge.java

#include <jni.h>
#include "NativeBridge.h"
#include <Python.h>

JNIEXPORT jstring JNICALL Java_NativeBridge_processData(
    JNIEnv *env, jobject obj, jstring input) {
    
    const char *str = (*env)->GetStringUTFChars(env, input, 0);
    
    // 初始化Python解釋器
    Py_Initialize();
    PyObject *pModule = PyImport_ImportModule("data_processor");
    PyObject *pFunc = PyObject_GetAttrString(pModule, "process");
    
    // 調(diào)用Python函數(shù)
    PyObject *pArgs = PyTuple_Pack(1, PyUnicode_FromString(str));
    PyObject *pResult = PyObject_CallObject(pFunc, pArgs);
    
    const char *result = PyUnicode_AsUTF8(pResult);
    
    // 清理資源
    Py_DECREF(pArgs);
    Py_DECREF(pResult);share.aalatni.cn
    Py_Finalize();
    
    return (*env)->NewStringUTF(env, result);
}

# Linux示例
gcc -shared -fPIC -I${JAVA_HOME}/include \
    -I${JAVA_HOME}/include/linux \
    -I/usr/include/python3.8 \
    -o libnativebridge.so NativeBridge.c \
    -lpython3.8

jpype.startJVM(..., "-Djpype.debug=True")

System.setProperty("py4j.logging", "py4j.logging.ConsoleLogger")

# JPype對象池示例
class ObjectPool:aiqiyi.aalatni.cn
    def __init__(self, j_class, size=10):
        self.pool = [j_class() for _ in range(size)]
        
    def acquire(self):
        return self.pool.pop() if self.pool else None
        
    def release(self, obj):
        self.pool.append(obj)

// Java端提供批量接口
public List<String> batchProcess(List<String> inputs) {
    return inputs.stream().map(this::process).collect(Collectors.toList());
}

# Python客戶端
creds = grpc.ssl_channel_credentials()tenxun.aalatni.cn
channel = grpc.secure_channel('localhost:50051', creds)

GatewayServer server = new GatewayServer(
    new MathService(),
    GatewayServer.DEFAULT_PORT,
    GatewayServer.DEFAULT_CONNECT_TIMEOUT,
    GatewayServer.DEFAULT_READ_TIMEOUT,
    new String[] {"192.168.1.*"}  // IP白名單
);