2022年 11月 3日

java调用python的几种方法（看这篇就够了）

关注公众号：任识算法，获取更多技术干货！

本文主要介绍了java调用python的几种方法。 

在java类中直接执行python语句

准备工作:

创建maven工程，结构如下：到官网https://www.jython.org/download.html下载Jython的jar包或者在maven的pom.xml文件中加入如下代码：

  1. <dependency>java
  2.     <groupId>org.python</groupId>
  3.     <artifactId>jython-standalone</artifactId>
  4.     <version>2.7.0</version>
  5. </dependency>

创建JavaRunPython.java类：

  1. import org.python.util.PythonInterpreter;
  2.  
  3. public class JavaRunPython {
  4.  
  5.     public static void main(String[] args) {
  6.         PythonInterpreter interpreter = new PythonInterpreter();
  7.         interpreter.exec("a='hello world'; ");
  8.         interpreter.exec("print a;");
  9.     }
  10.  
  11. }

2.在java中直接调用python脚本

在本地的D盘创建一个python脚本，文件名字为javaPythonFile.py，文件内容如下：

  1. a = 1
  2. b = 2
  3. print (a + b)

创建JavaPythonFile.java类，内容如下：

  1. import org.python.util.PythonInterpreter;
  2.  
  3. public class JavaPythonFile {
  4.  
  5.     public static void main(String[] args) {
  6.         PythonInterpreter interpreter = new PythonInterpreter();
  7.         interpreter.execfile("D:\\javaPythonFile.py");
  8.     }
  9. }

输出结果如下：

注意：以上两个方法虽然都可以调用python程序，但是使用Jpython调用的python库不是很多，如果你用以上两个方法调用，而python的程序中使用到第三方库，这时就会报错java ImportError: No module named xxx。遇到这种情况推荐使用下面的方法，即可解决该问题。

3.使用Runtime.getRuntime()执行python脚本文件，推荐使用

为了验证该方法可以运行含有python第三方库的程序，在本地的D盘创建一个python脚本，文件名字为demo1.py，代码如下：

  1. import numpy as np
  2.  
  3. a = np.arange(12).reshape(3,4)
  4. print(a)

可以看到程序中用到了numpy第三方库，并初始化了一个3×4的一个矩阵。

下面来看看怎么用Runtime.getRuntime()方法来调用python程序并输出该结果，java代码如下：

  1. import java.io.BufferedReader;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4.  
  5. public class Demo1 {
  6.     public static void main(String[] args) {
  7.         // TODO Auto-generated method stub
  8.         Process proc;
  9.         try {
  10.             proc = Runtime.getRuntime().exec("python D:\\demo1.py");// 执行py文件
  11.             //用输入输出流来截取结果
  12.             BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
  13.             String line = null;
  14.             while ((line = in.readLine()) != null) {
  15.                 System.out.println(line);
  16.             }
  17.             in.close();
  18.             proc.waitFor();
  19.         } catch (IOException e) {
  20.             e.printStackTrace();
  21.         } catch (InterruptedException e) {
  22.             e.printStackTrace();
  23.         } 
  24.     }
  25. }

输出的结果如下图所示：

可以看到运行成功了，但有的朋友可能会问了，怎么在python程序中函数传递参数并执行出结果，下面我就举一例来说明一下。

先写一个python的程序，代码如下：

  1. import sys
  2.  
  3. def func(a,b):
  4.     return (a+b)
  5.  
  6. if __name__ == '__main__':
  7.     a = []
  8.     for i in range(1, len(sys.argv)):
  9.         a.append((int(sys.argv[i])))
  10.  
  11.     print(func(a[0],a[1]))

其中sys.argv用于获取参数url1，url2等。而sys.argv[0]代表python程序名，所以列表从1开始读取参数。

以上代码实现一个两个数做加法的程序，下面看看在java中怎么传递函数参数，代码如下：

  1. int a = 18;
  2. int b = 23;
  3. try {
  4.     String[] args1 = new String[] { "python", "D:\\demo2.py", String.valueOf(a), String.valueOf(b) };
  5.     Process proc = Runtime.getRuntime().exec(args1);// 执行py文件
  6.  
  7.     BufferedReader in = new BufferedReader(new InputStreamReader(proc.getInputStream()));
  8.     String line = null;
  9.     while ((line = in.readLine()) != null) {
  10.         System.out.println(line);
  11.     }
  12.     in.close();
  13.     proc.waitFor();
  14. } catch (IOException e) {
  15.     e.printStackTrace();
  16. } catch (InterruptedException e) {
  17.     e.printStackTrace();
  18. }

