net.hasor.rsf.address

Class AddressBucket

java.lang.Object

java.util.Observable

net.hasor.rsf.address.AddressBucket

public class AddressBucket
extends Observable

描述：用于接收地址更新同时也用来计算有效和无效地址。 也负责提供服务地址列表集，负责分类存储和处理同一个服务的各种类型的服务地址数据，比如：

1. 同单元服务地址
2. 有效服务地址
3. 不可用服务地址
4. 全部服务地址

所有对服务地址的进一 步处理都需要使用getAvailableAddresses()获得的地址列表。 如果应用了本地机房策略，则本地

Version:

: 2014年9月12日

Author:

赵永春 (zyc@hasor.net)

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	addressLogger
protected static org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
AddressBucket(String serviceID, RsfEnvironment rsfEnvironment)

Method Summary

Modifier and Type	Method and Description
List<InterAddress>	getAllAddresses() 获取所有地址（包括本地的和无效的）。
List<InterAddress>	getAvailableAddresses() 获取计算之后可用的地址。
FlowControlRef	getFlowControlRef()
List<InterAddress>	getInvalidAddresses() 失效地址。
List<InterAddress>	getLocalUnitAddresses() 获取计算之后同一单元地址。
RuleRef	getRuleRef()
String	getServiceID()
void	invalidAddress(InterAddress newInvalid, long timeout) 将地址置为失效的(对于静态地址,该方法无效)。
void	newAddress(Collection<InterAddress> newHostSet, AddressTypeEnum type) 新增地址支持动态新增
void	readFromZip(InputStream inStream) 从流中读取地址列表地址列表到zip流中。
void	refreshAddress() 刷新地址计算结果。
void	refreshAddressToNew(List<InterAddress> addressList)
void	removeAddress(InterAddress address) 将地址从地址本中删除。
boolean	saveToZip(OutputStream outStream) 保存地址列表到zip流中。
String	toString()
boolean	updateFlowControl(String flowControl) 更新服务的流控规则。
boolean	updateRoute(RouteTypeEnum routeType, String script) 更新服务的路由脚本。

Methods inherited from class java.util.Observable

addObserver, clearChanged, countObservers, deleteObserver, deleteObservers, hasChanged, notifyObservers, notifyObservers, setChanged

Methods inherited from class java.lang.Object

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

Field Detail

addressLogger

protected static final org.slf4j.Logger addressLogger

logger

protected static final org.slf4j.Logger logger

Constructor Detail

AddressBucket

public AddressBucket(String serviceID,
                     RsfEnvironment rsfEnvironment)

Method Detail

getServiceID

public String getServiceID()

getFlowControlRef

public FlowControlRef getFlowControlRef()

getRuleRef

public RuleRef getRuleRef()

getAllAddresses

public List<InterAddress> getAllAddresses()

获取所有地址（包括本地的和无效的）。

getAvailableAddresses

public List<InterAddress> getAvailableAddresses()

获取计算之后可用的地址。

getInvalidAddresses

public List<InterAddress> getInvalidAddresses()

失效地址。

getLocalUnitAddresses

public List<InterAddress> getLocalUnitAddresses()

获取计算之后同一单元地址。

newAddress

public void newAddress(Collection<InterAddress> newHostSet,
                       AddressTypeEnum type)

新增地址支持动态新增

invalidAddress

public void invalidAddress(InterAddress newInvalid,
                           long timeout)

将地址置为失效的(对于静态地址,该方法无效)。

Parameters:

newInvalid - 失效的地址。

timeout - 失效时长

removeAddress

public void removeAddress(InterAddress address)

将地址从地址本中删除。

Parameters:

address - 要被删除的地址。

refreshAddress

public void refreshAddress()

刷新地址计算结果。

refreshAddressToNew

public void refreshAddressToNew(List<InterAddress> addressList)

updateFlowControl

public boolean updateFlowControl(String flowControl)

更新服务的流控规则。

updateRoute

public boolean updateRoute(RouteTypeEnum routeType,
                           String script)

更新服务的路由脚本。

toString

public String toString()

Overrides:

toString in class Object

saveToZip

public boolean saveToZip(OutputStream outStream)
                  throws IOException

保存地址列表到zip流中。

Throws:

IOException

readFromZip

public void readFromZip(InputStream inStream)
                 throws IOException

从流中读取地址列表地址列表到zip流中。

Throws:

IOException