基于UDP协议实现聊天系统

/**-------------------
 * 发送端
 **---------------------*/
class Client extends Thread{
    private static String content;       //发送内容
    private static int port;             //发送端口
    private static int target;           //目标端口
    private static byte[] addr;          //目标ip地址
        /**-------------------
         *构造函数
         **---------------------*/
    public Client(String content,int port,int target,byte[] addr){
        this.content=content;
        this.port=port;
        this.target=target;
        this.addr=addr;
    }
        /**-------------------
         *发送端函数
         **---------------------*/
    public void run(){
        DatagramSocket client= null;
        try {
            //定义发送端端口为 port 的DatagramSocket对象
            client = new DatagramSocket(port);
        } catch (SocketException e) {
            e.printStackTrace();
        }
        String str=content;

        DatagramPacket packet= null;
        try {
            //定义DatagramPacket对象，用于封装发送的数据以及目标地址 target
            packet = new DatagramPacket(str.getBytes(),str.getBytes().length,
                    InetAddress.getByAddress(addr),target);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }
        try {
            //发送数据
            client.send(packet);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //关闭释放资源
        client.close();
    }
}

    /**-------------------
     *接收端
     **---------------------*/
class Server extends Thread{
    private static JTextArea jt;           //对话框
    private static int target;             //目标端口
        /*-------------------
              构造函数
        ---------------------*/
    public  Server(JTextArea jt,int target){
        this.jt=jt;
        this.target=target;
    }

    /*-------------------
    接收端
    ---------------------*/
class Server extends Thread{
    private static JTextArea jt;           //对话框
    private static int target;             //目标端口
        /*-------------------
              构造函数
        ---------------------*/
    public  Server(JTextArea jt,int target){
        this.jt=jt;
        this.target=target;
    }

        /*-------------------
              接收端函数
        ---------------------*/
    public void run(){
        String str;
        DatagramSocket server= null;

        try {
            //定义一个端口号为 target 的接收端DatagramSocket对象
            server = new DatagramSocket(target);
        } catch (SocketException e) {
            e.printStackTrace();
        }
        byte[] buf=new byte[1024];
        //定义一个DatagramPacket数据报对象，用于封装接收数据
        DatagramPacket packet=new DatagramPacket(buf, buf.length);

        while (true){
            try {
                //等待接收数据，在数据没有被接收到之前会被堵塞
                server.receive(packet);
            } catch (IOException e) {
                e.printStackTrace();
            }
            //使用DatagramPacket的方法获得接收到的信息，并转为字符串类型
            str=new String(packet.getData(),
                    0,packet.getLength());
            //将接收到的信息打印到对话框
            jt.append("接收到："+str+"\n");
        }
    }
}

public class Main {
    public static int port;
    public static int target;
    public static byte[] addr;
    public static void Login(){
        System.out.print("请输入端口号：");
        Scanner ScPort=new Scanner(System.in);
        port=ScPort.nextInt();

        System.out.print("请输入目标端口号1：");
        Scanner ScTarget=new Scanner(System.in);
        target=ScTarget.nextInt();

        System.out.print("请输入目标端口号2：");
        Scanner ScTarget2=new Scanner(System.in);
        int target2=ScTarget2.nextInt();

        System.out.print("请输入目标IP地址：");
        Scanner Scaddr=new Scanner(System.in);
        /*---------------------
        将目标IP存储到数组中
        -----------------------*/
        String ip=Scaddr.nextLine();
        /*---------------------
        public String[] split(String regex)：
             根据给定正则表达式的匹配拆分此字符串
         ----------------------*/
        String[] ii=ip.split("\\.");
        /*---------------------
        我们现在使用的IPv4是用一个32位的二进制数来存储的，为了方便记忆，
        会将其分成4个8位的二进制数（4个一字节的二进制数），每8位之间用圆点隔开。
        而每8位二进制数可以转换为一个0~255的十进制数，例如103.42.176.244，
        这种写法被称为点数表示法
         ----------------------*/
        byte[] addr=new byte[4];
        for(int i=0;i<4;i++){
            addr[i]=(byte)(Integer.parseInt(ii[i]));
        }

        System.out.println("窗口启动中....");
        new Thread(new Server(CreateAndShowGUI(port,target,addr),target2),"接收服务").start();
    }
    /*-------------------
    GUI界面
    ---------------------*/
    public static JTextArea CreateAndShowGUI(int port,int target,byte[] addr){
        /*---------------------
        创建界面
         ----------------------*/
        JFrame jf=new JFrame("聊天界面");
        jf.setLocation(400,200);
        jf.setSize(400,300);
        /*---------------------
        设置布局
         ----------------------*/
        jf.setLayout(new BorderLayout());
        jf.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        /*---------------------
        创建聊天窗口
         ----------------------*/
        JTextArea jt=new JTextArea(14,34);
        JScrollPane scrollPane=new JScrollPane(jt);
        jt.setEditable(false);
        /*---------------------
        创建发送窗口
         ----------------------*/
        JTextField jte=new JTextField(20);

        JButton jb=new JButton("发送");
        jb.addActionListener(e->{
            String content=jte.getText();
            /*---------------------
            为发送按钮创建动作
             ----------------------*/
            if (content!=null&&!content.trim().equals("")){
                /*-------------------
                判断信息是否为空
                若为空，在在对话框提示 你输入的内容为空
                反之发送
                 --------------------*/
                jt.append("输入信息为："+content+"\n");
                /*--------------
                将发送框信息发送到目标对话框
                传入Client方法的参数分别为
                “发送内容，发送端口，目标端口，目标IP地址”
                ----------------*/
                try {
                    new Thread(new Client(content,port,target,addr),"发送服务").start();
                } catch (Exception exception) {
                    exception.printStackTrace();
                }
            }else{
                jt.append("你输入的内容为空");
            }
            jte.setText("");      //信息发送后，将发送框重置
        });

        JPanel jp=new JPanel();
        JLabel jl=new JLabel("聊天信息");

        jp.add(jl);
        jp.add(jte);
        jp.add(jb);
        jf.add(jt,BorderLayout.PAGE_START);
        jf.add(jp,BorderLayout.PAGE_END);
        //显示GUI界面
        jf.setVisible(true);
        return jt;
    }

    public static void main(String[] args) throws Exception{
        Login();
    }
}