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建立群聊系统代码实例的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！