com.fr.third.jgroups.protocols

类 UDP

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.TP

com.fr.third.jgroups.protocols.UDP

所有已实现的接口:

DiagnosticsHandler.ProbeHandler

public class UDP
extends TP

IP multicast transport based on UDP. Messages to the group (msg.dest == null) will be multicast (to all group members), whereas point-to-point messages (msg.dest != null) will be unicast to a single member. Uses a multicast and a unicast socket.

The following properties are read by the UDP protocol:

• param mcast_addr - the multicast address to use; default is 228.8.8.8.
• param mcast_port - (int) the port that the multicast is sent on; default is 7600
• param ip_mcast - (boolean) flag whether to use IP multicast; default is true.
• param ip_ttl - the default time-to-live for multicast packets sent out on this socket; default is 8.
• param use_packet_handler - boolean, defaults to false. If set, the mcast and ucast receiver threads just put the datagram's payload (a byte buffer) into a queue, from where a separate thread will dequeue and handle them (unmarshal and pass up). This frees the receiver threads from having to do message unmarshalling; this time can now be spent receiving packets. If you have lots of retransmissions because of network input buffer overflow, consider setting this property to true.

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
class	UDP.PacketReceiver

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.TP

TP.BaseBundler, TP.BatchHandler, TP.Bundler, TP.MyHandler, TP.ProtocolAdapter, TP.SenderSendsBundler, TP.SenderSendsWithTimerBundler, TP.SingleMessageHandler, TP.TransferQueueBundler

字段概要

字段

限定符和类型	字段和说明
protected boolean	disable_loopback
protected static java.lang.reflect.Method	getImpl
protected boolean	ip_mcast
protected int	ip_ttl
protected static boolean	is_android
protected static boolean	is_mac
protected IpAddress	mcast_addr The multicast address (mcast address and port) this member uses
protected java.net.InetAddress	mcast_group_addr
protected int	mcast_port
protected UDP.PacketReceiver	mcast_receiver Runnable to receive multicast packets
protected int	mcast_recv_buf_size
protected int	mcast_send_buf_size
protected java.net.MulticastSocket	mcast_sock IP multicast socket for receiving multicast packets
protected static java.lang.reflect.Method	setTimeToLive
protected java.net.DatagramSocket	sock Socket used for sending unicast and multicast packets and receiving unicast packets The address of this socket will be our local address (local_addr)
protected SuppressLog<java.net.InetAddress>	suppress_log_out_of_buffer_space
protected long	suppress_time_out_of_buffer_space
protected int	tos Traffic class for sending unicast and multicast datagrams.
protected UDP.PacketReceiver	ucast_receiver Runnable to receive unicast packets
protected int	ucast_recv_buf_size
protected int	ucast_send_buf_size

从类继承的字段 com.fr.third.jgroups.protocols.TP

