java使用MulticastSocket实现组播

组播是一种允许源进程将数据包发送到多个目标进程的网络技术。组播源将数据包发送到特定组播组,只有属于该组播组的进程才能接收到数据包。这些进程可以是在同一个物理网络,也可以来自不同的物理网络(只要有组播路由器支持)。

组播分为无连接和面向连接组播,但是基本的组播机制是无连接的,我们这里所讲的也是无连接组播。

我们说过使用MulticastSocket类,这个类叫组播数据报套接字类,主要用来发送和接收IP组播报文。MulticastSocket是DatagramSocket的子类,它增加了加入和离开组播组的功能。组播组通过一个D类IP地址和一个标准UDP端口号的组合来定义。D类IP地址的范围是224.0.0.0~239.255.255.255,除了224.0.0.0是保留地址,不应使用。

下面我们用一个简单的示例演示两个进程如何使用组播进行通信,这两个进程一个是发送端进程,另一个是接收端进程。

我们看代码:

Sender.java

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

public class Sender {

 public static void main(String[] args) {
 try {
  byte[] msg = new byte[] { 'h', 'e', 'l', 'l', 'o' };
  InetAddress inetAddress = InetAddress.getByName("230.0.0.1");//根据主机名返回主机的IP地址
  DatagramPacket datagramPacket = new DatagramPacket(msg, msg.length, inetAddress, 7777);//数据包包含消息内容,消息长度,组播IP和端口
  MulticastSocket multicastSocket = new MulticastSocket();
  multicastSocket.send(datagramPacket);//发送数据包
 } catch (Exception exception) {
  exception.printStackTrace();
 }
 }
}

Receiver.java

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

public class Receiver {
 public static void main(String[] arstring) {
 try {
  MulticastSocket multicastSocket = new MulticastSocket(7777);//创建组播套接字并绑定到发送端口
  InetAddress inetAddress = InetAddress.getByName("230.0.0.1");
  multicastSocket.joinGroup(inetAddress);//组播套接字加入组播组

  while (true) {
  byte[] data = new byte[100];
  DatagramPacket datagramPacket = new DatagramPacket(data,data.length);//创建一个用于接收数据的数据包
  multicastSocket.receive(datagramPacket);//接收数据包
  System.out.println(new String(data));
  }
 } catch (Exception exception) {
  exception.printStackTrace();
 }
 }
}

使用MulticastSocket实现组播的要点如下:

接收方:加入组播组;
发送方:发送包含组地址的数据报。

顺便提一下组播实现私信的做法:我们可以在消息头部加上指定接收者地址,然后使用组播的方式发送,关键在接收的时候检查该地址,如果跟匹配该地址,就接收并处理;如果不匹配当然就抛弃。当然这明显有安全问题,以后找到解决办法或者单播机制再另写一篇博文了。

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

(0)

