使用UDP建立群聊系统

相关java类介绍

DatagramSocket

public class DatagramSocket extends Object

此类表示用来发送和接收数据报包的套接字。 数据报套接字是包投递服务的发送或接收点。每个在数据报套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由,也可能按不同的顺序到达。 在 DatagramSocket 上总是启用 UDP 广播发送。为了接收广播包,应该将 DatagramSocket 绑定到通配符地址,在某些实现中,将 DatagramSocket 绑定到一个更加具体的地址时广播包也可以被接收. 可以通过DatagramSocketsendreceive来发送和接收数据.

public void receive(DatagramPacket p) throws IOException 从此套接字接收数据报包。当此方法返回时,DatagramPacket 的缓冲区填充了接收的数据。数据报包也包含发送方的 IP 地址和发送方机器上的端口号。 此方法在接收到数据报前一直阻塞,数据报包对象的 length 字段包含所接收信息的长度。如果信息比包的长度长,该信息将被截短 如果存在安全管理器,而安全管理器的 checkAccept 方法不允许接收操作,则包不能被接收。 参数: p - 要放置传入数据的 DatagramPacket。 抛出: IOException - 如果发生 I/O 错误。 SocketTimeoutException - 如果先前调用了 setSoTimeout 且超时值已过。 PortUnreachableException - 套接字连接到当前不可达的目标时可能抛出。注意,不能保证一定抛出该异常。 IllegalBlockingModeException - 如果此套接字具有相关联的通道,且通道处于非阻塞模式。

public void send(DatagramPacket p) throws IOException 从此套接字发送数据报包。DatagramPacket 包含的信息指示:将要发送的数据、其长度、远程主机的 IP 地址和远程主机的端口号 如果存在安全管理器,且套接字当前没有连接到远程地址,则此方法首先执行某些安全性检查。首先,如果 p.getAddress().isMulticastAddress() 为 true,则此方法以 p.getAddress() 作为参数调用安全管理器的 checkMulticast 方法。如果该表达式的值为 false,此方法改为调用安全管理器的以 p.getAddress().getHostAddress() 和 p.getPort() 为参数的 checkConnect 方法。如果不允许该操作,则每次调用安全管理器方法都会导致 SecurityException。 参数: p - 将要发送的 DatagramPacket。 抛出: IOException - 如果发生 I/O 错误。 SecurityException - 如果安全管理器存在并且其 checkMulticast 或 checkConnect 方法不允许进行发送。 PortUnreachableException - 套接字连接到当前不可达的目标时可能抛出。注意,不能保证一定抛出该异常。 IllegalBlockingModeException - 如果此套接字具有相关联的通道,且通道处于非阻塞模式。

DatagramPacket

public final class DatagramPacket extends Object

此类表示UDP数据报包,数据报包用来实现无连接包投递服务

构造方法:

  1. DatagramPacket(byte[] buf, int length) 构造 DatagramPacket,用来接收长度为 length 的数据包
  2. DatagramPacket(byte[] buf, int length, InetAddress address, int port) 构造数据报包,用来将长度为 length 的包发送到指定主机上的指定端口号

UDP群聊系统的示例

UDP是面向无连接的,群聊就是向广播地址(broadcasting address)发送数据,这样每个人都会收到消息; 采用线程的方式,启动一个发送方线程和接收方线程,发送方读取键盘输入作为输出,接收方读到输入的信息并显示

发送方

UdpSender.java

package cn.xidian.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;


public class UdpSender extends Thread{

