Netty网络编程零基础入门

public class Server {
    private static int port = 8585;
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        try {
            serverSocket = new ServerSocket(port);
            //开始监听
            System.out.println("服务器开始监听，监听端口:" + port);
            while(true) {
                Socket socket = serverSocket.accept();//阻塞  等待客戶端連接
                System.out.println("接受一个客户端的请求.....");
                InputStream in = socket.getInputStream();
                int len = -1;
                byte[] buff = new byte[1024];
                while ((len = in.read(buff)) != -1) {//阻塞   等待客戶端發送数据
                    String str = new String(buff, 0, len);
                    System.out.println("读取到客户端的输入字符:" + str);
                }
                in.close();
                socket.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

public class Client {
    private static int port = 8585;
    public static void main(String[] args) {
        Scanner sc = new Scanner(System.in);
        System.out.println("请输入客户端编号:");
        String no = sc.next();
        Socket socket = null;
        try {
            System.out.println("客户端"+no+"开始连接服务器..");
           socket = new Socket("127.0.0.1",port);
           if(socket!=null){
               System.out.println("客户端:"+no+"连接服务器成功!");
           }
            OutputStream out = socket.getOutputStream();
           while(true){
               System.out.println("客户端"+no+"请输入要发送字符(输入quit表示结束):");
               String str = sc.next();
               if(str.trim().equalsIgnoreCase("quit"))
                   break;
               out.write((no+":"+str).getBytes());
           }
            System.out.println("客户端"+no+"连接中断");
           out.close();
           socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}