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(); } } }
本文标题:Java编程使用UDP建立群聊系统代码实例-创新互联
分享地址:http://pwwzsj.com/article/dhdgis.html