简单讲解Java的Socket网络编程的多播与广播实现
程序员文章站
2024-03-08 23:36:46
在java中,我们可以有很多种方法来发送和接收数据。有的方法比较靠近底层,有些问题就需要程序员自己去解决,而有些方法抽象层次比较高,很方便地就可以拿来使用。这些处理数据的方...
在java中,我们可以有很多种方法来发送和接收数据。有的方法比较靠近底层,有些问题就需要程序员自己去解决,而有些方法抽象层次比较高,很方便地就可以拿来使用。这些处理数据的方法根据抽象层次由低到高分别有:
1.手动编码:使用位运算逐个自己编码和解析。
2.利用流来自动编码:组合使用outputstream和bytearrayoutputstream。
3.序列化:将数据放入一个数据对象中,直接将这个对象序列化后发送。
使用起来很方便,但要注意效率的损失,以及接收方也要使用java。
4.rmi:将对方法的调用都发送过去了,直接实现了方法的远程调用。
在最底层的方法1中,我们需要自己解决一些底层的问题:
1.整型的发送:要考虑是大尾端还是小尾端,是无符号的还是有符号的整数。
2.字符串的发送:要考虑编码问题。
3.无长度限制的类型,如大整数:要编码成帧frame,通过定界符或者长度位
来区分每帧。
多播与广播
我们可以向每个接受者单播一个数据副本,但这样做效率可能非常低。
只有udp套接字允许广播和多播,两者的区别是:广播会发送到网络上所有可达的
主机,有些操作系统可能不允许普通用户进行广播操作;而多播只发送给感兴趣的
主机。具体来说是调用multicastsocket的joingroup()加入到多播组的主机。
public class multicastreceivertest { public static void main(string[] args) throws exception { final inetaddress address = inetaddress.getbyname("224.1.1.1"); final int port = 45599; for (int i = 0; i < 5; i++) { new thread("thread #" + i){ @override public void run() { try { multicastsocket sock = new multicastsocket(port); sock.joingroup(address); byte[] msg = new byte[256]; datagrampacket packet = new datagrampacket(msg, msg.length); sock.receive(packet); system.out.println(thread.currentthread().getname() + " receive: " + new string(packet.getdata())); } catch (ioexception e) { e.printstacktrace(); } } }.start(); } thread.sleep(2000); multicastsocket sock = new multicastsocket(); sock.settimetolive(32); byte[] msg = "hellomulticast".getbytes(); datagrampacket packet = new datagrampacket(msg, msg.length, address, port); sock.send(packet); system.out.println("message sent"); } }