java使用MulticastSocket实现多点广播
这篇文章主要为大家详细介绍了java使用MulticastSocket实现多点广播，具有一定的参考价值，感兴趣的小伙伴们可以参考一下datagramsocket只允许数据报发送给指定的目标地址，而multicastsocket可以将数据报以广播方式发送到数量不等的多个客户端。
若要使用多点广播时，则需要让一个数据报标有一组目标主机地址，当数据报发出后，整个组的所有主机都能收到该数据报。ip多点广播实现了将单一信息发送到多个接收者的广播，其思想是设置一组特殊网络地址作为广播地址，每个多点广播地址都被看做一个组，当客户端主要发送、接收信息时，加入到该组即可。
ip协议为多点广播提供了这批特殊的ip地址，这些地址的ip地址范围是224.0.0.0至239.255.255.255。
通过java实现多点广播时，multicastsocket类是实现这一功能的关键，当multicastsocket把一个datagrampacket发送到多点广播的ip地址，该数据报将被自动广播到加入该地址的所有multicastsocket类既可以发送数据报到多点广播地址，也可以接受其他主机的广播信息。
multicastsocket有点像datagramsocket，事实上multicastsocket是特殊的datagramsocket。若要发送一个数据报时，可使用随机端口段间multicastsocket，也可以指定端口来创建multicastsocket。
multicastsocket提供了如下三个构造器
public multicastsocket():使用本机默认地址、随机端口来创建一个multicastsocket对象。
public multicastsocket(int number):使用本机默认地址、指定端口来创建一个multicastsocket对象。
public multicastsocket(socketaddress bindaddr):使用本机指定ip地址、指定端口来创建一个multicastsocket对象。
创建一个multicastsocket对象后，还需要将该multicastsocket加入到指定的多点广播地址，multicastsocket使用joingroup()方法来加入指定组；使用leavegroup()方法脱离一个组。
joingroup(inetaddress multicastaddr)：将该multicastsocket加入指定的多点广播地址
leavegroup(inetaddress multicastaddr)：让该multicastsocket离开指定的多点广播地址。
在某些系统中，可能有多个网络接口。这可能会对多点广播带来问题，这时候程序需要在一个指定的网络接口上监听，通过调用setinterface可选择multicastsocket所使用的网络接口；页可以使用getinterface方法查询multicastsocket监听的网络接口。
如果创建仅用于发送数据报的multicastsocket对象，则使用默认地址、随机端口即可。但如果创建接收用的multicastsocket对象，则该multicastsocket对象必须有指定端口，否则发送方无法确定发送的数据报的目标端口。
multicastsocket用于发送，接收数据报的方法与datagramsocket的完全一样。但multicastsocket比datagramsocket多一个settimetolive(int ttl)的方法，该ttl参数设置数据报最多可以跨过几个网络，当ttl为0时，指定数据报应停留在本地主机；当ttl的值为1时，指定数据报发送到本地局域网；当ttl的值为32时，意味着只能发送到本站点的网络上；当ttl为64时，意味着数据报应保留在本地区。当ttl为128时，意味着数据报应保留在本大洲。当ttl为255时，意味着数据报可发送到所有地方。默认情况下，该ttl的值为1。
使用multicastsocket进行多点广播时所有通信实体都是平等的，他们都将自己的数据报发送到多点广播ip地址，并使用multicastsocket接收其他人发送的广播数据报。
import java.io.ioexception;
import java.net.datagrampacket;
import java.net.inetaddress;
import java.net.multicastsocket;
import java.util.scanner;
//让该类实现runnable接口，该类的实例可作为线程的target
public class test implements runnable {
// 使用常量作为本程序的多点广播ip地址
private static final string broadcast_ip = "230.0.0.1";
// 使用常量作为本程序的多点广播目的的端口
public static final int broadcast_port = 30000;
// 定义每个数据报的最大大小为4k
private static final int data_len = 4096;
// 定义本程序的multicastsocket实例
private multicastsocket socket = null;
private inetaddress broadcastaddress = null;
private scanner scan = null;
// 定义接收网络数据的字节数组
byte[] inbuff = new byte;
// 以指定字节数组创建准备接受数据的datagrampacket对象
private datagrampacket inpacket = new datagrampacket(inbuff, inbuff.length);
// 定义一个用于发送的datagrampacket对象
private datagrampacket outpacket = null;
public void init() throws ioexception {
try {
// 创建用于发送、接收数据的multicastsocket对象
// 因为该multicastsocket对象需要接收，所以有指定端口
socket = new multicastsocket(broadcast_port);
broadcastaddress = inetaddress.getbyname(broadcast_ip);
// 将该socket加入指定的多点广播地址
socket.joingroup(broadcastaddress);
// 设置本multicastsocket发送的数据报被回送到自身
socket.setloopbackmode(false);
// 初始化发送用的datagramsocket，它包含一个长度为0的字节数组
outpacket = new datagrampacket(new byte, 0, broadcastaddress, broadcast_port);
// 启动以本实例的run()方法作为线程体的线程
new thread(this).start();
// 创建键盘输入流
scan = new scanner(system.in);
// 不断读取键盘输入
while (scan.hasnextline()) {
// 将键盘输入的一行字符串转换字节数组
byte[] buff = scan.nextline().getbytes();
// 设置发送用的datagrampacket里的字节数据
outpacket.setdata(buff);
// 发送数据报
socket.send(outpacket);
}
} finally {
socket.close();
}
}
public void run() {
try {
while (true) {
// 读取socket中的数据，读到的数据放在inpacket所封装的字节数组里。
socket.receive(inpacket);
// 打印输出从socket中读取的内容
system.out.println("聊天信息：" + new string(inbuff, 0, inpacket.getlength()));
}
}
// 捕捉异常
catch (ioexception ex) {
ex.printstacktrace();
try {
if (socket != null) {
// 让该socket离开该多点ip广播地址
socket.leavegroup(broadcastaddress);
// 关闭该socket对象
socket.close();
}
system.exit(1);
} catch (ioexception e) {
e.printstacktrace();
}
}
}
public static void main(string[] args) throws ioexception {
new test().init();
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持CodeAE代码之家。
原文链接：https://blog.csdn.net/u014142287/article/details/53438650
http://www.zzvips.com/article/174011.html
页:
[1]