Java网络编程实例——简单模拟在线聊天

public class UdpOnlineClient {

    public static void main(String[] args) throws IOException {
        
        DatagramSocket socket = new DatagramSocket(10000);

        BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(System.in));

        while (true) {

            String data = bufferedReader.readLine();
            byte[] datas = data.getBytes();

            DatagramPacket packet = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress("localhost", 9999));

            socket.send(packet);

            if (data.equals("bye")){
                break;
            }

        }
        socket.close();
    }

}

public class UdpOnlineServer {

    public static void main(String[] args) throws IOException {

        DatagramSocket socket = new DatagramSocket(9999);

        while (true){

            byte[] buffer = new byte[1024];

            DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);

            socket.receive(packet);
            String msg = new String(packet.getData(), 0, packet.getLength());

            System.out.println(msg);

            if(msg.equals("bye")){
                break;
            }
        }
        socket.close();

    }

}

public class TaskSend implements Runnable{
	
    private String sendIP;
    //自己的服务端口
    private int ownPort;
    private int sendPort;
    //读取控制台输入流
    private BufferedReader bufferedReader;
    private DatagramSocket socket;

    public TaskSend(String sendIP, int ownPort, int sendPort) {
        this.sendIP = sendIP;
        this.sendPort = sendPort;
        try {
            socket = new DatagramSocket(ownPort);
            bufferedReader = new BufferedReader(new InputStreamReader(System.in));
        } catch (SocketException e) {
            e.printStackTrace();
        } finally {
        }
    }

    //发送消息
    public void run() {
        while (true) {

            try {
                String data = bufferedReader.readLine();
                //打印自己的消息
                System.out.println("我："+data);
                byte[] datas = data.getBytes();

                DatagramPacket packet = new DatagramPacket(datas, 0, datas.length,new InetSocketAddress(sendIP,sendPort));

                socket.send(packet);
                if (data.equals("bye")) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
            }
        }
        socket.close();
    }
}

public class TaskReceive implements Runnable{

    private int ownPort;
    //发送信息的人
    private String msgOwner;
    private DatagramSocket socket;

    public TaskReceive(int ownPort, String msgOwner) {
        this.msgOwner = msgOwner;
        try {
            socket = new DatagramSocket(ownPort);
        } catch (SocketException e) {
            e.printStackTrace();
        } finally {
        }
    }
	
    //接收消息
    public void run() {
        while (true) {
            try {
                byte[] buffer = new byte[1024];
                DatagramPacket packet = new DatagramPacket(buffer, 0, buffer.length);
                socket.receive(packet);
                String msg = new String(packet.getData(), 0, packet.getLength());
                System.out.println(msgOwner+"："+msg);

                if (msg.equals("bye")) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
            }
        }
        socket.close();
    }
}

public class ChatThread1 {

    public static void main(String[] args) {
        new Thread(new TaskSend("localhost",9999,10000)).start();
        new Thread(new TaskReceive(9998,"老师")).start();
    }

}

public class ChatThread2 {

    public static void main(String[] args) {

        new Thread(new TaskReceive(9999,"学生")).start();
        new Thread(new TaskSend("localhost",9998,10001)).start();
    }

}