最简实例，易上手，python 作为服务端，java 等语言进行调用

整体思路是：

　　python本身作为服务端和客户端，但是可以用其他语言，调用python命令，只用执行函数，然后获取函数返回值，那么其他语言就能获取python函数执行过的信息。

python/server.py:

import socket


HOST = ''                 # Symbolic name meaning all available interfaces
PORT = 50007              # Arbitrary non-privileged port
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
while 1:
    conn, addr = s.accept()
    print('Connected by', addr)
    data = conn.recv(1024)
    if not data: break
    method=str(data)[2]
    if(method=="1"):
        conn.sendall(("111").encode())
    else:
        conn.sendall(("DDDDD").encode())
    # update plot
    conn.close()

python/client.py

import socket

HOST = '127.0.0.1'  # The remote host
PORT = 50007  # The same port as used by the server

#调用服务端接口
def cl_get_text():
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((HOST, PORT))
    s.sendall((str(1)).encode())
    data = []
    while True:
        subdata = s.recv(20480)
        if not subdata: break
        data.append(str(subdata, encoding='utf-8'))
    data= ''.join(data)

    s.close()
    return data


if __name__ =="__main__":
    # 预测训练文件
    #将训练文件的预测结果以csv文件的形式存放到result中
    for i in range(10):
        print(i)
        print(cl_get_text())

java:

package com.util;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;


public class Ppyrun {
    static final String workspace=Config.workspace;//client.py所在的文件夹
    public static void main(String args[])
    {
        String a=send_text();
        System.out.println(a);
    }
    
    
    public static String send_text()
    {
        String predict_result="";
        Runtime proc;
        proc = Runtime.getRuntime();
        try {
            Process result=proc.exec("python");
            OutputStream output=result.getOutputStream();
            runOutput(output,"import os");
            runOutput(output,"os.chdir('"+workspace+"')");
            runOutput(output,"import client");
            runOutput(output,"print(client.cl_get_text())");
            runFinish(output);
            InputStream input=result.getInputStream();
            BufferedReader br = null;
            br = new BufferedReader(new InputStreamReader(input, "GB2312"));
            String line = null;
            while ((line = br.readLine()) != null) {
                predict_result+=line+"
";
            }
            input.close();
            result.waitFor();
        }catch (IOException | InterruptedException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        return predict_result;
    }
    
    
    public static void runOutput(OutputStream outstream,String command)
    {
        try {
//            outstream.write((new String(command.getBytes("utf-8"),"GBK")+"
").getBytes("GBK"));
            outstream.write((command+"
").getBytes("UTF-8"));
        } catch (IOException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
    }


    public static void runFinish(OutputStream outstream)
    {
        try {
            outstream.flush();
            outstream.close();
        } catch (IOException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        
    }
}