java使用MulticastSocket实现多点广播

2025-05-29 0 46

datagramsocket只允许数据报发送给指定的目标地址,而multicastsocket可以将数据报以广播方式发送到数量不等的多个客户端。

若要使用多点广播时,则需要让一个数据报标有一组目标主机地址,当数据报发出后,整个组的所有主机都能收到该数据报。ip多点广播实现了将单一信息发送到多个接收者的广播,其思想是设置一组特殊网络地址作为广播地址,每个多点广播地址都被看做一个组,当客户端主要发送、接收信息时,加入到该组即可。

ip协议为多点广播提供了这批特殊的ip地址,这些地址的ip地址范围是224.0.0.0至239.255.255.255。

java使用MulticastSocket实现多点广播

通过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接收其他人发送的广播数据报。

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85
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[data_len];

// 以指定字节数组创建准备接受数据的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], 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();

}

}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持快网idc。

原文链接:https://blog.csdn.net/u014142287/article/details/53438650

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 java使用MulticastSocket实现多点广播 https://www.kuaiidc.com/110803.html

相关文章

发表评论
暂无评论