协调节点

    协调节点作为数据请求部分的协调者,本身并不参与数据的匹配与读写操作,而仅仅是将请求分发到所需要处理的数据节点。

    一般来说,协调节点的处理流程如下:

    • 得到请求
    • 解析请求
    • 本地缓存查询该请求对应集合的信息
    • 如果信息不存在则从编目节点获取
    • 将请求转发至相应的数据节点
    • 从数据节点得到结果
    • 把结果汇总或直接传递给客户端协调节点与其它节点之间主要使用分区服务端口( SequoiaDB 的 —shardname 参数)进行通讯。

    SequoiaDB 中有两类协调节点:

    • 协调节点:通过正常的流程创建的协调节点组中的协调节点。该类协调节点注册到编目节点中,并且可以被集群管理。

    创建 SequoiaDB 集群时,可以在 Sdb Shell 中通过 sdbcm 创建临时协调节点:

    • 连接到本地的集群管理服务进程 sdbcm
    • 创建临时协调节点
    1. > oma.createCoord( 18800, "/opt/sequoiadb/database/coord/18800" )
    • 启动临时协调节点
    1. oma.startNode( 18800 )

    在 Sdb Shell 中可以通过临时协调节点可以创建协调节点组:

    • 连接临时协调节点
    1. > var db = new Sdb( 'sdbserver1', 18800 )
    • 创建协调节点组
    1. > db.createCoordRG()

    当集群规模扩大时,协调节点也需要随着规模的增加而进行增加。建议匹配时,一台物理节点,配置一个协调节点。

    在 Sdb Shell 中可以通过现有的协调节点组添加新的协调节点(假设 sdbserver1 中已有协调节点或临时协调节点,现在向 sdbserver2 中添加新的协调节点):

    • 连接 sdbserver1 的协调节点 11810
    1. > var db = new Sdb( 'sdbserver1', 11810 )
    • 获取协调节点组
    • 在 sdbserver2 中新建协调节点 11810
    1. > var node = rg.createNode( "sdbserver2", 11810, "/opt/sequoiadb/database/coord/11810" )
    1. > node.start()
    1. > db.getCoordRG().getDetail()
    • 创建协调节点配置目录,其中11810为协调节点的服务端口,可根据需要配置;
    1. $ mkdir -p /opt/sequoiadb/conf/local/11810
    • 拷贝协调节点样例配置文件;
    1. $ cp /opt/sequoiadb/conf/samples/sdb.conf.coord /opt/sequoiadb/conf/local/11810/sdb.conf
    • 修改配置文件;

    修改内容

    1. # database path dbpath=/opt/sequoiadb/database/coord

    该参数为数据库放置路径,可根据需要修改,请确保路径已经存在(不存在请手工创建)

    将如下行:

    1. # catalog addr(hostname1:servicename1,hostname2:servicename2,...)
    2. # catalogaddr=

    修改为:

    1. # catalog addr(hostname1:servicename1,hostname2:servicename2,...)
    2. catalogaddr=sdbserver1:11803,sdbserver2:11803,sdbserver3:11803

    该参数为Catalog服务地址和端口

    • 按 :wq,保存退出 vi;

    • 创建数据文件存放路径,路径为上一步骤配置的路径;

    1. $ mkdir -p /opt/sequoiadb/database/coord
    1. $ /opt/sequoiadb/bin/sdbstart -c /opt/sequoiadb/conf/local/11810/