java实现内网通信

package newTest;

import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author liuwenlong
 * @create 2020-08-10 14:29:40
 */
@SuppressWarnings("all")
public class LwlClient {
    public static void main(String[] args) {
        if (args.length != 2) {
            System.out.println("usage:java TcpServer port[5000~9999]");
            return;
        }
        try {
            Socket socket = new Socket(args[0], Integer.parseInt(args[1]));
            OutputStream out = socket.getOutputStream();
            byte b[] = new byte[300];
            while (true) {
                System.out.print("mymsg>");
                int len = System.in.read(b);
                if (len < 1) continue;

                if (b[len - 2] == 13 && b[len - 1] == 10) {
                    len = len - 2;
                } else {
                    len = len - 1;
                }
                if (len == 0) continue;
                out.write(b, 0, len);
            }
        } catch (Exception e) {
            System.err.println(e.getMessage());
        }
    }
}

package newTest;

import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * @author liuwenlong
 * @create 2020-08-10 13:38:07
 */
@SuppressWarnings("all")
class ServerThread extends Thread {
    Socket socket;

    public ServerThread() {
    }

    public ServerThread(Socket socket) {
        this.socket = socket;
    }

    @Override
    public void run() {
        try {
            byte b[] = new byte[300];
            InputStream in = socket.getInputStream();
            while (true) {
                int len = in.read(b);
                System.out.println(new String(b, 0, len));
            }

        } catch (Exception e) {
            System.err.println(e.getMessage());
        }
    }
}


public class TcpServer {
    public static void main(String[] args) {
        if (args.length != 1) {
            System.out.println("usage:java TcpServer port[5000~9999]");
            System.exit(0);
        }

        try {
            ServerSocket server = new ServerSocket(Integer.parseInt(args[0]));
            while (true) {
                Socket socket = server.accept();
                new ServerThread(socket).start();
            }
        } catch (Exception e) {
            System.err.println(e.getMessage());
        }
    }
}