From 5906594148d4679a268e8fdb48d8b4aa1451292c Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Tue, 11 Dec 2018 18:58:15 +0800 Subject: [PATCH] --- src/org/redkale/boot/watch/ServerWatchService.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/src/org/redkale/boot/watch/ServerWatchService.java b/src/org/redkale/boot/watch/ServerWatchService.java index a23ec6f3c..893c8f5f8 100644 --- a/src/org/redkale/boot/watch/ServerWatchService.java +++ b/src/org/redkale/boot/watch/ServerWatchService.java @@ -6,6 +6,7 @@ package org.redkale.boot.watch; import java.util.*; +import java.util.stream.Stream; import javax.annotation.Resource; import org.redkale.boot.*; import org.redkale.net.Server; @@ -27,14 +28,9 @@ public class ServerWatchService extends AbstractWatchService { protected Application application; @RestMapping(name = "info", comment = "单个Server信息查询") - public RetResult info(@RestParam(name = "#port:") int port) { - NodeServer node = null; - for (NodeServer ns : application.getNodeServers()) { - if (ns.getServer().getSocketAddress().getPort() == port) { - node = ns; - break; - } - } + public RetResult info(@RestParam(name = "#port:") final int port) { + Stream stream = application.getNodeServers().stream(); + NodeServer node = stream.filter(ns -> ns.getServer().getSocketAddress().getPort() == port).findFirst().orElse(null); if (node == null) return new RetResult(RET_SERVER_NOT_EXISTS, "Server(port=" + port + ") not found"); return new RetResult(formatToMap(node)); }