程式師世界 >> 數據庫知識 >> DB2數據庫 >> DB2教程 >> AerospikeC客戶端手冊———共享內存

AerospikeC客戶端手冊———共享內存

編輯：DB2教程

AerospikeC客戶端手冊———共享內存

共享內存

每個客戶端實例運行一個額外的集群侍服線程，周期地輪詢集群各服務器節點以得到集群的狀態。在一個單進程/多線程環境，只需要一個客戶端實例。此實例被設計成跨多線程共享。
在一個多進程/單線程環境，需要多個客戶端實例，意味著多個集群侍服線程輪詢各服務器節點，並得到完全相同的集群狀態。共享內存方式被設計出來，以解決這種效率低下情況。
啟用共享方式時，集群狀態（包括節點和數據分區映射）存放進一個共享內存段。然後，只有一個集群侍服擁有者進程輪詢各服務節點，獲取集群的狀態，並將寫入這個共享內存段。其它客戶端從共享內存中讀取集群狀態，不再去輪詢各服務器節點。
多進程/單線程環境是類PHP和Python等語言環境中常見的方式。Aerospike PHP和Python客戶端實現，就是通過調用Aerospike C客戶端，來獲得客戶端共享內存方式的能力。

共享內存配置

共享內存使用as_config的如下域成員來配置：

/**
 *  Indicates if shared memory should be used for cluster tending.  Shared memory
 *  is useful when operating in single threaded mode with multiple client processes.
 *  This model is used by wrapper languages such as PHP and Python.  When enabled, 
 *  the data partition maps are maintained by only one process and all other processes 
 *  use these shared memory maps.
 *
 *  Shared memory should not be enabled for multi-threaded programs.
 *  Default: false
 */
bool use_shm;

/**
 *  Shared memory identifier.  This identifier should be the same for all applications
 *  that use the Aerospike C client. 
 *  Default: 0xA5000000
 */
int shm_key;

/**
 *  Shared memory maximum number of server nodes allowed.  This value is used to size
 *  the fixed shared memory segment.  Leave a cushion between actual server node
 *  count and shm_max_nodes so new nodes can be added without having to reboot the client.
 *  Default: 16
 */
uint32_t shm_max_nodes;

/**
 *  Shared memory maximum number of namespaces allowed.  This value is used to size
 *  the fixed shared memory segment.  Leave a cushion between actual namespaces
 *  and shm_max_namespaces so new namespaces can be added without having to reboot the
 *  client.
 *  Default: 8
 */
uint32_t shm_max_namespaces;

/**
 *  Take over shared memory cluster tending if the cluster hasn't been tended by this
 *  threshold in seconds.
 *  Default: 30
 */
uint32_t shm_takeover_threshold_sec;

`啟用共享內存方式`

共享內存方式需在aerospike_connect()之前啟用。

as_config config;
as_config_init(&config);
as_config_add_host(&config, host, port);
config.use_shm = true;
config.shm_key = 0xA5000000;
config.shm_max_nodes = 16;
config.shm_max_namespaces = 8;
config.shm_takeover_threshold_sec = 30;

aerospike client;
as_error err;
aerospike_init(&client, &config);
as_status status = aerospike_connect(&client, &err);

`操作備注`

若共享內存段不存在，客戶端會自動創建。

第一個客戶端進程通過獲得共享內存鎖，來占有集群侍服能力，。

後繼的客戶端進程從共享內存段讀取集群狀態，但不做集群侍服也不寫共享內存。

應用退出前應調用aerospike_close()。此方法釋放共享內存鎖。另一個客戶端進程會自動獲得鎖，成為新的群集侍服擁有者。

若應用在釋放鎖之前死掉，另一個客戶端進程仍將接管集群待服，但會有一個延遲（默認30秒）。在這個延遲期間集群狀態仍然可讀，但集群侍服（輪詢新的集群狀態）不會開始，直到另一個客戶端進程接管。

共享內存段可使用這個命令查看：

ipcs -m

------ Shared Memory Segments --------
key        shmid      owner      perms      bytes      nattch     status      
0xA5000000 622592     root       666        263224     0

若共享內存配置變量需要更改（比如：增加最大節點數），新的共享內存段要重新創建。有兩種方式升級應用。

一次升級

關閉所有應用。

若共享內存還存在，則刪除。