avg_batch_size, bind_addr, bind_interface_str, bind_port, BUNDLE_MSG, bundler, bundler_capacity, bundler_type, can_bind_to_mcast_addr, cluster_name, connect_count, connectLock, default_thread_factory, diag_handler, diagnostics_addr, diagnostics_bind_interfaces, diagnostics_passcode, diagnostics_port, diagnostics_ttl, discard_incompatible_packets, enable_batching, enable_bundling, enable_diagnostics, enable_unicast_bundling, external_addr, external_port, f, global_thread_factory, header, ignore_dont_bundle, internal_thread_factory, internal_thread_pool, internal_thread_pool_enabled, internal_thread_pool_keep_alive_time, internal_thread_pool_max_threads, internal_thread_pool_min_threads, internal_thread_pool_queue, internal_thread_pool_queue_enabled, internal_thread_pool_queue_max_size, internal_thread_pool_rejection_policy, last_discovery_request, LIST, local_addr, local_physical_addr, log_discard_msgs, log_discard_msgs_version, logical_addr_cache, logical_addr_cache_expiration, logical_addr_cache_max_size, logical_addr_cache_reaper_interval, loopback, loopback_copy, loopback_separate_thread, max_bundle_size, max_bundle_timeout, members, MSG_OFFSET, MSG_OVERHEAD, MULTICAST, num_batches_received, num_batches_sent, num_bytes_received, num_bytes_sent, num_incoming_msgs_received, num_internal_msgs_received, num_msgs_received, num_msgs_sent, num_oob_msgs_received, num_rejected_msgs, num_single_msgs_received, num_single_msgs_sent, oob_thread_factory, oob_thread_pool, oob_thread_pool_enabled, oob_thread_pool_keep_alive_time, oob_thread_pool_max_threads, oob_thread_pool_min_threads, oob_thread_pool_queue, oob_thread_pool_queue_enabled, oob_thread_pool_queue_max_size, oob_thread_pool_rejection_policy, physical_addr_max_fetch_attempts, port_range, preregistered_probe_handlers, print_function, receive_interfaces, receive_on_all_interfaces, singleton_name, socket_factory, suppress_log_different_cluster, suppress_log_different_version, suppress_time_different_cluster_warnings, suppress_time_different_version_warnings, thread_naming_pattern, thread_pool, thread_pool_enabled, thread_pool_keep_alive_time, thread_pool_max_threads, thread_pool_min_threads, thread_pool_queue, thread_pool_queue_enabled, thread_pool_queue_max_size, thread_pool_rejection_policy, tick_time, time_service, time_service_interval, timer, timer_keep_alive_time, timer_max_threads, timer_min_threads, timer_queue_max_size, timer_rejection_policy, timer_thread_factory, timer_type, up_prots, wheel_size, who_has_cache, who_has_cache_timeout

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
UDP()

方法概要

方法

限定符和类型	方法和说明
protected void	_send(java.net.InetAddress dest, int port, boolean mcast, byte[] data, int offset, int length)
protected void	bindToInterfaces(java.util.List<java.net.NetworkInterface> interfaces, java.net.MulticastSocket s, java.net.InetAddress mcastAddr)
void	clearDroppedMessagesCache()
protected void	closeUnicastSocket()
protected java.net.DatagramSocket	createDatagramSocketWithBindPort() Creates a DatagramSocket when bind_port > 0.
protected IpAddress	createLocalAddress()
protected void	createSockets() Creates the UDP sender and receiver sockets
void	destroy() This method is called on a Channel.close().
protected void	destroySockets()
protected java.lang.String	dumpSocketInfo()
protected static java.lang.reflect.Method	findMethod(java.lang.Class<?> clazz, java.lang.String method_name, java.lang.Class<?>... parameters)
int	getDroppedMessage()
java.lang.String	getInfo()
java.net.InetAddress	getMulticastAddress()
int	getMulticastPort()
int	getMulticastTTL() Getter for current multicast TTL
protected PhysicalAddress	getPhysicalAddress()
protected void	handleConfigEvent(java.util.Map<java.lang.String,java.lang.Object> map)
protected void	handleConnect()
protected void	handleDisconnect()
protected java.lang.Object	handleDownEvent(Event evt)
void	init() Called after instance has been created (null constructor) and before protocol is started.
void	sendMulticast(AsciiString cluster_name, byte[] data, int offset, int length) Send to all members in the group.
void	sendUnicast(PhysicalAddress dest, byte[] data, int offset, int length) Send a unicast to 1 member.
protected void	setBufferSize(java.net.DatagramSocket sock, int send_buf_size, int recv_buf_size)
void	setMaxBundleSize(int size)
void	setMcastPort(int mcast_port)
void	setMulticastAddress(java.net.InetAddress addr)
void	setMulticastPort(int mcast_port)
void	setMulticastTTL(int ttl) Set the ttl for multicast socket
protected void	setTimeToLive(int ttl)
void	start() Creates the unicast and multicast sockets and starts the unicast and multicast receiver threads
void	stop() This method is called on a Channel.disconnect().
boolean	supportsMulticasting() Whether or not hardware multicasting is supported

