services.moleculer.transporter

Class UdpMulticastTransporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

services.moleculer.transporter.UdpMulticastTransporter

public class UdpMulticastTransporter
extends Transporter

Multicast UDP-based, server-less Transporter. It cannot transfer large amounts of data in one package; 64 kilobytes is the theoretical maximum size of a complete IP datagram, but only 576 bytes are guaranteed to be routed. UDP does not behave well in a lossy network by itself.

If you need a RELIABLE data transport without central server (i.e. no loss of data, forwarding large messages) then TCPTransporter is the suitable option. Usage:

 ServiceBroker broker = ServiceBroker.builder().nodeID("node1")
 .transporter(new UdpMulticastTransporter()).build();
 

See Also:

TcpTransporter, AmqpTransporter, RedisTransporter, NatsTransporter, MqttTransporter, JmsTransporter, GoogleTransporter, KafkaTransporter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	UdpMulticastTransporter.MulticastReceiver

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	address UDP multicast address
protected java.lang.String	bindAddress UDP bind address (null = autodetect)
protected int	bufferSize 64 kilobytes is the theoretical maximum size of a complete IP datagram, but only 576 bytes are guaranteed to be routed
protected java.util.concurrent.ExecutorService	executor
protected int	multicastTTL UDP multicast TTL
protected int	port UDP multicast port
protected java.util.LinkedList<UdpMulticastTransporter.MulticastReceiver>	receivers Subscribed channels
protected boolean	reuseAddr Resuse addresses
protected java.util.HashSet<java.lang.String>	subscriptions Subscribed channels

Fields inherited from class services.moleculer.transporter.Transporter

checkTimeoutTimer, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, monitor, namespace, nodeID, nodes, offlineTimeout, PACKET_DISCONNECT, PACKET_DISCOVER, PACKET_EVENT, PACKET_HEARTBEAT, PACKET_INFO, PACKET_PING, PACKET_PONG, PACKET_REQUEST, PACKET_RESPONSE, pingChannel, pongChannel, preferHostname, prefix, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializer

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
UdpMulticastTransporter()

Method Summary

Modifier and Type	Method and Description
void	connect()
protected void	disconnect()
protected void	error(java.lang.Throwable cause) Any I/O error occurred.
void	publish(java.lang.String channel, io.datatree.Tree message)
protected void	reconnect()
protected void	startReceivers(java.net.NetworkInterface ni)
io.datatree.Promise	subscribe(java.lang.String channel)

Methods inherited from class services.moleculer.transporter.Transporter

broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, channel, checkTimeouts, connected, connected, createPingPacket, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, publish, received, sendClosePacket, sendDataPacket, sendDisconnectPacket, sendDiscoverPacket, sendErrorPacket, sendEventPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, sendRequestPacket, setDebug, setDebugHeartbeats, setHeartbeatInterval, setHeartbeatTimeout, setNamespace, setOfflineTimeout, setPreferHostname, setPrefix, setSerializer, setSubscriptionTimeout, started, stopped, subscribe, updateNodeInfo

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

bindAddress

protected java.lang.String bindAddress

UDP bind address (null = autodetect)

address

protected java.lang.String address

UDP multicast address

reuseAddr

protected boolean reuseAddr

Resuse addresses

port

protected int port

UDP multicast port

multicastTTL

protected int multicastTTL

UDP multicast TTL

bufferSize

protected int bufferSize

64 kilobytes is the theoretical maximum size of a complete IP datagram, but only 576 bytes are guaranteed to be routed

subscriptions

protected java.util.HashSet<java.lang.String> subscriptions

Subscribed channels

receivers

protected java.util.LinkedList<UdpMulticastTransporter.MulticastReceiver> receivers

Subscribed channels

executor

protected java.util.concurrent.ExecutorService executor

Constructor Detail

UdpMulticastTransporter

public UdpMulticastTransporter()

Method Detail

connect

public void connect()

Specified by:

connect in class Transporter

startReceivers

protected void startReceivers(java.net.NetworkInterface ni)
                       throws java.lang.Exception

Throws:

java.lang.Exception

disconnect

protected void disconnect()

reconnect

protected void reconnect()

error

protected void error(java.lang.Throwable cause)

Description copied from class: Transporter

Any I/O error occurred. Implementation-specific error handling goes here (reconnection, etc.).

Overrides:

error in class Transporter

Parameters:

cause - I/O error

publish

public void publish(java.lang.String channel,
                    io.datatree.Tree message)

Specified by:

publish in class Transporter

subscribe

public io.datatree.Promise subscribe(java.lang.String channel)

Specified by:

subscribe in class Transporter