多agent,服务之间发送消息延迟过高

[yfengworld]

function CMD.request(id, addr)
  socket.start(id)
  
  local code, url, method, header, body = httpd.read_request(sockethelper.readfunc(id), 8192)
  --syslog.trace("---------------------code:%s %s, %d, %d",code, method, id, skynet.self())
  if code then
    local origin = header['origin']
    if 'OPTIONS' == method then
      response(id, 200, '', origin)
      socket.close(id)
      return
    end

    if code ~= 200 then
      response(id, code, '', origin)
      socket.close(id)
    else
      local usrname = header["username"]
      -- trace("----- usrname:[%s]", usrname)
      local session_id = header["sessionid"]
      if not usrname then
        response(id, 400, "header username no set", origin)
        socket.close(id)
      else
        usrname = tostring(usrname)
        local ret = skynet.call(database, "lua", "allow_login", usrname, addr)
        if not ret then
          response(id, 503, "server maintain", origin)
          socket.close(id)
          return 
        end 

        local agent = skynet.call(agentmgr, "lua", "query", usrname)
        if not agent then --极端情况
          response(id, 503, "server busy", origin) 
          socket.close(id)
          return 
        end

        --转到agent去处理
        socket.abandon(id)
        skynet.send(agent, "lua", "request", id, body, session_id, usrname, origin)
      end
    end
  else
    if url == sockethelper.socket_error then
      skynet.error("socket closed")
    else
      skynet.error(url)
    end
    socket.close(id)
  end
end

这是webagent里的代码,send数据到agent服务,随着消息变多，agent那边收到消息的延迟很大。每秒100个消息是正常，每秒200个消息，cpu直接接近100%

[terry8210]

你开了多少个agent ？为什么要去call agentmgr去那agent 直接username hash到固定的agent即可，效率会更高，目前你的瓶颈在skynet.call(agentmgr, "lua", "query", usrname)

[yfengworld]

提前开好1000个agent,压测工具每1秒200个登录。call agentmgr主要是为了固定agent。100个登录ok，200个cpu接近100%。如果瓶颈在call agentmgr 那为什么send到agent,agent那边收到请求慢

[terry8210]

你可以做下链路排查，看看哪里耗时比较多

[yfengworld]

按照你所说方式，性能的确大提升了。但是cpu 200并发时还是太高，我估计是初始化时循环太多造成，每个agent里有不少循环。

[huahua132]

skynet.call(database, "lua", "allow_login", usrname, addr) 这里每次都要查库吗？ 我猜至少查了缓存数据库吧

[yfengworld]

8核，开16个线程。有一瞬间接近满，过后就下来了。

[sniper00]

每次都走登录流程？对于单个玩家， 起码要判断下重复登录吧，已登录的就直接返回，上次登录流程没走完，收到新的登录，就拒绝请求。 登录请求对游戏业务相对来说是比较复杂的，可能涉及到第三方认证的访问。

[yfengworld]

不都走登录流程,已登录的直接内存数据返回。其实测试的是新玩家注册登录。现在只要是瞬间cpu很高

[terry8210]

是所有核都跑满100%？

[yfengworld]

不是，是大部分核，有1,2核也是90多

[huahua132]

经过了2个单点服务才到agent，肯定延迟高

[yfengworld]

不是哦，你看我代码，我是经过2个单点后取的时间，然后那边收到后取的时间差。

[huahua132]

建议使用jwt 签发token，避免每次走login和agent查询

[yfengworld]

经过排查，是其他地方导致了cpu飚升。问题已解决。