会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132838个问题
Python 全系列/第八阶段:轻量级Web开发利器-Flask框架/虚拟环境 33781楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 33783楼

package cn;

import java.io.IOException;
import java.net.*;
import java.util.Scanner;
/**客户端1
*/
public class UDPClient1 {
    public static void main(String[] args) throws IOException {
        //创建DatagramSocket对象
        DatagramSocket ds = new DatagramSocket(8888);//本应用程序端口
        while (true){
            try {
                //准备要发送的数据
                byte[]buf = talk().getBytes();
                //创建数据对象
                DatagramPacket dp1 = new DatagramPacket(
                        buf, buf.length, InetAddress.getByName("localhost"), 9999);
                //发送数据
                ds.send(dp1);
                byte[]buf2 = new byte[8196];
                DatagramPacket dp2 = new DatagramPacket(
                        buf, buf.length);
                ds.receive(dp2);
                System.out.println(new String(dp2.getData()));
                buf2=null;
                buf2 = new byte[1024];//清空残余数据
            } catch (IOException e) {
                e.printStackTrace();
                //关闭
                ds.close();
            }
        }
    }

    /**
     * 用户输入聊天信息
     * @return
     */
    public static String talk(){
        Scanner sc = new Scanner(System.in);
        return "客户端1:"+sc.nextLine();
    }
}
package cn;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;
/**客户端2
*/
public class UDPCLient2 {
    public static void main(String[] args) throws IOException {
        DatagramSocket ds1 = new DatagramSocket(9999);
        byte []buf = new byte[8196];

        while (true){
            DatagramPacket dp1 = new DatagramPacket(
                    buf,buf.length);
            //查看接收到的数据
            ds1.receive(dp1);
            String str = new String(dp1.getData());
            buf=null;//清空残余数据,重新分配新的空间
            buf = new byte[8196];
            System.out.println(str);
            byte[]buf2 = talk().getBytes();
            DatagramPacket dp2 = new DatagramPacket(
                    buf2,buf2.length,dp1.getAddress(),dp1.getPort());
            try {
                ds1.send(dp2);
            } catch (IOException e) {
                e.printStackTrace();
                //关闭流
                ds1.close();
            }
        }
    }

    /**
     * 用户输入聊天信息
     * @return
     */
    public static String talk(){
        Scanner sc = new Scanner(System.in);
        return "客户端2:"+sc.nextLine();
    }
}

    上述代码实现了两个客户端的简单通信。

     但是有BUG,就是两个客户端启动后,只有客户端1给客户端2发送数据后,双方通信才正常。

     原因可能是客户端2在通信前不知道客户端的地址和端口号

     目前暂时找不到解决办法,请老师给指导指导呗,谢谢@_@

JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 33784楼
Python 全系列/第八阶段:轻量级Web开发利器-Flask框架/Flask视图基础和URL 33786楼
Python 全系列/第八阶段:轻量级Web开发利器-Flask框架/Flask视图基础和URL 33787楼
Python 全系列/第一阶段:Python入门/面向对象 33788楼
Python 全系列/第十四阶段:Python 爬虫开发/动态数据抓取 33790楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/手写服务器项目(旧) 33791楼
JAVA 全系列/(旧的隐藏)第七阶段:JAVA 高级技术/Linux 33793楼
WEB前端全系列/第五阶段:前后端交互/PHP、数据库编程与设计 33794楼
JAVA 全系列/(旧的隐藏)第十一阶段:spring全家桶(Spring Boot)/Spring Boot 33795楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637