1

我们的分布式数据库具有基于 php 扩展开发的 php 客户端。我们将数据库对象存储在persistant_list 中。

问题:从我们查到的日志中,对于同一个进程,有时候从persistant_list中找不到数据库对象,不得不初始化persistant_list中的db对象,但后来(可能1s)找不到相同的key-value再次。似乎持久列表中的值被破坏了。基于我对 php 的了解不足,persistent_list 中的值仅被 zend_hash_del 或 Web 服务器关闭破坏。源代码:

if (zend_hash_find(&EG(persistent_list), hash_key, hash_key_len+1, (void **) &le) == FAILURE) {
    tc = tair_init();
    last_rst = tair_startup(tc,uri);
    if(last_rst != TAIR_RETURN_SUCCESS){
        return -1;
    }

    zend_rsrc_list_entry new_le;
    new_le.type = le_tair;
    new_le.ptr  = tc;

    /* register new persistent connection */
    if (zend_hash_update(&EG(persistent_list), hash_key, hash_key_len+1, (void *) &new_le, sizeof(zend_rsrc_list_entry), NULL) == FAILURE) {
        tair_deinit(tc);
        tc = NULL;
    } else {
        rsrc_id = zend_list_insert(tc,le_tair);
    }
}else if (le->type != le_tair || le->ptr == NULL) {
    zend_hash_del(&EG(persistent_list), hash_key, hash_key_len+1);

    tc = tair_init();
    last_rst = tair_startup(tc,uri);
    if(last_rst != TAIR_RETURN_SUCCESS){
        return -1;
    }

    zend_rsrc_list_entry new_le;
    new_le.type = le_tair;
    new_le.ptr  = tc;
    if (zend_hash_update(&EG(persistent_list), hash_key, hash_key_len+1, (void *) &new_le, sizeof(zend_rsrc_list_entry), NULL) == FAILURE) {
        tair_deinit(tc);
        tc = NULL;
    } else {
        rsrc_id = zend_list_insert(tc,le_tair);
    }
}else {
    tc = (tair_handler)le->ptr;
    rsrc_id = zend_list_insert(tc,le_tair);
}

PHP_MINIT_FUNCTION(tair)
{
    REGISTER_INI_ENTRIES();
    tair_set_loglevel(tair_globals.log_level);
    le_tair = zend_register_list_destructors_ex(NULL,tair_dtor,"Tair session", module_number);
    return SUCCESS;
}

谁能告诉我我的 php zend 引擎有什么问题?顺便说一句,客户端使用 Nginx+fpm。

4

0 回答 0