| | |
| | | logger.info("获取负载最低的节点时无在线节点"); |
| | | return null; |
| | | } |
| | | |
| | | logger.error("ddddddd"); |
| | | // 获取分数最低的,及并发最低的 |
| | | Set<Object> objects = redisTemplate.opsForZSet().range(key, 0, -1); |
| | | ArrayList<Object> mediaServerObjectS = new ArrayList<>(objects); |
| | |
| | | if (hasAssist == null) { |
| | | String mediaServerId = (String)mediaServerObjectS.get(0); |
| | | mediaServer = getOne(mediaServerId); |
| | | logger.error("111"); |
| | | }else if (hasAssist) { |
| | | logger.error("222"); |
| | | for (Object mediaServerObject : mediaServerObjectS) { |
| | | String mediaServerId = (String)mediaServerObject; |
| | | MediaServer serverItem = getOne(mediaServerId); |
| | |
| | | } |
| | | } |
| | | }else if (!hasAssist) { |
| | | logger.error("333"); |
| | | for (Object mediaServerObject : mediaServerObjectS) { |
| | | String mediaServerId = (String)mediaServerObject; |
| | | MediaServer serverItem = getOne(mediaServerId); |