java tcp通讯

java tcp通讯

import java.io.*;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class tcp02 {
    public static void main(String[] args) {
        tcp02 tcp02 = new tcp02();
        new Thread(() -> {
            tcp02.r();
        }).start();
        new Thread(() -> {
            tcp02.w();
        }).start();
    }

    public void r() {
        try {
            ServerSocket socket = new ServerSocket(9999);
            while (true) {
                Socket accept = socket.accept();
                BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(accept.getInputStream()));
                String s = bufferedReader.readLine();
                System.out.println(s);
            }
        } catch (IOException ioException) {
            ioException.printStackTrace();
        }
    }

    public void w() {
        try {
            Scanner S = new Scanner(System.in);
            while (true) {
                String s = S.nextLine();
                //"127.0.0.1"对方接受端ip地址，11111对方接受端端口号
                Socket socket = new Socket("127.0.0.1", 11111);
                BufferedWriter bufferedWriter = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
                bufferedWriter.write(s);
                bufferedWriter.flush();
                socket.close();
            }
        } catch (IOException ioException) {
            ioException.printStackTrace();
        }
    }
}