big data multicast

大数据组播工具,内部实现好拆包装包算法.使用该工具可直接发送大数据包和接收.几行代码就搞定!

如何开始?

1.把 multicast-1.0.jar 添加到您项目的classpath中去.

2.编写一个类实现 MessageHandler 接口

3.使用TiandeMulticastSocket关键类开启组播服务:

MyMessageHandler handler = new MyMessageHandler();

TiandeMulticastSocket tiandeMulticastSocket = new TiandeMulticastSocket();
tiandeMulticastSocket.setGroup("228.0.0.10");
tiandeMulticastSocket.setIntervalSend(0);
tiandeMulticastSocket.setReceiveTimeOut(2000);
tiandeMulticastSocket.setBlockMaxSize(1024 * 50);
tiandeMulticastSocket.setReceivePacketSize(1024 * 60);	
tiandeMulticastSocket.registerHandler(handler);
tiandeMulticastSocket.start();

4.发送组播消息:

TiandeMulticastMessage msg = new TiandeMulticastMessage();
msg.setMethod("register");
msg.setProperty("key", "value");
msg.setBody("Hello a big data now");
tiandeMulticastSocket.send(msg);