GossipRouter

java.lang.Object
- com.fr.third.jgroups.stack.GossipRouter

```
public class GossipRouter
extends java.lang.Object
```
Router for TCP based group comunication (using layer TCP instead of UDP). Instead of the TCP layer sending packets point-to-point to each other member, it sends the packet to the router which - depending on the target address - multicasts or unicasts it to the group / or single member.
This class is especially interesting for applets which cannot directly make connections (neither UDP nor TCP) to a host different from the one they were loaded from. Therefore, an applet would create a normal channel plus protocol stack, but the bottom layer would have to be the TCP layer which sends all packets point-to-point (over a TCP connection) to the router, which in turn forwards them to their end location(s) (also over TCP). A centralized router would therefore have to be running on the host the applet was loaded from.
An alternative for running JGroups in an applet (IP multicast is not allows in applets as of 1.2), is to use point-to-point UDP communication via the gossip server. However, then the appplet has to be signed which involves additional administrative effort on the part of the user.
Note that a GossipRouter is also a good way of running JGroups in Amazon's EC2 environment which (as of summer 09) doesn't support IP multicasting.

从以下版本开始:

2.1.1

作者:

Bela Ban, Vladimir Blagojevic, Ovidiu Feodorov

嵌套类概要

嵌套类
限定符和类型类和说明

static interface GossipRouter.ConnectionTearListener

嵌套类
限定符和类型	类和说明
`static interface`	`GossipRouter.ConnectionTearListener`

字段概要

字段
限定符和类型	字段和说明
`static byte`	`CLOSE`
`static byte`	`CONNECT`
`static byte`	`CONNECT_OK`
`protected java.util.List<GossipRouter.ConnectionTearListener>`	`connectionTearListeners`
`protected ThreadFactory`	`default_thread_factory`
`static byte`	`DISCONNECT`
`static byte`	`DISCONNECT_OK`
`static byte`	`GOSSIP_GET`
`protected Log`	`log`
`static byte`	`MESSAGE`
`static byte`	`OP_FAIL`
`static byte`	`PING`
`static int`	`PORT`
`static byte`	`SUSPECT`
`protected java.util.Timer`	`timer`

构造器概要

构造器
构造器和说明
`GossipRouter()`
`GossipRouter(int port)`
`GossipRouter(int port, java.lang.String bindAddressString)`
`GossipRouter(int port, java.lang.String bindAddressString, boolean jmx)`
`GossipRouter(int port, java.lang.String bindAddressString, boolean jmx, long expiryTime)`

方法概要

方法
限定符和类型	方法和说明
`void`	`clear()`
`void`	`destroy()`
`java.lang.String`	`dumpAddresssMappings()`
`java.lang.String`	`dumpRoutingTable()`
`java.lang.String`	`dumpRoutingTableDetailed()`
`int`	`getBacklog()`
`java.lang.String`	`getBindAddress()`
`ThreadFactory`	`getDefaultThreadPoolThreadFactory()`
`long`	`getExpiryTime()`
`long`	`getLingerTimeout()`
`int`	`getPort()`
`long`	`getSocketReadTimeout()`
`boolean`	`isDiscardLoopbacks()`
`boolean`	`isRunning()`
`boolean`	`isStarted()`
`static void`	`main(java.lang.String[] args)`
`protected boolean`	`removeGroupIfEmpty(java.lang.String group)`
`void`	`setBacklog(int backlog)`
`void`	`setBindAddress(java.lang.String bindAddress)`
`void`	`setDiscardLoopbacks(boolean discard_loopbacks)`
`void`	`setExpiryTime(long expiryTime)`
`void`	`setLingerTimeout(long linger_timeout)`
`void`	`setPort(int port)`
`void`	`setSocketReadTimeout(long sock_read_timeout)`
`void`	`start()` Lifecycle operation.
`void`	`stop()` Always called before destroy().
`static java.lang.String`	`type2String(int type)`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

CONNECT
```
public static final byte CONNECT
```
另请参阅:
常量字段值

DISCONNECT
```
public static final byte DISCONNECT
```
另请参阅:
常量字段值

GOSSIP_GET
```
public static final byte GOSSIP_GET
```
另请参阅:
常量字段值

MESSAGE
```
public static final byte MESSAGE
```
另请参阅:
常量字段值

