[网络协议]Java学习---JavaSE----基础聊天室实现

*多线程互相发送与接收

封装两个线程

发送端

package com.TaskUDP;

import javax.print.attribute.standard.NumberUp;
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 TaskSender implements Runnable {

    DatagramSocket datagramSocket = null;
    BufferedReader reader =null;

    private int formPort;
    private String toIP;
    private int toPort;

    public TaskSender(int formPort, String toIP, int toPort) {
        this.formPort = formPort;
        this.toIP = toIP;
        this.toPort = toPort;
        try {
            //创建一个socket
            datagramSocket = new DatagramSocket(formPort);
            //准备数据，读取控制台system in
            reader = new BufferedReader(new InputStreamReader(System.in));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        //持续聊天
        while (true){
            try {
                //接收控制台输入的数据
                String date=reader.readLine();
                //转为字节数组
                byte[] dates=date.getBytes();
                //数据入流
                DatagramPacket packet = new DatagramPacket(dates, 0, dates.length,new InetSocketAddress(this.toIP,this.toPort));
                //发送流
                datagramSocket.send(packet);
                //退出
                if (date.equals("bye")){
                    break;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        //关闭流
        datagramSocket.close();
    }
}

接收端

package com.TaskUDP;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class TaskReceive implements Runnable{
    DatagramSocket datagramSocket =null;

    private int port;
    private String msgForm;

    public TaskReceive(int port,String msgForm) {
        this.port = port;
        this.msgForm=msgForm;
        try {
            //创建一个socket
            datagramSocket = new DatagramSocket(port);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        while (true){
            try {
                //准备接收包
                byte[] container = new byte[2048];
                DatagramPacket datagramPacket = new DatagramPacket(container,0,container.length);
                //阻塞接收数据
                datagramSocket.receive(datagramPacket);
                //断开连接
                //获取数据变为字节数组
                byte[] data = datagramPacket.getData();
                //类型转换
                String receiveDate = new String(data, 0, data.length);
                //显示数据
                System.out.println(msgForm+":"+receiveDate);
                //退出循环
                if (receiveDate.equals("bye")){
                    break;
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        //关闭流
        datagramSocket.close();
    }
}

实现

package com.TaskUDP;

public class TaskStudent {
    public static void main(String[] args) {
        //开启两个线程
        Thread sender = new Thread(new TaskSender(7777,"localhost",9999));
        Thread Recevie = new Thread(new TaskReceive(8888,"老师"));
        //开启线程
        sender.start();
        Recevie.start();
    }
}

package com.TaskUDP;

public class TaskTaecher {
    public static void main(String[] args) {
        //开启两个线程
        Thread sender = new Thread(new TaskSender(5555,"localhost",8888));
        Thread Recevie = new Thread(new TaskReceive(9999,"学生"));
        //开启线程
        sender.start();
        Recevie.start();
    }
}