从类继承的方法 com.fr.third.jgroups.protocols.TP

_send, addPhysicalAddressToCache, clearDifferentClusterCache, clearDifferentVersionCache, clearLogicalAddressCache, createThreadPool, disableDiagnostics, doSend, down, dumpTimerTasks, enableDiagnostics, evictLogicalAddressCache, evictLogicalAddressCache, fetchLocalAddresses, fetchPhysicalAddrs, fetchResponsesFromDiscoveryProtocol, getAllPhysicalAddressesFromCache, getAvgBatchSize, getBindAddress, getBindPort, getBundlerBufferSize, getClusterName, getClusterName, getDefaultThreadPool, getDefaultThreadPoolThreadFactory, getDifferentClusterMessages, getDifferentVersionMessages, getInternalMaxQueueSize, getInternalMessages, getInternalPoolSize, getInternalPoolSizeActive, getInternalQueueSize, getInternalThreadPool, getInternalThreadPoolThreadFactory, getLocalAddress, getLocalPhysicalAddress, getLogDiscardMessages, getLogDiscardMessagesVersion, getMaxBundleSize, getMaxBundleTimeout, getNumBytesReceived, getNumBytesSent, getNumMessagesReceived, getNumMessagesSent, getNumThreads, getNumTimerTasks, getOOBMaxQueueSize, getOOBMessages, getOOBPoolSize, getOOBPoolSizeActive, getOOBQueueSize, getOOBThreadPool, getOOBThreadPoolKeepAliveTime, getOOBThreadPoolMaxThreads, getOOBThreadPoolMinThreads, getOOBThreadPoolThreadFactory, getPhysicalAddressFromCache, getPortRange, getReceiveInterfaces, getRegularMaxQueueSize, getRegularMessages, getRegularPoolSize, getRegularPoolSizeActive, getRegularQueueSize, getSingletonName, getSocketFactory, getThreadFactory, getThreadNamingPattern, getThreadPoolKeepAliveTime, getThreadPoolMaxThreads, getThreadPoolMinThreads, getTimer, getTimerClass, getTimerKeepAliveTime, getTimerMaxThreads, getTimerMinThreads, getTimerQueueSize, getTimerThreadFactory, getTimerThreads, getTimeService, getUpProtocols, handleMessageBatch, handleProbe, handleSingleMessage, isDefaulThreadPoolEnabled, isDiagnosticsHandlerRunning, isDiscardIncompatiblePackets, isEnableBundling, isEnableUnicastBundling, isLogicalAddressCacheReaperRunning, isLoopback, isMulticastCapable, isOOBThreadPoolEnabled, isReceiveOnAllInterfaces, isSingleton, loggerType, loopback, passBatchUp, passMessageUp, passToAllUpProtocols, pickThreadPool, printLogicalAddressCache, printWhoHasCache, readMessage, readMessageBatch, readMessageList, receive, registerLocalAddress, registerProbeHandler, removeAndDispatchNonBundledMessages, removeLogicalAddressFromCache, resetStats, send, sendToMembers, sendToSingleMember, setBindAddress, setBindPort, setBindToAllInterfaces, setBundler, setDefaultThreadPool, setDefaultThreadPoolThreadFactory, setDiagnosticsHandler, setDiscardIncompatiblePackets, setEnableBundling, setEnableUnicastBundling, setInAllThreadFactories, setInternalThreadPool, setInternalThreadPoolThreadFactory, setLogDiscardMessages, setLogDiscardMessagesVersion, setLoopback, setMaxBundleTimeout, setOOBRejectionPolicy, setOOBThreadPool, setOOBThreadPoolKeepAliveTime, setOOBThreadPoolMaxThreads, setOOBThreadPoolMinThreads, setOOBThreadPoolQueueEnabled, setOOBThreadPoolThreadFactory, setPingData, setPortRange, setRegularRejectionPolicy, setSocketFactory, setSourceAddress, setThreadFactory, setThreadNames, setThreadPoolKeepAliveTime, setThreadPoolMaxThreads, setThreadPoolMinThreads, setThreadPoolQueueEnabled, setTimer, setTimerKeepAliveTime, setTimerMaxThreads, setTimerMinThreads, setTimerThreadFactory, setTimeService, shutdownThreadPool, startDiagnostics, stopDiagnostics, supportedKeys, toString, unregisterProbeHandler, unsetThreadNames, up, versionMatch, writeMessage, writeMessageList

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredDownServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setUpProtocol, setValue, setValues, statsEnabled, up