SUSPECT
```
public static final byte SUSPECT
```
另请参阅:
常量字段值

PING
```
public static final byte PING
```
另请参阅:
常量字段值

CLOSE
```
public static final byte CLOSE
```
另请参阅:
常量字段值

CONNECT_OK
```
public static final byte CONNECT_OK
```
另请参阅:
常量字段值

OP_FAIL
```
public static final byte OP_FAIL
```
另请参阅:
常量字段值

DISCONNECT_OK
```
public static final byte DISCONNECT_OK
```
另请参阅:
常量字段值

PORT
```
public static final int PORT
```
另请参阅:
常量字段值

connectionTearListeners

protected java.util.List<GossipRouter.ConnectionTearListener> connectionTearListeners

default_thread_factory

protected ThreadFactory default_thread_factory

timer
```
protected java.util.Timer timer
```

log
```
protected final Log log
```

构造器详细资料

GossipRouter
```
public GossipRouter()
```

GossipRouter
```
public GossipRouter(int port)
```

GossipRouter

public GossipRouter(int port,
            java.lang.String bindAddressString)

GossipRouter

public GossipRouter(int port,
            java.lang.String bindAddressString,
            boolean jmx)

GossipRouter

public GossipRouter(int port,
            java.lang.String bindAddressString,
            boolean jmx,
            long expiryTime)

方法详细资料

setPort
```
public void setPort(int port)
```

getPort
```
public int getPort()
```

setBindAddress

public void setBindAddress(java.lang.String bindAddress)

getBindAddress

public java.lang.String getBindAddress()

getBacklog
```
public int getBacklog()
```

setBacklog
```
public void setBacklog(int backlog)
```

setExpiryTime

public void setExpiryTime(long expiryTime)

getExpiryTime
```
public long getExpiryTime()
```

isStarted
```
public boolean isStarted()
```

isDiscardLoopbacks
```
public boolean isDiscardLoopbacks()
```

setDiscardLoopbacks

public void setDiscardLoopbacks(boolean discard_loopbacks)

getLingerTimeout
```
public long getLingerTimeout()
```

setLingerTimeout

public void setLingerTimeout(long linger_timeout)

getSocketReadTimeout
```
public long getSocketReadTimeout()
```

setSocketReadTimeout

public void setSocketReadTimeout(long sock_read_timeout)

getDefaultThreadPoolThreadFactory

public ThreadFactory getDefaultThreadPoolThreadFactory()

type2String

public static java.lang.String type2String(int type)

start
```
public void start()
           throws java.lang.Exception
```
Lifecycle operation. Called after create(). When this method is called, the managed attributes have already been set.
Brings the Router into a fully functional state.

抛出:

java.lang.Exception

stop
```
public void stop()
```
Always called before destroy(). Close connections and frees resources.

clear
```
public void clear()
```

destroy
```
public void destroy()
```

isRunning
```
public boolean isRunning()
```

dumpRoutingTable

public java.lang.String dumpRoutingTable()

dumpRoutingTableDetailed

public java.lang.String dumpRoutingTableDetailed()

dumpAddresssMappings

public java.lang.String dumpAddresssMappings()

removeGroupIfEmpty

protected boolean removeGroupIfEmpty(java.lang.String group)

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

抛出:: java.lang.Exception

类 GossipRouter

嵌套类概要

字段概要

构造器概要

方法概要

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

字段详细资料

CONNECT

DISCONNECT

GOSSIP_GET

MESSAGE

SUSPECT

PING

CLOSE

CONNECT_OK

OP_FAIL

DISCONNECT_OK

PORT

connectionTearListeners

default_thread_factory

timer

log

构造器详细资料

GossipRouter

GossipRouter

GossipRouter

GossipRouter

GossipRouter

方法详细资料

setPort

getPort

setBindAddress

getBindAddress

getBacklog

setBacklog

setExpiryTime

getExpiryTime

isStarted

isDiscardLoopbacks

setDiscardLoopbacks

getLingerTimeout

setLingerTimeout

getSocketReadTimeout

setSocketReadTimeout

getDefaultThreadPoolThreadFactory

type2String

start

stop

clear

destroy

isRunning

dumpRoutingTable

dumpRoutingTableDetailed

dumpAddresssMappings

removeGroupIfEmpty

main