ClusterConnection
ClusterConnection 类扩展了 Connection 类,用于 SmartEDB 集群应用程序。
类定义
public class ClusterConnection extends Connection
{
public ClusterConnection(Database db)
{
super(db);
}
public void listen()
{
listen(id);
}
public void barrier()
{
barrier(id);
}
public void detach()
{
detach(id);
}
public void stop()
{
stop(id);
}
public Database.ClusterInfo getInfo()
{
return getInfo(id);
}
public void setWindowParams(Database.ClusterWindow windowParams)
{
setWindowParams(id, windowParams);
}
public Database.ClusterWindow getWindowParams()
{
return getWindowParams(id);
}
public Database.ClusterNodeInfo[] getActiveNodes()
{
return getActiveNodes(id);
}
public boolean scatter(Class [] classes, int [] nodeIds)
{
...
}
public boolean scatter()
{
return scatter(null, null);
}
public boolean scatter(Class [] classes)
{
return scatter(classes, null);
}
public boolean gather(Class [] classes, int [] nodeIds)
{
...
}
public boolean gather()
{
return gather(null, null);
}
public boolean gather(Class [] classes)
{
return gather(classes, null);
}
public void attach(Database.ClusterParams clusterParams)
{
attach(id, clusterParams, db, db.config);
}
}
方法
ClusterConnection
public ClusterConnection(Database db)
构造函数:为指定的数据库返回一个 ClusterConnection 实例
listen
public void listen():启动集群监听线程
barrier
public void barrier()
阻塞此节点,直至集群中的所有节点都已调用它
attach
public void attach(Database.ClusterParams clusterParams)
将此节点附加到活动集群
detach
public void detach()
将此节点从集群中分离
stop
public void stop()
停止集群网络通信
getInfo
public Database.ClusterInfo getInfo()
返回有关当前 ClusterConnection 的信息
setWindowParams
public void setWindowParams(Database.ClusterWindow windowParams)
设置异步复制窗口参数
getActiveNodes
public Database.ClusterNodeInfo[] getActiveNodes()
返回有关集群中活动节点的信息
scatter
public boolean scatter(Class [] classes, int [] nodeIds)
将此节点本地缓存中“分布式”对象的更改分发到集群中的其他节点
gather
public boolean gather(Class [] classes, int [] nodeIds)
接收集群中其他节点上“分布式”对象的更改