如何在Java中调用python文件执行详解

< dependency >

     < groupId >org.python</ groupId >

     < artifactId >jython-standalone</ artifactId >

     < version >2.7.0</ version >

</ dependency >

PythonInterpreter interpreter = new PythonInterpreter();

interpreter.exec( "a=[5,2,3,9,4,0]; " );

interpreter.exec( "print(sorted(a));" );

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

publicclass Demo1 {

publicstaticvoid main(String[] args) {

         Process proc;

         // 编译器是python

         String exe = "python" ;

         // py文件存的绝对路径

         String path = "D:\\NLP.py" ;

         // 传入的参数

         String args = "今天过的很开心" ;

         try {

             proc = Runtime.getRuntime().exec(exe + ' ' + path + ' ' + args); // 执⾏py⽂件

             // ⽤输⼊输出流来截取结果

             BufferedReader in = new BufferedReader( new InputStreamReader(proc.getInputStream()));

             String line = null ;

         while ((line = in.readLine()) != null ) {

                 System.out.println(line);

             }

             in.close();

             proc.waitFor();

         } catch (IOException e) {

             e.printStackTrace();

         } catch (InterruptedException e) {

             e.printStackTrace();

         }

     }

}

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

publicclass Demo1 {

publicstaticvoid main(String[] args) {

         Process proc;

         // 编译器是python

         String exe = "cmd.exe" ;

         // py文件存的绝对路径

         String path = "D:\\NLP.py" ;

         // 传入的参数

         String args = "今天过的很开心" ;

         try {

             proc = Runtime.getRuntime().exec(exe + " \c start " + path + ' ' + args); // 执⾏py⽂件

             proc.waitFor();

         } catch (Exception e) {

             e.printStackTrace();

         }

     }

}

package com.Lee.utils;

import java.io.*;

public class NLPUtils {

     // NLP处理

     public static String NLP(String data) throws Exception{

         try {

             inputToFile(data);

         }

         catch (Exception e){

             e.printStackTrace();

         }

         System.out.println( "调用python程序" );

         Process pcs = null ;

         String py = "python.exe" ;

         try {

             if (processIsRun(py))

                 killProcess(py);

             System.out.println( "start" );

             pcs = Runtime.getRuntime().exec( "cmd.exe /c start F://python_project//NLP.bat" );

             pcs.waitFor();

             if (processIsRun(py)){

                 System.out.println( "正在执行" );

                 Thread.currentThread().sleep( 30000 );

             }

             System.out.println( "end" );

         }

         catch (Exception e){

             e.printStackTrace();

         }

         String result = "" ;

         try {

             System.out.println( "out:" + outputFromFile());

             result = outputFromFile();

         }

         catch (Exception e){

             e.printStackTrace();

         }

         return result;

     }

     // 清空文件

     public static void clearInfoForFile(String fileName) {

         File file = new File(fileName);

         try {

             if (!file.exists()) {

                 file.createNewFile();

             }

             FileWriter fileWriter = new FileWriter(file);

             fileWriter.write( "" );

             fileWriter.flush();

             fileWriter.close();

         } catch (Exception e) {

             e.printStackTrace();

         }

     }

     // 输入文件，参数为输出字符串

     public static void inputToFile(String input) throws Exception{

         // 写入前清空

         clearInfoForFile( "F:\\python_project\\input.txt" );

         //创建写入流

         FileWriter writer= new FileWriter( "F:\\python_project\\input.txt" );

         // 写入

         writer.write(input + "\r\n" );

         //关闭资源

         writer.flush();

         writer.close();

     }

     // 读取文件

     public static String outputFromFile() throws Exception{

         InputStreamReader isr = new InputStreamReader( new FileInputStream( "F:\\python_project\\output.txt" ), "GBK" );

         BufferedReader read = new BufferedReader(isr);

         String s = null ;

         String result = "" ;

         while ((s = read.readLine()) != null )

             result += s;

         isr.close();

         read.close();

         return result;

     }

     // 杀掉一个进程

     public static void killProcess(String name) {

         try {

             String[] cmd = { "tasklist" };

             Process proc = Runtime.getRuntime().exec(cmd);

             BufferedReader in = new BufferedReader( new InputStreamReader(proc.getInputStream()));

             String string_Temp = in.readLine();

             while (string_Temp != null ) {

                 // System.out.println(string_Temp);

                 if (string_Temp.indexOf(name) != - 1 ) {

                     Runtime.getRuntime().exec( "taskkill /F /IM " + name);

                     System.out.println( "杀死进程  " + name);

                 }

                 string_Temp = in.readLine();

             }

         } catch (Exception e) {

             e.printStackTrace();

         }

     }

     // 判断进程是否存在

     public static boolean processIsRun(String ProjectName) {

         boolean flag = false ;

         try {

             Process p = Runtime.getRuntime().exec( "cmd /c tasklist " );

             ByteArrayOutputStream baos = new ByteArrayOutputStream();

             InputStream os = p.getInputStream();

             byte b[] = new byte [ 256 ];

             while (os.read(b) > 0 )

                 baos.write(b);

             String s = baos.toString();

             if (s.indexOf(ProjectName) >= 0 ) {

                 flag = true ;

             } else {

                 flag = false ;

             }

         } catch (Exception e) {

             e.printStackTrace();

         }

         return flag;

     }

}