PHP 怎么PHP调Java

wen PHP项目 2026-08-04 197

本文目录导读：

PHP 怎么PHP调Java

通过命令行调用（最简单）
使用 PHP-Java Bridge（推荐）
使用 REST API / Web Service（推荐）
使用消息队列（异步处理）
使用内存缓存（Redis等）
通过 Socket 通信
推荐方案

在 PHP 中调用 Java 有几种常见的方法,我来详细介绍几种主流方案：

通过命令行调用（最简单）

<?php
// 直接调用Java命令
$output = shell_exec('java -jar MyJavaApp.jar "参数1" "参数2"');
echo $output;
// 或者使用exec函数
exec('java -cp /path/to/classes MyJavaClass arg1 arg2', $output, $returnCode);
print_r($output);

Java端示例：

public class MyJavaClass {
    public static void main(String[] args) {
        if (args.length > 0) {
            System.out.println("Hello from Java: " + args[0]);
        }
    }
}

使用 PHP-Java Bridge（推荐）

PHP-Java Bridge 是最常用的解决方案,支持双向调用。

安装步骤：

# 下载并安装 PHP-Java Bridge
wget http://php-java-bridge.sourceforge.net/php-java-bridge_6.2.1_jdk8-2.tar.gz
tar -xzf php-java-bridge_6.2.1_jdk8-2.tar.gz
cd php-java-bridge_6.2.1_jdk8-2
./configure
make
make install

PHP调用示例：

<?php
// 加载JavaBridge
require_once("java/Java.inc");
// 调用Java类
$date = new Java('java.util.Date');
echo $date->toString();
// 调用自定义Java类
$myClass = new Java('com.example.MyService');
$result = $myClass->doSomething("参数");
echo $result;
?>

使用 REST API / Web Service（推荐）

通过 HTTP 服务进行通信,这是最灵活的方式。

Java端（Spring Boot）：

@RestController
public class MyController {
    @GetMapping("/api/hello")
    public String hello(@RequestParam String name) {
        return "Hello " + name + " from Java!";
    }
    @PostMapping("/api/process")
    public Map<String, Object> process(@RequestBody Map<String, Object> data) {
        // 处理业务逻辑
        return responseData;
    }
}

PHP端调用：

<?php
// 使用cURL调用Java REST API
function callJavaAPI($url, $data = null, $method = 'GET') {
    $ch = curl_init();
    if ($method == 'POST') {
        curl_setopt($ch, CURLOPT_POST, 1);
        if ($data) {
            curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
        }
    }
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Content-Type: application/json'
    ]);
    $response = curl_exec($ch);
    curl_close($ch);
    return json_decode($response, true);
}
// 调用Java服务
$result = callJavaAPI('http://localhost:8080/api/hello?name=World');
var_dump($result);
// POST请求
$data = ['key' => 'value'];
$result = callJavaAPI('http://localhost:8080/api/process', $data, 'POST');
?>

使用消息队列（异步处理）

适合处理大量任务，使用 RabbitMQ、Kafka 等。

PHP生产者：

<?php
require_once __DIR__ . '/vendor/autoload.php';
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('java_tasks', false, true, false, false);
$msg = new AMQPMessage(json_encode(['task' => 'process_data', 'data' => '...']));
$channel->basic_publish($msg, '', 'java_tasks');
echo "Task sent to Java worker\n";
$channel->close();
$connection->close();
?>

Java端消费者：

import com.rabbitmq.client.*;
public class Consumer {
    private final static String QUEUE_NAME = "java_tasks";
    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        channel.queueDeclare(QUEUE_NAME, true, false, false, null);
        System.out.println("Waiting for tasks...");
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println("Received: " + message);
            // 处理业务逻辑
        };
        channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {});
    }
}

使用内存缓存（Redis等）

通过共享缓存进行数据交换：

<?php
// PHP端写入
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis->set('php_to_java', json_encode(['task' => 'data_process']));
// PHP端读取Java处理结果
$result = $redis->get('java_result');
?>

通过 Socket 通信

<?php
function callJavaSocket($host, $port, $data) {
    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    if ($socket === false) {
        return false;
    }
    $result = socket_connect($socket, $host, $port);
    if ($result === false) {
        return false;
    }
    socket_write($socket, $data, strlen($data));
    $response = socket_read($socket, 4096);
    socket_close($socket);
    return $response;
}
$result = callJavaSocket('127.0.0.1', 9999, 'processing data');
echo $result;
?>