Package com.bytedesk.core.cluster.udp.broadcast

Class BroadcastingClient

java.lang.Object

com.bytedesk.core.cluster.udp.broadcast.BroadcastingClient

public class BroadcastingClient
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private InetAddress	address
private byte[]	buf
private int	expectedServerCount
private DatagramSocket	socket

Constructor Summary

Constructors

Constructor	Description
BroadcastingClient(int expectedServerCount)

Method Summary

Modifier and Type	Method	Description
private void	broadcastPacket(InetAddress address)
void	close()
private void	copyMessageOnBuffer(String msg)
int	discoverServers(String msg)
private void	initializeSocketForBroadcasting()
(package private) List<InetAddress>	listAllBroadcastAddresses()
private void	receivePacket()
private int	receivePackets()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

socket

private DatagramSocket socket

address

private InetAddress address

expectedServerCount

private int expectedServerCount

buf

private byte[] buf

Constructor Details

BroadcastingClient

public BroadcastingClient(int expectedServerCount)
                   throws Exception

Throws:

Exception

Method Details

discoverServers

public int discoverServers(String msg)
                    throws IOException

Throws:

IOException

listAllBroadcastAddresses

List<InetAddress> listAllBroadcastAddresses()
                                     throws SocketException

Throws:

SocketException

initializeSocketForBroadcasting

private void initializeSocketForBroadcasting()
                                      throws SocketException

Throws:

SocketException

copyMessageOnBuffer

private void copyMessageOnBuffer(String msg)

broadcastPacket

private void broadcastPacket(InetAddress address)
                      throws IOException

Throws:

IOException

receivePackets

private int receivePackets()
                    throws IOException

Throws:

IOException

receivePacket

private void receivePacket()
                    throws IOException

Throws:

IOException

close

public void close()