php网站开发学什么,申请网站一年多少钱,设计logo怎么收费,wordpress插件cloud一#xff0c;说明
想实现如下功能#xff0c;项目后端架构是Spring Boot#xff0c;某个功能需要调用Python脚本来实现#xff0c;调用Python脚本的功能要兼容Windows和Linux#xff0c;即可以运行在Windows和Linux两种平台上。
二#xff0c;Java代码
// 定义一个线…一说明
想实现如下功能项目后端架构是Spring Boot某个功能需要调用Python脚本来实现调用Python脚本的功能要兼容Windows和Linux即可以运行在Windows和Linux两种平台上。
二Java代码
// 定义一个线程池来读取python脚本的执行结果
private static ExecutorService taskPool new ThreadPoolExecutor(3, 10, 200L, TimeUnit.MILLISECONDS,new LinkedBlockingDeque(200),new ThreadFactoryBuilder().setNamePrefix(thread-python-exec-runner-%d).build());private void execPythonFile(String path, String params) throws MoyaException {// 获得操作系统名称String os System.getProperty(os.name);String[] args;if (os.startsWith(Windows)) {// 如果当前环境是Windows环境args new String[]{cmd.exe, /c, python, path, params};} else {// 如果当前环境是Linux环境args new String[]{python, path, params};}Process process null;try {// 执行python脚本process Runtime.getRuntime().exec(args);// 错误输出流InputStream errorStream process.getErrorStream();// 正确输出流InputStream inputStream process.getInputStream();// 开线程来读取执行失败的信息taskPool.submit(() - {BufferedReader reader new BufferedReader(new InputStreamReader(errorStream));ListString list read(path, reader);log.info(Python Script execute failed, error message:{}, list);});// 开线程来读取执行成功的信息taskPool.submit(() - {BufferedReader reader new BufferedReader(new InputStreamReader(inputStream));ListString list read(path, reader);log.info(Python Script execute success, successful message:{}, list);});// 阻塞进程等待执行完成int processResult process.waitFor();if (processResult ! 0) {log.error(Python Script error, waitFor is not zero.);throw new MoyaException(已知威胁流生成失败);}} catch (Exception e) {log.error(python script occur error:{}, e);throw new MoyaException(已知威胁流生成失败);} finally {try {// 在finally中关闭正确输出流与错误输出流process.getErrorStream().close();process.getInputStream().close();} catch (IOException e) {log.info(close process stream exception: {}, e);}// 执行完成销毁Process对象process.destroy();}}定义读取方法
/*** 读取输出流数据并以数组形式返回读取结果** param path 路径* param reader 缓冲流对象* return*/private ListString read(String path, BufferedReader reader) {ListString resultList new ArrayList();String res ;while (true) {try {// 读取到null值跳出循环if ((res reader.readLine()) null) break;} catch (IOException e) {log.error(reading python file: {} occur exception: {}., path, e);}// 将读取结果放入数组集合中resultList.add(res);}return resultList;}三Python代码
import sys# 定义一个主函数作为脚本执行的入口如果没有主函数则从第一行开始执行
if __name__ __main__:# 获取外部输入参数param sys.argv[1]print (param)