    @Override
    public void run() {
        try {
            //建立UDP的服务
            DatagramSocket socket = new DatagramSocket();
            //准备数据包发送
            //从系统输入读取输入
            BufferedReader in = new BufferedReader(new InputStreamReader(System.in)) ;
            String line = null;
            while((line = in.readLine()) != null){
                //我做测试,写的是本机地址,群聊需要写广播地址,比如:192.168.137.255
                DatagramPacket data = new DatagramPacket(line.getBytes(), line.getBytes().length, InetAddress.getByName("127.0.0.1"), 9090); 
                //发送数据
                socket.send(data);
            }
            //关闭socket
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

接收方

UdpReceiver.java

package cn.xidian.socket;

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

public class UdpReceiver extends Thread {
    @Override
    public void run() {
        try {
            //建立UDP的服务,监听端口
            DatagramSocket socket = new DatagramSocket(9090); 
            //接受数据包
            byte[] temp = new byte[1024];
            DatagramPacket data = new DatagramPacket(temp, temp.length);
            boolean flag = true;
            while(flag){
                socket.receive(data);
                //输出发送方的相关信息
                String senderAddress = data.getAddress().getHostAddress();
                String senderHostName = data.getAddress().getHostName();
                System.out.println(senderHostName+"("+senderAddress+")"+" say: " + new String(temp, 0,data.getLength()));

            }
            //关闭资源
            socket.close();
        }catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Main方法

UdpMain.java

package cn.xidian.socket;

public class UdpMain {
    public static void main(String[] args) {
        //启动UdpReceiver线程
        UdpReceiver receiver = new UdpReceiver();
        receiver.start();

        //启动UdpSender线程
        UdpSender sender = new UdpSender();
        sender.start();

    }
}

测试结果

输入方读取键盘输入作为输出,接收方接收消息并显示发送方的ip和主机名

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏技术小讲堂

ASP.NET AJAX(1)__Microsoft AJAX LibraryASP.NET AJAX(1)__Microsoft AJAX Library

ASP.NET AJAX(1)__Microsoft AJAX Library Microsoft AJAX Library为我们提供的客户端框架,提供的内容大...

2804
来自专栏分布式系统进阶

ReplicaManager源码解析1-消息同步线程管理

基本上就是作三件事: 构造FetchRequest, 同步发送FetchRequest并接收FetchResponse, 处理FetchResponse, 这三...

1222
来自专栏wannshan(javaer,RPC)

利用spring-ws 现实soap webservice服务

背景:有的系统还用soap协议来做webservice.特别要和他们对接的时候。我们需要实现一套。 今天说说,利用spring-ws来(部署,调用)webse...

1.9K6
来自专栏有趣的django

37.Django1.11.6文档

第一步 入门 检查版本 python -m django --version 创建第一个项目 django-admin startproject mysite ...

4268
来自专栏知识分享

java 之UDP编程

大白话:每一台电脑都有自己的ip地址,向指定的ip地址发数据,数据就发送到了指定的电脑。UDP通信只是一种通信方式而已,其特点就不多说。有了ip地址数据就能发送...

2724
来自专栏逆向技术

x64内核HOOK技术之拦截进程.拦截线程.拦截模块

            x64内核HOOK技术之拦截进程.拦截线程.拦截模块 一丶为什么讲解HOOK技术. 在32系统下, 例如我们要HOOK SSDT表,那么...

4477
来自专栏jeremy的技术点滴

sed命令工作原理及命令备忘

3419
来自专栏Spark学习技巧

Hbase源码系列之scan源码解析及调优

一,hbase的scan基本使用问题介绍 Hbase的Scan方法是基于Rowkey进行数据扫描的,过程中client会将我们的请求,转化为向服务端的RPC请求...

3358
来自专栏blog.csdn.net/LHWorld

HBase篇--HBase常用优化

HBase优化能够让我们对调优有一定的理解,当然企业并不是所有的优化全都用,优化还要根据业务具体实施。

1824
来自专栏Star先生的专栏

从源码中分析 Hadoop 的 RPC 机制

RPC是Remote Procedure Call(远程过程调用)的简称,这一机制都要面对两个问题:对象调用方式余与序列/反序列化机制。本文给大家介绍从源码中分...

5620

扫码关注云+社区