openresty+redis incrby命令生成唯一数字id,高并发问题

winlia520

这是我的存放redis incrby的唯一数字id表结构
CREATE TABLE `table` (
  `sid` varchar(45) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是存放redis生成的唯一自增id', 
  `client_uid` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是所谓客户端生成的唯一字段识别', 
  PRIMARY KEY (`sid`),
  UNIQUE KEY `index1` (`client_uid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


下面是存储过程
CREATE DEFINER=`myfunc`@`%` PROCEDURE `proc_myfunc`(
     v_sid INT,
     v_client_uid CHAR(50))
BEGIN
    DECLARE v_int INT(11) DEFAULT 0 ;
    DECLARE t_error INTEGER DEFAULT 0;
    DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;
       START TRANSACTION;
       set t_error=0;

            SET @strsql=CONCAT("INSERT INTO `table"`(
    sid,client_uid)
VALUES('",v_sid,"','",v_client_uid,"')") ;

            PREPARE t FROM @strsql ;
            EXECUTE t ;
            DEALLOCATE PREPARE t ;


            SET @strsql2=CONCAT("INSERT INTO `table2"`(
    sid,flag)
VALUES('",v_sid,"','1')") ;

            PREPARE t2 FROM @strsql2 ;
            EXECUTE t2 ;
            DEALLOCATE PREPARE t2 ;
            select t_error;#这里返回给lua程序判断，0为成功，1为失败表示己回滚了
       IF t_error = 1 THEN
            ROLLBACK;
       ELSE
            COMMIT;
       END IF; 

END

lua代码如下

local ok, err = red:connect("127.0.0.1", 6379)
if not ok then
    ngx.say("failed to connect: ", err)
    return
end

local db, err = mysql:new()
--[[
--  连接数据库代码省略
-- ]]
 

function create_udid()
    local res, err = red:incrby("udid",1) --这里自增步长为1
    if not res then
        ngx.say("failed to get udid: ", err)
        return
    end
    return res  --这里返回 redis自增长id
end

client_uid = ngx.req.get_uri_args()["client_uid"] -- 获取客户端的client_uid

res, err, errcode, sqlstate = db:query("select sid from table where client_uid='"..client_uid.."'")
if not res then
    ngx.say("bad result: ", err, ": ", errcode, ": ", sqlstate, ".")
    return
end

if res==nil or res[1]['sid'] == nil then  --如果查询数据库不存在
   --服务端重新生成一个数字id
   udid = create_udid()
   --保存数据库,调用存储过程
    ret = db:query("call proc_myfunc('"..udid.."','"..client_uid.."')")
    --判断存储过程是返回1,还是返回0,0表示成功,1表示失败
    if ret==0 then
        ngx.say("{'sid':'"..udid.."'}")
    else
         ngx.exit(500)
    end
else
  --如何存在则只更新数据库 
    --此处代码省略
end




--[[
--  设置redis,mysql set_keepalive 代码省略
-- ]]

以上是少量伪代码

按照上面的思路，客户端请求接口 http://localhost/v1/?client_uid=xxxxx 这个样子

高并时发现分配到的redis数字唯一id和客户端请求过来的client_uid不对应，

也就是说，客户端拿到了别人的生成的唯一id

请问这个怎么解决？？？？？？？？？

hello2t0403

一般这种问题都是某个地方的变量不是local导致的。。。

在 2017年1月11日星期三 UTC+8下午2:15:24，tan winfan写道：

这是我的存放redis incrby的唯一数字id表结构
CREATE TABLE `table` (
  `sid` varchar(45) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是存放redis生成的唯一自增id', 
  `client_uid` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是所谓客户端生成的唯一字段识别', 
  PRIMARY KEY (`sid`),
  UNIQUE KEY `index1` (`client_uid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


下面是存储过程
CREATE DEFINER=`myfunc`@`%` PROCEDURE `proc_myfunc`(
     v_sid INT,
     v_client_uid CHAR(50))
BEGIN
    DECLARE v_int INT(11) DEFAULT 0 ;
    DECLARE t_error INTEGER DEFAULT 0;
    DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;
       START TRANSACTION;
       set t_error=0;

            SET @strsql=CONCAT("INSERT INTO `table"`(
    sid,client_uid)
VALUES('",v_sid,"','",v_client_uid,"')") ;

            PREPARE t FROM @strsql ;
            EXECUTE t ;
            DEALLOCATE PREPARE t ;


            SET @strsql2=CONCAT("INSERT INTO `table2"`(
    sid,flag)
VALUES('",v_sid,"','1')") ;

            PREPARE t2 FROM @strsql2 ;
            EXECUTE t2 ;
            DEALLOCATE PREPARE t2 ;
            select t_error;#这里返回给lua程序判断，0为成功，1为失败表示己回滚了
       IF t_error = 1 THEN
            ROLLBACK;
       ELSE
            COMMIT;
       END IF; 

END

lua代码如下



local ok, err = red:connect("127.0.0.1", 6379)
if not ok then
    ngx.say("failed to connect: ", err)
    return
end

local db, err = mysql:new()
--[[
--  连接数据库代码省略
-- ]]
 

function create_udid()
    local res, err = red:incrby("udid",1) --这里自增步长为1
    if not res then
        ngx.say("failed to get udid: ", err)
        return
    end
    return res  --这里返回 redis自增长id
end

client_uid = ngx.req.get_uri_args()["client_uid"] -- 获取客户端的client_uid

res, err, errcode, sqlstate = db:query("select sid from table where client_uid='"..client_uid.."'")
if not res then
    ngx.say("bad result: ", err, ": ", errcode, ": ", sqlstate, ".")
    return
end

if res==nil or res[1]['sid'] == nil then  --如果查询数据库不存在
   --服务端重新生成一个数字id
   udid = create_udid()
   --保存数据库,调用存储过程
    ret = db:query("call proc_myfunc('"..udid.."','"..client_uid.."')")
    --判断存储过程是返回1,还是返回0,0表示成功,1表示失败
    if ret==0 then
        ngx.say("{'sid':'"..udid.."'}")
    else
         ngx.exit(500)
    end
else
  --如何存在则只更新数据库 
    --此处代码省略
end




--[[
--  设置redis,mysql set_keepalive 代码省略
-- ]]

以上是少量伪代码

按照上面的思路，客户端请求接口 http://localhost/v1/?client_uid=xxxxx 这个样子

高并时发现分配到的redis数字唯一id和客户端请求过来的client_uid不对应，

也就是说，客户端拿到了别人的生成的唯一id

请问这个怎么解决？？？？？？？？？

winlia520

我确实好多都没用local ，有些用了，我感觉在滥用

在 2017年1月11日星期三 UTC+8下午2:15:24，tan winfan写道：

这是我的存放redis incrby的唯一数字id表结构
CREATE TABLE `table` (
  `sid` varchar(45) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是存放redis生成的唯一自增id', 
  `client_uid` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是所谓客户端生成的唯一字段识别', 
  PRIMARY KEY (`sid`),
  UNIQUE KEY `index1` (`client_uid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


下面是存储过程
CREATE DEFINER=`myfunc`@`%` PROCEDURE `proc_myfunc`(
     v_sid INT,
     v_client_uid CHAR(50))
BEGIN
    DECLARE v_int INT(11) DEFAULT 0 ;
    DECLARE t_error INTEGER DEFAULT 0;
    DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;
       START TRANSACTION;
       set t_error=0;

            SET @strsql=CONCAT("INSERT INTO `table"`(
    sid,client_uid)
VALUES('",v_sid,"','",v_client_uid,"')") ;

            PREPARE t FROM @strsql ;
            EXECUTE t ;
            DEALLOCATE PREPARE t ;


            SET @strsql2=CONCAT("INSERT INTO `table2"`(
    sid,flag)
VALUES('",v_sid,"','1')") ;

            PREPARE t2 FROM @strsql2 ;
            EXECUTE t2 ;
            DEALLOCATE PREPARE t2 ;
            select t_error;#这里返回给lua程序判断，0为成功，1为失败表示己回滚了
       IF t_error = 1 THEN
            ROLLBACK;
       ELSE
            COMMIT;
       END IF; 

END

lua代码如下



local ok, err = red:connect("127.0.0.1", 6379)
if not ok then
    ngx.say("failed to connect: ", err)
    return
end

local db, err = mysql:new()
--[[
--  连接数据库代码省略
-- ]]
 

function create_udid()
    local res, err = red:incrby("udid",1) --这里自增步长为1
    if not res then
        ngx.say("failed to get udid: ", err)
        return
    end
    return res  --这里返回 redis自增长id
end

client_uid = ngx.req.get_uri_args()["client_uid"] -- 获取客户端的client_uid

res, err, errcode, sqlstate = db:query("select sid from table where client_uid='"..client_uid.."'")
if not res then
    ngx.say("bad result: ", err, ": ", errcode, ": ", sqlstate, ".")
    return
end

if res==nil or res[1]['sid'] == nil then  --如果查询数据库不存在
   --服务端重新生成一个数字id
   udid = create_udid()
   --保存数据库,调用存储过程
    ret = db:query("call proc_myfunc('"..udid.."','"..client_uid.."')")
    --判断存储过程是返回1,还是返回0,0表示成功,1表示失败
    if ret==0 then
        ngx.say("{'sid':'"..udid.."'}")
    else
         ngx.exit(500)
    end
else
  --如何存在则只更新数据库 
    --此处代码省略
end




--[[
--  设置redis,mysql set_keepalive 代码省略
-- ]]

以上是少量伪代码

按照上面的思路，客户端请求接口 http://localhost/v1/?client_uid=xxxxx 这个样子

高并时发现分配到的redis数字唯一id和客户端请求过来的client_uid不对应，

也就是说，客户端拿到了别人的生成的唯一id

请问这个怎么解决？？？？？？？？？

hello2t0403

我觉得你需要看看这里的讨论：https://groups.google.com/forum/#!topic/openresty/3ylMdtvUJqg

以及：https://moonbingbing.gitbooks.io/openresty-best-practices/content/ngx_lua/lua-variable-scope.html

在 2017年1月11日星期三 UTC+8下午2:42:48，tan winfan写道：

我确实好多都没用local ，有些用了，我感觉在滥用

在 2017年1月11日星期三 UTC+8下午2:15:24，tan winfan写道：

这是我的存放redis incrby的唯一数字id表结构
CREATE TABLE `table` (
  `sid` varchar(45) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是存放redis生成的唯一自增id', 
  `client_uid` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT '这是所谓客户端生成的唯一字段识别', 
  PRIMARY KEY (`sid`),
  UNIQUE KEY `index1` (`client_uid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


下面是存储过程
CREATE DEFINER=`myfunc`@`%` PROCEDURE `proc_myfunc`(
     v_sid INT,
     v_client_uid CHAR(50))
BEGIN
    DECLARE v_int INT(11) DEFAULT 0 ;
    DECLARE t_error INTEGER DEFAULT 0;
    DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET t_error=1;
       START TRANSACTION;
       set t_error=0;

            SET @strsql=CONCAT("INSERT INTO `table"`(
    sid,client_uid)
VALUES('",v_sid,"','",v_client_uid,"')") ;

            PREPARE t FROM @strsql ;
            EXECUTE t ;
            DEALLOCATE PREPARE t ;


            SET @strsql2=CONCAT("INSERT INTO `table2"`(
    sid,flag)
VALUES('",v_sid,"','1')") ;

            PREPARE t2 FROM @strsql2 ;
            EXECUTE t2 ;
            DEALLOCATE PREPARE t2 ;
            select t_error;#这里返回给lua程序判断，0为成功，1为失败表示己回滚了
       IF t_error = 1 THEN
            ROLLBACK;
       ELSE
            COMMIT;
       END IF; 

END

lua代码如下



local ok, err = red:connect("127.0.0.1", 6379)
if not ok then
    ngx.say("failed to connect: ", err)
    return
end

local db, err = mysql:new()
--[[
--  连接数据库代码省略
-- ]]
 

function create_udid()
    local res, err = red:incrby("udid",1) --这里自增步长为1
    if not res then
        ngx.say("failed to get udid: ", err)
        return
    end
    return res  --这里返回 redis自增长id
end

client_uid = ngx.req.get_uri_args()["client_uid"] -- 获取客户端的client_uid

res, err, errcode, sqlstate = db:query("select sid from table where client_uid='"..client_uid.."'")
if not res then
    ngx.say("bad result: ", err, ": ", errcode, ": ", sqlstate, ".")
    return
end

if res==nil or res[1]['sid'] == nil then  --如果查询数据库不存在
   --服务端重新生成一个数字id
   udid = create_udid()
   --保存数据库,调用存储过程
    ret = db:query("call proc_myfunc('"..udid.."','"..client_uid.."')")
    --判断存储过程是返回1,还是返回0,0表示成功,1表示失败
    if ret==0 then
        ngx.say("{'sid':'"..udid.."'}")
    else
         ngx.exit(500)
    end
else
  --如何存在则只更新数据库 
    --此处代码省略
end




--[[
--  设置redis,mysql set_keepalive 代码省略
-- ]]

以上是少量伪代码

按照上面的思路，客户端请求接口 http://localhost/v1/?client_uid=xxxxx 这个样子

高并时发现分配到的redis数字唯一id和客户端请求过来的client_uid不对应，

也就是说，客户端拿到了别人的生成的唯一id

请问这个怎么解决？？？？？？？？？