#手写聊天室

构建一个聊天室

如何能构建一个小型的聊天室呢，今天狗头哥哥给你们带来了一个小型聊天室的构建！

基于UDP的小型聊天室

一.创建传输方udptalk

``

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;

public class udptalk implements Runnable {
    DatagramSocket datagramSocket = null;
    BufferedReader bufferedReader = null;
    private int fromport;
    private String toip;
    private int toport;

    public udptalk(int fromport, String toip, int toport) {
        this.fromport = fromport;
        this.toip = toip;
        this.toport = toport;
        try {
            datagramSocket = new DatagramSocket(fromport);
            bufferedReader = new BufferedReader(new InputStreamReader(System.in));
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {

        while (true) {
            String data = null;
            try {
                data = bufferedReader.readLine();
                byte[] datas = data.getBytes();
                DatagramPacket datagramPacket = new DatagramPacket(datas, 0, datas.length, new InetSocketAddress(this.toip, this.toport));
                datagramSocket.send(datagramPacket);
                if(data.equals("baibai")){
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }

        }
        datagramSocket.close();

    }

}

二.接收方udptalk2的创建

import java.io.IOException;
import	java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class udptalk2 implements Runnable{
    DatagramSocket datagramSocket = null;
    private int port;
    private String info;
    public udptalk2(int port,String info) {
        this.port = port;
        this.info = info;
        try {
            datagramSocket = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
    }
    @Override
    public void run() {
        while (true) {
            try {
                byte[] data = new byte[10];
                DatagramPacket datagramPacket = new DatagramPacket(data, 0, data.length);
                datagramSocket.receive(datagramPacket);
                byte[] datas = datagramPacket.getData();
                String s = new String(datas, 0, datas.length);
                System.out.println(info +":"+s);
                if (s.equals("baibai")) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        datagramSocket.close();
    }
}

三.多线程双方的实现学生和老师

public class Student {
    public static void main(String[] args) {
        new Thread(new udptalk(666,"localhost",888)).start();
        new Thread(new udptalk2(999,"老师")).start();
    }
}

public class Teacher {
    public static void main(String[] args) {
        new Thread(new udptalk(333,"localhost",999)).start();
        new Thread(new udptalk2(888,"学生")).start();
    }
}

四.测试运行学生端和老师端
student向teacher发送hello，teacher接受并给student发送hello


今天的分享就到这里，有帮助的帮忙点赞分享！谢谢大家。