码迷,mamicode.com
首页 > 其他好文 > 详细

多播(组播)与广播的技术实现

时间:2015-07-31 18:03:24      阅读:137      评论:0      收藏:0      [点我收藏+]

标签:

1、组播是基于路由器之上实现的,要想网络内支持组播,需要有能够管理组播组的路由器或是三层交换机(带部分路由功能的交换机)。通常在我们的网络中,都会支持组播,即我们的程序可以使用组播技术,视频会议就使用这个技术。

2、IP网络的多播一般通过多播IP地址来实现。多播IP地址就是D类IP地址,即224.0.0.0至239.255.255.255之间的IP地址。通常选择230之后的地址,使用UDP协议,把每个客户端(收端和发端)的socket都加入到这个地址上,之后客户端往这个地址上发送一个消息后,在这个组里的其他客户端都可以监听收到这个消息。

3、在java中,java.net.MulticastSocket具有组播的功能,它是DatagramSocket的子类。具体程序如下:


package com.udpdemo.multicast;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.InetAddress;

import java.net.MulticastSocket;

import java.text.SimpleDateFormat;

import java.util.Date;


public
class ServerMulticastSocketTest { public static void main(String[] args) { // TODO Auto-generated method stub MulticastSocket multicastSocket; try { multicastSocket = new MulticastSocket(); InetAddress address = InetAddress.getByName("239.0.0.1"); // 必须使用D类地址 multicastSocket.joinGroup(address); // 以D类地址为标识,加入同一个组才能实现广播 while (true) { String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); byte[] buf = time.getBytes(); DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length); datagramPacket.setAddress(address); // 接收地址和group的标识相同 datagramPacket.setPort(10000); // 发送至的端口号 multicastSocket.send(datagramPacket); Thread.sleep(1000); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
package com.udpdemo.multicast;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;

public class ClientMulticastSocketTest {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        MulticastSocket multicastSocket;
        try {
            multicastSocket = new MulticastSocket(10000);
             InetAddress address = InetAddress.getByName("239.0.0.1");
                multicastSocket.joinGroup(address);
                byte[] buf = new byte[1024];
                
                while (true) {
                    DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length);
                    multicastSocket.receive(datagramPacket); // 接收数据,同样会进入阻塞状态
                    
                    byte[] message = new byte[datagramPacket.getLength()]; // 从buffer中截取收到的数据
                    System.arraycopy(buf, 0, message, 0, datagramPacket.getLength());
                    System.out.println(datagramPacket.getAddress());
                    System.out.println(new String(message));
                }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } // 接收数据时需要指定监听的端口号
       
    }

}


4、广播功能:

    使用255.255.255.255(或者是192.168.10.255,具体ip地址上设置第四个参数为255是本网段的广播地址)的IP地址,所有的客户端都监听这个地址,发这个地址上发送消息,其他的客户端都会接收到。

  java中使用java.net.DatagramSocket来完成监听和发送,发送信息前,要开启广播,即调用socket的setbroadcast(true)。

 

发送端Socket:
void
init_uSock(String sendText) throws Exception{ uSock = new DatagramSocket(); InetAddress host = InetAddress.getByName("192.168.10.255"); byte[] data = sendText.getBytes(); DatagramPacket packet = new DatagramPacket(data, data.length, host, office.local_udp_port); uSock.setBroadcast(true); uSock.send(packet); Log.e("UDP", "发送"); }
接收端Socket:
InetAddress addr
= InetAddress.getByName("192.168.10.255"); DatagramSocket uServ = new DatagramSocket(office.local_udp_port,addr); while (uWork) { DatagramPacket packet = new DatagramPacket(new byte[102400], 102400); uServ.receive(packet); ............. }

 

  

 

多播(组播)与广播的技术实现

标签:

原文地址:http://www.cnblogs.com/wangle1001986/p/4692524.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!