标签：DatagramSocket UDP DatagramPacket Java java 聊天室 import new dp

在Java中通过UDP来实现简易的聊天室功能

方法一：使用线程

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner;

public class _UDP简易聊天室by线程 {
    public static void main(String[] args) {
        new Thread(new Sender()).start();
        new Thread(new Receiver()).start();
    }
}

class Sender implements Runnable {

    @Override
    public void run() {
        //
        try {
            DatagramSocket ds = new DatagramSocket();
            Scanner sc = new Scanner(System.in);
            while (true) {
                byte[] message = sc.nextLine().getBytes();
                DatagramPacket dp = new DatagramPacket(message,
                        message.length,
                        new InetSocketAddress("255.255.255.255", 8091));

                ds.send(dp);


            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

class Receiver implements Runnable {

    @Override
    public void run() {
        try {
            DatagramSocket ds = new DatagramSocket(8091);
            DatagramPacket dp = new DatagramPacket(new byte[1024], 1024);

            while (true) {
                ds.receive(dp);
                System.out.println(dp.getAddress());
                System.out.println(new String(dp.getData(), 0, dp.getLength()));
            }
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}

方法二：

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


public class _UDP简易聊天室接收端 {
    public static void main(String[] args) throws IOException {
        while (true) {
            DatagramSocket ds = new DatagramSocket(8091);

            DatagramPacket dp = new DatagramPacket(new byte[100], 100);

            ds.receive(dp);
            ds.close();


            System.out.println(dp.getAddress());

            System.out.println(new String(dp.getData(), 0, dp.getLength()));
        }
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.util.Scanner;

public class _UDP简易聊天室发送端 {
    public static void main(String[] args) throws IOException {
        boolean flag = true;
        while (flag == true) {
            Scanner sc = new Scanner(System.in);
            String message = sc.nextLine();
            DatagramSocket ds = new DatagramSocket();
            DatagramPacket dp = new DatagramPacket(message.getBytes(),
                    message.getBytes().length,
                    new InetSocketAddress("127.0.0.1", 8091));
            flag = false;
            //发送数据包
            ds.send(dp);

            //关流
            ds.close();
            flag = true;
        }
    }
}

标签：DatagramSocket,UDP,DatagramPacket,Java,java,聊天室,import,new,dp
来源： https://blog.csdn.net/Wuguan_7/article/details/119042768

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。