零基础学习java------30---------wordCount案例（涉及到第三种多线程callable）

public class ThreadMain {
    public static void main(String[] args) throws Exception, ExecutionException {
        ThreadTest threadTest = new ThreadTest();//线程任务
        // FutureTask接收线程的返回数据
        FutureTask<String> f = new FutureTask<>(threadTest);
        Thread thread = new Thread(f);
        thread.start();
        String res = f.get();
        System.out.println(res);
    }
}

class ThreadTest implements Callable<String>{
    @Override
    public String call() throws Exception {
        return "hello";
    }
}

public class MyClient implements Callable<String>{
    
    //不同线程处理不同的文件
    String localFilePath ;
    public MyClient(String localFilePath) {
        super();
        this.localFilePath = localFilePath;
    }
    
    public static final String KEY = "天王盖地虎";
    public static final String PATH = "E:/javafile/wc_server.jar";
    @SuppressWarnings("unused")
    private String task() throws Exception{
        String res = null;
        Socket socket = new Socket("127.0.0.1",8888);
        ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
        ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
        //1 发送身份校验
        oos.writeObject(KEY);
        //2 接收校验结果
        boolean b = (boolean)ois.readObject();
        if(b) {//校验成功
            System.out.println("校验成功");
            //3 发送服务端存储jar包的路径
            oos.writeObject(PATH);
            //4 往服务端发送jar包
            // 4.1 读取本地需要的jar包
            BufferedInputStream bis = new BufferedInputStream(new FileInputStream("E:/javafile/wc.jar"));
            byte[] bs = new byte[1024];
            int len;
            while((len = bis.read(bs))!= -1) {
                // 4.2 利用网络流发送此jar包
                oos.write(bs,0,len);
            }
            oos.flush();
            bis.close();
            // 往服务端发送执行命令
            String cmd = "java -jar "+PATH+" " +localFilePath;
            oos.writeObject(cmd);
            // 接收服务端jar程序执行的结果 
            res = (String)ois.readObject();
//            System.out.println(res);
        }else {
            System.out.println("校验失败");
        }
        socket.close();
        return res;
    }
    @Override
    public String call() throws Exception {
        String res = task();
        return res;
    }
}

public class MyServer {
    public static final String KEY = "天王盖地虎";
    public static void main(String[] args) throws Exception {
        ServerSocket ss = new ServerSocket(8888);
        while(true) {
            Socket socket = ss.accept();
            OutputStream os = socket.getOutputStream();
            InputStream in = socket.getInputStream();
            ObjectInputStream ois = new ObjectInputStream(in);
            ObjectOutputStream oos = new ObjectOutputStream(os);
            //接收客户端发送的身份校验
            String str = (String)ois.readObject();
            //校验成功
            if(KEY.equals(str)) {
                oos.writeObject(true);
                // 接收路径
                String path = (String)ois.readObject();
                // 接收jar包,并写入指定的路径
                BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(path));
                byte[] bs = new byte[1024];
                int len = 0;
                while((len = ois.read(bs)) != -1) {
                    bos.write(bs,0,len);
                }
                bos.flush();
                bos.close();
                // 接收执行命令
                String cmd = (String)ois.readObject();
                Runtime runtime = Runtime.getRuntime();
                Process p = runtime.exec(cmd);
                InputStream inputStream = p.getInputStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(inputStream));
                String line = null;
                StringBuilder res = new StringBuilder();
                while((line = br.readLine()) != null) {
                    res.append(line+"\r\n");
                }
                // 将结果返回给客户端
                oos.writeObject(res.toString());
                oos.flush();
            // 校验失败
            }else {
                //将结果返回到客户端
                oos.writeObject(false);
            }
        }
    }
}

public class TestClient {
    public static void main(String[] args) throws Exception {
        // 创建第一个线程任务
        MyClient m1 = new MyClient("E:/javafile/wc1.txt");
        FutureTask<String> f1 = new FutureTask<>(m1);
        new Thread(f1).start();
        String res1 = f1.get();
//        System.out.println("线程1的结果:"+"/r/n"+ res1);
        
        // 创建第二个线程任务
        MyClient m2 = new MyClient("E:/javafile/wc2.txt");
        FutureTask<String> f2 = new FutureTask<>(m2);
        new Thread(f2).start();
        String res2 = f2.get();
//        System.out.println("线程2的结果:" +res2);
        //结果数据的汇总  --->  写到中间结果
                //将结果数据追加到指定的文件中
                BufferedWriter bw = new BufferedWriter(new FileWriter(new File("E:/javafile/res.res"), true));
                bw.write(res1);
                bw.write(res2, 0, res2.length()-2);
                //bw.write(res2);
                bw.close();
                //统计结果数据
                Map<String,Integer> map = new HashMap<>() ;
                BufferedReader br = new BufferedReader(new FileReader("E:/javafile/res.res"));
                String line = null ;
                while((line = br.readLine())!=null){
                    System.out.println(line);
                    String[] split = line.split(":");
                    String word = split[0];
                    int num = Integer.parseInt(split[1]);
                    Integer num2 = map.getOrDefault(word, 0);
                    num2+=num;
                    map.put(word, num2);
                }
                Set<Entry<String, Integer>> entrySet = map.entrySet();
                for (Entry<String, Integer> entry : entrySet) {
                    System.out.println(entry);
                }
    }
}