java使用udp实现简单多人聊天功能

本文实例为大家分享了udp实现简单的多人聊天功能,供大家参考,具体内容如下

多个客户端向服务器发送信息,服务端再将信息返回到各个客户端。

这是接收udp的实现类:

public class Rec implements Runnable{
    private DatagramSocket ds;
    public Rec(DatagramSocket ds){
        this.ds = ds;
    }
    @Override
    public void run() {
        while(true){
            //接受数据和打印数据
            byte[] buf= new byte[1024];
            DatagramPacket pac = null;
            try {
                pac = new DatagramPacket(buf,buf.length);
                ds.receive(pac);//接收数据
            } catch (IOException e) {
                e.printStackTrace();
            }
            //获得消息
            String info = new String(pac.getData(),0,pac.getLength());
            //获得ip地址
            String ip = pac.getAddress().getHostAddress();
            String port = pac.getPort()+"";
            String name = info.substring(0, info.lastIndexOf(":"));
            if(!name.equals(Thread.currentThread().getName())){
                System.out.println(info);
            }
        }
    }
}

这是发送udp的实现类:

public class Send implements Runnable {
        private DatagramSocket ds;//负责发送和接受数据
        private int receport;//准备发送的端口号
        private String ipAddress; //准备发送的ip地址
        public Send(DatagramSocket ds,int receport,String ipAddress){
            this.ds = ds;
            this.ipAddress = ipAddress;
            this.receport = receport;
        }
        @Override
        public void run() {
            // 多线程发送消息
            Scanner sc = new Scanner(System.in);
            InetAddress ip = null;
            try {
               // String ipad = ipAddress.substring(0, ipAddress.lastIndexOf(":"));//ip地址
                ip = InetAddress.getByName(ipAddress);
            } catch (UnknownHostException e) {
                e.printStackTrace();
            }
            while(true){
                String info = sc.nextLine();
                info=Thread.currentThread().getName()+":"+info;
                byte[] bs = info.getBytes();
                //把数据封装为数据包
                //数据包有四个部分组成
                DatagramPacket pack = new DatagramPacket(bs,bs.length,ip,receport);
                try {
                    ds.send(pack);
                    String content=info.substring(info.lastIndexOf(":")+1);
                    if(content.equals("886")){
                        System.out.println("已退出聊天室");
                        break;
                    }
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }

服务端:

我是模拟的本地多用户,端口号不能重复所以设置了6001-6005,线上只需同一接收udp端口号即可。

public class ServerCilent {
    public static void main(String[] args) throws IOException {
        //接受数据包
        DatagramSocket rec = new DatagramSocket(6262);//接收端口号
        //建立发送类
        DatagramSocket send = new DatagramSocket(); //发送数据
        List<String> addressList=new ArrayList<>();//存放所有发送数据用户的ip
        while (true) {
            //定义一个数据包接受数据
            byte[] bs = new byte[1024];
            DatagramPacket dp = new DatagramPacket(bs, bs.length);
            //接受数据
            rec.receive(dp);
            InetAddress address = dp.getAddress();
            String s = address.toString();
            String ip = s.substring(s.lastIndexOf("/") + 1);//ip
            //判断ip是否已存在List中
            int index=1;
            for (String s1 : addressList) {
                if(s1.equals(ip)){
                    index=-1;
                }
            }
            if(index>0){
                addressList.add(ip);
            }
            //取出数据
            //dp.getData()获取发送数据的字节数组,dp.getLength()获取发送内容的长度
            String info = new String(dp.getData(), 0, dp.getLength());
            System.out.println("客户端发送来的信息:" + info);
            //--------------------服务器转发--------------------------//
            String content=info.substring(info.lastIndexOf(":")+1);
            if (content.equals("886")) {
                String name=info.substring(0,info.lastIndexOf(":"));
                info=name+":退出了聊天室";
            }
            //建立数据包 并转发信息
            byte[] bs1 = info.getBytes();
            for (String s1 : addressList) {
                for (int i=6001;i<=6005;i++){
                    DatagramPacket dp1 = new DatagramPacket(bs1, bs1.length, InetAddress.getByName(s1), i);
                    send.send(dp1);
                }
            }
        }
    }
}

客户端测试:

public class Test1 {
    public static void main(String[] args) throws SocketException {
        Send s=new Send(new DatagramSocket(),6262,"127.0.0.1");
        Rec rec=new Rec(new DatagramSocket(6001));
        new Thread(s,"宸").start();
        new Thread(rec,"宸").start();
    }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • java聊天室的实现代码

    本文实例为大家分享了java实现聊天室的具体代码,供大家参考,具体内容如下 聊天室界面: 源码: public class ClientFrame extends Frame { private TextField textFieldContent = new TextField(); private TextArea textAreaContent = new TextArea(); private Socket socket = null; private OutputStream out

  • java中UDP简单聊天程序实例代码

    学过计算机网络通信的都知道,计算机之间传送数据由两种,即TCP通信和UDP通信.TCP是可靠的面向连接的通信协议,二UDP是不可靠的面向无连接的通信协议. java中有基于TCP的网络套接字通信,也有基于UDP的用户数据报通信,UDP的信息传输速度快,但不可靠! 基于UDP通信的基本模式: (1)将数据打包,称为数据包(好比将信件装入信封一样),然后将数据包发往目的地. (2)接受别人发来的数据包(好比接收信封一样),然后查看数据包中的内容. 客户机 复制代码 代码如下: package com

  • 使用Java和WebSocket实现网页聊天室实例代码

    在没介绍正文之前,先给大家介绍下websocket的背景和原理: 背景 在浏览器中通过http仅能实现单向的通信,comet可以一定程度上模拟双向通信,但效率较低,并需要服务器有较好的支持; flash中的socket和xmlsocket可以实现真正的双向通信,通过 flex ajax bridge,可以在javascript中使用这两项功能. 可以预见,如果websocket一旦在浏览器中得到实现,将会替代上面两项技术,得到广泛的使用.面对这种状况,HTML5定义了WebSocket协议,能更

  • java实现基于UDP协议的聊天小程序操作

    UDP(User Data Protocol,用户数据报协议)是与TCP相对应的协议.它是面向非连接的协议,它不与对方建立连接,而是直接就把数据包发送过去! UDP适用于一次只传送少量数据.对可靠性要求不高的应用环境.正因为UDP协议没有连接的过程,所以它的通信效率高:但也正因为如此,它的可靠性不如TCP协议高.QQ就使用UDP发消息,因此有时会出现收不到消息的情况. 利用UDP协议的发送和接收,模拟聊天小程序 创建聊天程序的A端: 1.发送信息到接收端                 1 .准

  • java UDP实现一个聊天工具的示例代码

    题目: 假设Tom和Jerry利用Java UDP进行聊天,请为他们编写程序.具体如下: (1).Tom和Jerry聊天的双方都应该具有发送端和接收端: (2).利用DatagramSocket与DatagramPacket: (3).实现 java.lang.Runnable类,重写 run()方法. 学过计网的都知道,利用三元组(ip地址,协议,端口)就可以标识网络的进程了. 而进行通信我们直接运用socket就可以了,首先需要知道是socket是什么,这部分可以参考这个大佬写的博客. ht

  • java网络之基于UDP的聊天程序示例解析

    基于UDP的Socket通信 UDP协议不是一种基于稳定连接的协议,是一种面向数据报包的通信协议,不需要通信双方建立稳定的连接,也没有所谓服务端和客户的概念,数据报包在传输的时候不保证一定及时到达,也不能保证数据报包的到达顺序,但是UDP协议传输效率要远高于TCP/IP. 以下是一个基于UDP的简单的消息发送接收程序. 消息发送方 1.创建一个数据报的网络通道 DatagramSocket ds = new DatagramSocket(); 2.准备需要传输的数据 String msg = "

  • Java网络编程UDP实现消息发送及聊天

    TCP可以实现聊天,UDP也可以实现消息发送及聊天.不同的是,TCP需要有服务端和客户端的连接,但UDP不需要,只需要有发送方和接收方即可. 一.实现消息发送 发送方: package com.kuang.lesson03; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.SocketException; //不需要连接服务器

  • Java基于UDP协议实现简单的聊天室程序

    最近比较闲,一直在抽空回顾一些Java方面的技术应用. 今天没什么事做,基于UDP协议,写了一个非常简单的聊天室程序. 现在的工作,很少用到socket,也算是对Java网络编程方面的一个简单回忆. 先看一下效果: 实现的效果可以说是非常非常简单,但还是可以简单的看到一个实现原理.  "聊天室001"的用户,小红和小绿相互聊了两句,"聊天室002"的小黑无人理会,在一旁寂寞着. 看一下代码实现: 1.首先是消息服务器的实现,功能很简单: •将客户端的信息(进入了哪一

  • java使用UDP实现多人聊天功能

    使用UDP实现简单聊天功能,供大家参考,具体内容如下 使用UDP实现一个简单的多人聊天功能.该程序使用了多线程,实现了聊天功能. package 课后作业.E103_10_聊天; import java.io.IOException; import java.net.*; import java.util.Scanner; //接收 class Receive implements Runnable{     @Override     public void run() {         D

  • Java网络编程UDP实现多线程在线聊天

    本文实例为大家分享了Java实现多线程在线聊天的具体代码,供大家参考,具体内容如下 上一篇博客通过UDP实现了聊天,但只能单方面发送消息,这次实现了多线程在线聊天,也就是可以双方互发消息. 发送消息: package com.kuang.chat; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket;

随机推荐