Java编程使用UDP建立群聊系统代码实例

 更新时间:2018年01月05日 11:26:23   作者:GavinZhou_xd  
这篇文章主要介绍了Java编程使用UDP建立群聊系统代码实例,具有一定借鉴价值,需要的朋友可以参考下。

相关java类介绍

DatagramSocket

public class DatagramSocket extends Object

此类表示用来发送和接收数据报包的套接字。

数据报套接字是包投递服务的发送或接收点。每个在数据报套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由,也可能按不同的顺序到达。

在DatagramSocket上总是启用UDP广播发送。为了接收广播包,应该将DatagramSocket绑定到通配符地址,在某些实现中,将DatagramSocket绑定到一个更加具体的地址时广播包也可以被接收.

可以通过DatagramSocket的send和receive来发送和接收数据.

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数据报包,数据报包用来实现无连接包投递服务

构造方法:

DatagramPacket(byte[]buf,intlength)

构造DatagramPacket,用来接收长度为length的数据包

DatagramPacket(byte[]buf,intlength,InetAddressaddress,intport)

构造数据报包,用来将长度为length的包发送到指定主机上的指定端口号

UDP群聊系统的示例

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

发送方

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和主机名

总结

以上就是本文关于Java编程使用UDP建立群聊系统代码实例的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!

相关文章

  • 详谈jpa中表的@OneToMany等关联关系

    详谈jpa中表的@OneToMany等关联关系

    这篇文章主要介绍了详谈jpa中表的@OneToMany等关联关系,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12
  • Java设计模式之外观模式示例详解

    Java设计模式之外观模式示例详解

    外观模式为多个复杂的子系统,提供了一个一致的界面,使得调用端只和这个接口发生调用,而无须关系这个子系统内部的细节。本文将通过示例详细为大家讲解一下外观模式,需要的可以参考一下
    2022-08-08
  • MyBatis自定义类型转换器实现加解密

    MyBatis自定义类型转换器实现加解密

    这篇文章主要介绍了MyBatis自定义类型转换器实现加解密的相关资料,需要的朋友可以参考下
    2016-07-07
  • java虚拟机学习笔记进阶篇

    java虚拟机学习笔记进阶篇

    在本篇内容里小编给大家分享了关于java虚拟机学习笔记的进阶内容,需要的朋友们跟着学习下。
    2019-06-06
  • java冒泡排序和快速排序代码

    java冒泡排序和快速排序代码

    本文主要介绍了java冒泡排序和快速排序的实例代码。具有很好的参考价值。下面跟着小编一起来看下吧
    2017-04-04
  • Springboot实现验证码登录

    Springboot实现验证码登录

    这篇文章主要为大家详细介绍了Springboot实现验证码登录,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-07-07
  • jar包双击执行程序的方法

    jar包双击执行程序的方法

    这篇文章主要介绍了jar包双击执行程序的方法,可实现双击jar包直接执行Java程序的功能,具有一定的参考借鉴价值,需要的朋友可以参考下
    2014-12-12
  • Java Zookeeper分布式分片算法超详细讲解流程

    Java Zookeeper分布式分片算法超详细讲解流程

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等
    2023-03-03
  • 使用Spring自身提供的地址匹配工具匹配URL操作

    使用Spring自身提供的地址匹配工具匹配URL操作

    这篇文章主要介绍了使用Spring自身提供的地址匹配工具匹配URL操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • java实现单链表中是否有环的方法详解

    java实现单链表中是否有环的方法详解

    本篇文章介绍了,用java实现单链表中是否有环的方法详解。需要的朋友参考下
    2013-05-05

最新评论