相关推荐

  • 学习非阻塞的同步机制CAS

    在研究线程池的执行原理时,看到一段不断循环重试的代码,不理解它的原理,看注释这是CAS的实现,所以学会之后记录下来. 锁有什么劣势 在多线程并发下,可以通过加锁来保证线程安全性,但多个线程同时请求锁,很多情况下避免不了要借助操作系统,线程挂起和恢复会存在很大的开销,并存在很长时间的中断.一些细粒度的操作,例如同步容器,操作往往只有很少代码量,如果存在锁并且线程激烈地竞争,调度的代价很大. 总结来说,线程持有锁,会让其他需要锁的线程阻塞,产生多种风险和开销.加锁是一种悲观方法,线程总是设想在自己持

  • Java多线程之CAS算法实现线程安全

    前言 对于线程安全,我们有说不尽的话题.大多数保证线程安全的方法是添加各种类型锁,使用各种同步机制,用限制对共享的.可变的类变量并发访问的方式来保证线程安全.文本从另一个角度,使用"比较交换算法"(CompareAndSwap)实现同样的需求.我们实现一个简单的"栈",并逐步重构代码来进行讲解. 本文通俗易懂,不会涉及到过多的底层知识,适合初学者阅读(言外之意是各位大神可以绕道了). 旅程开始 1.先定个小目标,实现一个"栈" "栈&q

  • Java并发的CAS原理与ABA问题的讲解

    CAS原理 在计算机科学中,比较和交换(Compare And Swap)是用于实现多线程同步的原子指令. 它将内存位置的内容与给定值进行比较,只有在相同的情况下,将该内存位置的内容修改为新的给定值. 这是作为单个原子操作完成的. 原子性保证新值基于最新信息计算; 如果该值在同一时间被另一个线程更新,则写入将失败. 操作结果必须说明是否进行替换; 这可以通过一个简单的布尔响应(这个变体通常称为比较和设置),或通过返回从内存位置读取的值来完成(摘自维基本科) CAS流程 以AtomicIntege

  • java使用MulticastSocket实现组播

    组播是一种允许源进程将数据包发送到多个目标进程的网络技术.组播源将数据包发送到特定组播组,只有属于该组播组的进程才能接收到数据包.这些进程可以是在同一个物理网络,也可以来自不同的物理网络(只要有组播路由器支持). 组播分为无连接和面向连接组播,但是基本的组播机制是无连接的,我们这里所讲的也是无连接组播. 我们说过使用MulticastSocket类,这个类叫组播数据报套接字类,主要用来发送和接收IP组播报文.MulticastSocket是DatagramSocket的子类,它增加了加入和离开组

  • java 单播、广播、组播详解及实例代码

    java 单播.广播.组播详解及实例代码 在当前网络通信中(TCP/IP也不例外)有三种通信模式:单播.广播.组播(又叫多播, 个人感觉叫多播描述的有点不恰当),其中多播出现的时间最晚,但同时具备单播和广播的优点,最具有发展前景. 一.通信方式分类: 1.单播:单台主机与单台主机之间的通信: 2.广播:单台主机与网络中所有主机的通信: 3.组播:单台主机与选定的一组主机的通信: 二.单播:    单播是网络通信中最常见的,网络节点之间的通信 就好像是人们之间的对话一样.如果一个人对另外一个人说话

  • java使用MulticastSocket实现多点广播

    DatagramSocket只允许数据报发送给指定的目标地址,而MulticastSocket可以将数据报以广播方式发送到数量不等的多个客户端. 若要使用多点广播时,则需要让一个数据报标有一组目标主机地址,当数据报发出后,整个组的所有主机都能收到该数据报.IP多点广播实现了将单一信息发送到多个接收者的广播,其思想是设置一组特殊网络地址作为广播地址,每个多点广播地址都被看做一个组,当客户端主要发送.接收信息时,加入到该组即可. IP协议为多点广播提供了这批特殊的IP地址,这些地址的IP地址范围是2

  • java使用MulticastSocket实现基于广播的多人聊天室

    使用MulticastSocket实现多点广播: (1)DatagramSocket只允许数据报发给指定的目标地址,而MulticastSocket可以将数据报以广播的方式发送到多个客户端. (2)IP协议为多点广播提供了这批特殊的IP地址,这些IP地址的范围是:224.0.0.0至239.255.255.255.. (3)MulticastSocket类时实现多点广播的关键,当MulticastSocket把一个DaragramPocket发送到多点广播的IP地址时,该数据报将会自动广播到加入

  • Java使用MulticastSocket实现群聊应用程序

    本文实例为大家分享了Java使用MulticastSocket实现群聊应用程序的具体代码,供大家参考,具体内容如下 在这篇文章中,讨论了一个使用 MulticastSocket (Java Platform SE 7) 类的群聊应用程序.MulticastSocket 是一个 (UDP) DatagramSocket,具有加入 Internet 上其他多播主机“组”的附加功能. import java.net.*; import java.io.*; import java.util.*;  

  • 组播的相关概念

    D类地址是用于组播,也就是以1110开头,剩下28位用于鉴别组播地址(剩下的这28是个无结构的地址), 以01005e开头的MAC地址用于表示MAC的组播地址,剩下的23位用于标识组播,IP组播地址对于MAC地址有一个映射关系,也就是IP组播的后23对应Mac组播的后23位,这样就有可能出现多个IP对应一个MAC的现象,它们之间用Arp来解析. 如果一个局域网使用组播,那么所有的主机必须加入一个all-host组(组播地址为224.0.0.1),但是Host可以决定是否去接受组播.当一个组播交通

  • Java实现求子数组和的最大值算法示例

    本文实例讲述了Java实现求子数组和的最大值算法.分享给大家供大家参考,具体如下: 一般C和C++在算法实现中使用较多,下面我们通过java语言实现算法,更有亲切感. 题目: 输入一个整形数组,数组里有正数也有负数. 数组中连续的一个或多个整数组成一个子数组,每个子数组都有一个和. 求所有子数组的和的最大值. 例如输入的数组为1, -2, 3, 10, -4, 7, 2, -5,和最大的子数组为3, 10, -4, 7, 2, 因此输出为该子数组的和18. 实现代码: package arrDe

  • Java通过正则表达式捕获组中的文本

    1.简介 Java 正则表达式如何捕获组中的文本 ?--请看下文. 2.代码 /** * 版权所有 编程十万个怎么办(www.tah1986.com) */ public class CapturingTextInAGroupInARegularExpression { public static void main(String[] argv) throws Exception { CharSequence inputStr = "abbabcd"; String patternSt

  • nodejs dgram模块广播+组播的实现示例

    本机IP地址是10.8.93.80, 具体信息如上图所示 根据计算得知我的广播地址应该是10.8.93.255,不是10.8.93.254哦. 其它内容就直接上代码 server.js const dgram = require('dgram'); const server = dgram.createSocket('udp4'); const multicastAddr = '224.100.100.100'; server.on('close', () => { console.log('s

  • Java实现OJ多组测试数据的输入方法

    Java:必须是public class Main提交,并且不能带包名,输入和输出的格式一定要按照题目要求的去写,否则提交不过.输入不可用文件输入. 就比如说要输入多组数据,每行一组,进行加法,输出的时候每行输出一个. import java.util.Scanner; public class Main { public static void main(String[] args) { Scanner sc=new Scanner(System.in); int a,b; while(sc.

随机推荐