从类继承的方法 java.lang.Object

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

字段详细资料

tos

protected int tos

Traffic class for sending unicast and multicast datagrams. Valid values are (check DatagramSocket.setTrafficClass(int) ); for details):

• IPTOS_LOWCOST (0x02), decimal 2
• IPTOS_RELIABILITY (0x04)<, decimal 4/LI>
• IPTOS_THROUGHPUT (0x08), decimal 8
• IPTOS_LOWDELAY (0x10), decimal 16

mcast_group_addr

protected java.net.InetAddress mcast_group_addr

mcast_port

protected int mcast_port

ip_mcast

protected boolean ip_mcast

ip_ttl

protected int ip_ttl

mcast_send_buf_size

protected int mcast_send_buf_size

mcast_recv_buf_size

protected int mcast_recv_buf_size

ucast_send_buf_size

protected int ucast_send_buf_size

ucast_recv_buf_size

protected int ucast_recv_buf_size

disable_loopback

protected boolean disable_loopback

suppress_time_out_of_buffer_space

protected long suppress_time_out_of_buffer_space

mcast_addr

protected IpAddress mcast_addr

The multicast address (mcast address and port) this member uses

sock

protected java.net.DatagramSocket sock

Socket used for

1. sending unicast and multicast packets and
2. receiving unicast packets

The address of this socket will be our local address (local_addr)

mcast_sock

protected java.net.MulticastSocket mcast_sock

IP multicast socket for receiving multicast packets

mcast_receiver

protected UDP.PacketReceiver mcast_receiver

Runnable to receive multicast packets

ucast_receiver

protected UDP.PacketReceiver ucast_receiver

Runnable to receive unicast packets

suppress_log_out_of_buffer_space

protected SuppressLog<java.net.InetAddress> suppress_log_out_of_buffer_space

is_android

protected static final boolean is_android

is_mac

protected static final boolean is_mac

getImpl

protected static final java.lang.reflect.Method getImpl

setTimeToLive

protected static final java.lang.reflect.Method setTimeToLive

构造器详细资料

UDP

public UDP()

方法详细资料

supportsMulticasting

public boolean supportsMulticasting()

从类复制的说明: TP

Whether or not hardware multicasting is supported

指定者:

supportsMulticasting 在类中 TP

setMulticastAddress

public void setMulticastAddress(java.net.InetAddress addr)

getMulticastAddress

public java.net.InetAddress getMulticastAddress()

getMulticastPort

public int getMulticastPort()

setMulticastPort

public void setMulticastPort(int mcast_port)

setMcastPort

public void setMcastPort(int mcast_port)

setMulticastTTL

public void setMulticastTTL(int ttl)

Set the ttl for multicast socket

参数:

ttl - the time to live for the socket.

抛出:

java.io.IOException

getMulticastTTL

public int getMulticastTTL()

Getter for current multicast TTL

返回:

setMaxBundleSize

public void setMaxBundleSize(int size)

覆盖:

setMaxBundleSize 在类中 TP

getDroppedMessage

public int getDroppedMessage()

clearDroppedMessagesCache

public void clearDroppedMessagesCache()

getInfo

public java.lang.String getInfo()

指定者:

getInfo 在类中 TP

sendMulticast

public void sendMulticast(AsciiString cluster_name,
                 byte[] data,
                 int offset,
                 int length)
                   throws java.lang.Exception

从类复制的说明: TP

Send to all members in the group. UDP would use an IP multicast message, whereas TCP would send N messages, one for each member

