Java数据报编程之组播

在信息时代，网络技术应用已经很普通。其中很多应用都依赖于从一个主机向多个主机或者从多个主机向多个主机发送同一信息的能力，在Internet上分发的数目可能达数十万台，这些都需要更高的带宽，并且大大超出了单播的能力。一种能最大限度地利用现有带宽的重要技术是IP组播。

1．IP组播技术的概念

IP组播技术，是一种允许一台或多台主机（组播源）发送单一数据包到多台主机（一次的，同时的）的TCP/IP网络技术,是一点对多点的通信。在网络多媒体广播的应用中，当需要将一个节点的信号传送到多个节点时，无论是采用重复点对点通信方式，还是采用广播方式，都会严重浪费网络带宽，只有组播才是最好的选择。组播能使一个或多个组播源只把数据包发送给特定的组播组，而只有加入该组播组的主机才能接收到数据包。

2．IP组播地址

IP组播通信依赖于IP组播地址，在IPv4中它是一个D类IP地址，范围从224.0.0.0到239.255.255.255，并被划分为局部链接组播地址、预留组播地址和管理权限组播地址三类。其中，局部链接组播地址范围在224.0.0.0~224.0.0.255，这是为路由协议和其它用途保留的地址，路由器并不转发属于此范围的IP包；预留组播地址为224.0.1.0~238.255.255.255，可用于全球范围（如Internet）或网络协议；管理权限组播地址为239.0.0.0~239.255.255.255，可供组织内部使用，类似于私有IP地址，不能用于Internet，可限制组播范围。

3．组播组

使用同一个IP组播地址接收组播数据包的所有主机构成了一个主机组，也称为组播组。一个组播组的成员是随时变动的，一台主机可以随时加入或离开组播组，组播组成员的数目和所在的地理位置也不受限制，一台主机也可以属于几个组播组。此外，不属于某一个组播组的主机也可以向该组播组发送数据包。

本文使用MulticastSocket类的实例编写组播应用，MulticastSocket类提供连接和离开组播等操作。

MultiSender类清单

package recmail.multiservice;

import Java.net.*;
import java.io.IOException;

/**
* 该类封装了MulticastSocket类,完成了MulticastSocket类实例的创建、初始化功能,
* 并提供了一个发送数据的接口.
*/

public class MultiSender {
public static final int MultiSender_Port=4099;
private MulticastSocket road;
private InetAddress ia;

public MultiSender() {
try {

//组播地址
ia = InetAddress.getByName("239.66.69.18");
road = new MulticastSocket(MultiSender_Port);
road.joinGroup(ia);
}
catch (UnknownHostException ex) {
}
catch (IOException ex1) {
}
}
public InetAddress getInetAddress(){
return ia;
}
public MulticastSocket getRoad(){
return road;
}
public void send(byte[] b){
DatagramPacket dp = new DatagramPacket(b, 0, b.length,
ia, MultiSender.MultiSender_Port);
try {
road.send(dp);
}
catch (IOException ex) {
ex.printStackTrace();
}
}
}

ImageServer类,使用上面的类发送文件数据.

package recmail.multiservice;
import java.io.*;
import javax.Swing.Timer;
import java.awt.event.*;
import java.awt.image.*;
import java.util.*;
import java.io.FileFilter;
import java.io.FilenameFilter;

/**
* 本类利用MultiSender类发送文件数据到一个组播组发送数据.
*/

public class ImageServer
extends Thread implements ActionListener {
Timer timer;
BufferedImage image;
ArrayList streamfragments;
int counter = 0;
byte[] imagebyte;
ArrayList listener;
MultiSender sender;

public ImageServer(ArrayList f) {
timer = new Timer(50, this);
timer.addActionListener(this);
listener = new ArrayList();
streamfragments = f;
sender = new MultiSender();
timer.start();
}

public void addDataSwapListener(DataSwapListener dsl) {
listener.add(dsl);
}

public void removeDataSwapListener(DataSwapListener dsl) {
listener.remove(dsl);
}

private void processEvent() {
for (int i = 0; i < this.listener.size(); i ) {
DataSwapEvent dse = new DataSwapEvent();
( (DataSwapListener)this.listener.get(i)).OnDataSendFinished(this, dse);
}
}

public void actionPerformed(ActionEvent e) {
DataPacket dp = new DataPacket(streamfragments.get(counter).toString());
DataEntry de;
try {
ArrayList al = dp.getDataPackets();
Thread.sleep(1000);
System.out.println(streamfragments.get(counter).toString());
for (int i = 0; i < al.size(); i ) {
imagebyte = ( (DataEntry) al.get(i)).getByte(); //(byte[]) al.get(i);
sender.send(imagebyte);
}
this.processEvent();
}
catch (Exception ex) {
System.out.println(ex);
}
counter ;
if (counter >= streamfragments.size())
counter = 0;
}

public void run() {
while (true) {
try {
this.sleep(20);
}
catch (InterruptedException ex) {
}
}
}

public static void main(String[] args) {
String file[];
ArrayList al = new ArrayList();

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有