在来一个实战案例—模型获取相似关键词：

调用pyhon模型

java代码

package com.hadoop.flowsum;/*
  1. 文件     :testpython.java
  2. IDE      :IntelliJ IDEA
  3. */
  4.  
  5. import java.io.BufferedReader;
  6. import java.io.IOException;
  7. import java.io.InputStreamReader;
  8. import java.util.HashMap;
  9. import java.util.Iterator;
  10. import java.util.Map;
  11. import java.util.Set;
  12.  
  13. public class Demo1 {
  14.  
  15.     public static String getType(Object o){ //获取变bai量类型方法du
  16.  
  17.         return o.getClass().toString(); //使用int类型的getClass()方法
  18.  
  19.     }
  20.  
  21.     public static void main(String[] args) throws IOException, InterruptedException {
  22.         // TODO Auto-generated method stub
  23.  
  24.         String cmds = String.format("python D:word2vec\\testsimilar.py %s","中国");
  25.         Process pcs = Runtime.getRuntime().exec(cmds);
  26.         pcs.waitFor();
  27.  
  28.         BufferedReader in = new BufferedReader(new InputStreamReader(pcs.getInputStream(),"GB2312"));
  29.  
  30.         Map<String, String> map = new HashMap<>();
  31.         String line = null;
  32. //        System.out.println(in.readLine());
  33.         while ((line = in.readLine()) != null) {
  34.             System.out.println(line);
  35.             String[] s = line.split("\t");
  36. //            System.out.println(s[0]+s[1]);
  37.             map.put(s[0],s[1]);
  38.         }
  39. //        System.out.println(in.readLine());
  40.         if (in.readLine() == null){
  41.             System.out.println("yes hhhhhh");
  42.         }
  43. //        String key1 = (String) map.keySet().toArray()[0];
  44.         String key1 = (String) map.keySet().toArray()[0];
  45.         String d1 = map.get(key1);
  46.         double xx = Double.parseDouble(d1);
  47. //        System.out.println(getType(xx));
  48. //        if (xx > 0.6){
  49. //            System.out.println("nice   ................");
  50. //        }
  51.     }
  52. }

python代码：

  1. # * coding:utf-8_*_
  2.  
  3.  
  4. import os
  5. import time
  6. import warnings
  7. import sys
  8. # import config
  9. # import logging
  10. from gensim.models import Word2Vec
  11. # from gensim.models.word2vec import LineSentence, PathLineSentences
  12. # from pretreatment.pretreatment import PreDeal
  13. warnings.filterwarnings(action='ignore', category=UserWarning, module='gensim')
  14. model = Word2Vec.load(r"D:\\model\\word2vec.model")
  15.  
  16.  
  17. def similarwords(keyword, tops=5):
  18.     # 默认获取前10个相似关键词
  19.     start = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
  20.     # print("start execute Word2vec, get similar keywords! Time:" + start +">>>>>>>>>>>>>>>>>>>>>")
  21.     try:
  22.         # model = Word2Vec.load(modelpath)
  23.         words = model.wv.most_similar(keyword, topn=tops)
  24.     except KeyError:
  25.         # print("word '%s' not in vocabulary" % keyword)
  26.         return None
  27.     end = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time()))
  28.     if not words:
  29.         return None
  30.         # res = [[item[0], item[1]] for item in words]   # 相似关键词及其相似度
  31.     res = []
  32.     for word in words:
  33.         res.append([word[0], word[1]])
  34.         print(word[0], "\t", word[1])
  35.     # print("get similar keywords end!................... Time:" + end + ">>>>>>>>>>>>>>>>>>>>>")
  36.     # print(res)
  37.     return res
  38.  
  39.  
  40. if __name__ == '__main__':
  41.     word = sys.argv[1];
  42.     similarwords(word)

输出：