指定者:

sendMulticast 在类中 TP

参数:

cluster_name - The name of the cluster. Null if not a shared transport

data - The data to be sent. This is not a copy, so don't modify it

抛出:

java.lang.Exception

sendUnicast

public void sendUnicast(PhysicalAddress dest,
               byte[] data,
               int offset,
               int length)
                 throws java.lang.Exception

从类复制的说明: TP

Send a unicast to 1 member. Note that the destination address is a *physical*, not a logical address

指定者:

sendUnicast 在类中 TP

参数:

dest - Must be a non-null unicast address

data - The data to be sent. This is not a copy, so don't modify it

抛出:

java.lang.Exception

_send

protected void _send(java.net.InetAddress dest,
         int port,
         boolean mcast,
         byte[] data,
         int offset,
         int length)
              throws java.lang.Exception

抛出:

java.lang.Exception

handleDownEvent

protected java.lang.Object handleDownEvent(Event evt)

覆盖:

handleDownEvent 在类中 TP

init

public void init()
          throws java.lang.Exception

从类复制的说明: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

覆盖:

init 在类中 TP

抛出:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

start

public void start()
           throws java.lang.Exception

Creates the unicast and multicast sockets and starts the unicast and multicast receiver threads

覆盖:

start 在类中 TP

抛出:

java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so Channel.connect(String) will throw an exception

stop

public void stop()

从类复制的说明: Protocol

This method is called on a Channel.disconnect(). Stops work (e.g. by closing multicast socket). Will be called from top to bottom. This means that at the time of the method invocation the neighbor protocol below is still working. This method will replace the STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that when this method is called all messages in the down queue will have been flushed

覆盖:

stop 在类中 TP

destroy

public void destroy()

从类复制的说明: Protocol

This method is called on a Channel.close(). Does some cleanup; after the call the VM will terminate

覆盖:

destroy 在类中 TP

handleConnect

protected void handleConnect()
                      throws java.lang.Exception

覆盖:

handleConnect 在类中 TP

抛出:

java.lang.Exception

handleDisconnect

protected void handleDisconnect()

覆盖:

handleDisconnect 在类中 TP

findMethod

protected static java.lang.reflect.Method findMethod(java.lang.Class<?> clazz,
                                  java.lang.String method_name,
                                  java.lang.Class<?>... parameters)

setTimeToLive

protected void setTimeToLive(int ttl)

createSockets

protected void createSockets()
                      throws java.lang.Exception

Creates the UDP sender and receiver sockets

抛出:

java.lang.Exception

destroySockets

protected void destroySockets()

createLocalAddress

protected IpAddress createLocalAddress()

getPhysicalAddress

protected PhysicalAddress getPhysicalAddress()

指定者:

getPhysicalAddress 在类中 TP

bindToInterfaces

protected void bindToInterfaces(java.util.List<java.net.NetworkInterface> interfaces,
                    java.net.MulticastSocket s,
                    java.net.InetAddress mcastAddr)

参数:

interfaces - List. Guaranteed to have no duplicates

s -

mcastAddr -

抛出:

java.io.IOException

createDatagramSocketWithBindPort

protected java.net.DatagramSocket createDatagramSocketWithBindPort()
                                                            throws java.lang.Exception

Creates a DatagramSocket when bind_port > 0. Attempts to allocate the socket with port == bind_port, and increments until it finds a valid port, or until port_range has been exceeded

返回:

DatagramSocket The newly created socket

抛出:

java.lang.Exception

dumpSocketInfo

protected java.lang.String dumpSocketInfo()
                                   throws java.lang.Exception

抛出:

java.lang.Exception

setBufferSize

protected void setBufferSize(java.net.DatagramSocket sock,
                 int send_buf_size,
                 int recv_buf_size)

closeUnicastSocket

protected void closeUnicastSocket()

handleConfigEvent

protected void handleConfigEvent(java.util.Map<java.lang.String,java.lang.Object> map)