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

public class NetworkServer {
    public static void main(String[] args) throws IOException {
        ServerSocket server = new ServerSocket(9999);
        System.out.println("等待客户端连接");
        Socket sSocket = server.accept();//孔
        System.out.println("连接完毕");
        //服务器向客户端发送消息 写 输出 SocketOutputStream Fi
        while(true){
            OutputStream os = sSocket.getOutputStream();
            PrintWriter writer = new PrintWriter(os);
            Scanner sc = new Scanner(System.in);
            System.out.println("你要说啥?");
            String message = sc.nextLine();
            System.out.println("你说："+message);
            writer.println(message);
            writer.flush();

            InputStream is = sSocket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String message1 = br.readLine();
            System.out.println("客户端说:"+message1);
            if(message.equals("拜拜") || message1.equals("拜拜")){
                break;
            }
        }
    }
}

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

public class NetworkClient {
    public static void main(String[] args) throws IOException {
        Socket cSocket = new Socket("127.0.0.1",9999);
        //流
        while(true){
            InputStream is = cSocket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String message = br.readLine();
            System.out.println("服务器说:"+message);
            OutputStream os = cSocket.getOutputStream();
            PrintWriter writer = new PrintWriter(os);
            Scanner sc = new Scanner(System.in);
            System.out.println("你要说啥?");
            String message1 = sc.nextLine();
            System.out.println("你说："+message1);
            writer.println(message1);
            writer.flush();
            if(message1.equals("拜拜") || message.equals("拜拜")){
                break;
            }
        }
    }
}

import java.io.IOException;
import java.net.*;

public class NetworkReceiveUDP{
    public static void main(String[] args) throws IOException {
        DatagramSocket datagramSocket = new DatagramSocket();
        String s = "你好";
        byte[] bs = s.getBytes();
        DatagramPacket packet = new DatagramPacket(bs,bs.length, InetAddress.getByName("127.0.0.1"),9999);
        for (int i = 0;i<1000000;i++){
            datagramSocket.send(packet);
        }
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class TestSend {
    public static void main(String[] args) throws IOException {
        DatagramSocket datagramSocket = new DatagramSocket(9999);
        byte[] b = new byte[24];
        DatagramPacket datagramPacket = new DatagramPacket(b,0,b.length);
        int count = 0;
        while (true){
            datagramSocket.receive(datagramPacket);
            String s = new String(b,0,datagramPacket.getLength());
            System.out.println(s);
            count++;
            System.out.println(count);
        }
    }
}