@@ -144,9 +144,11 @@ public synchronized ConfExt buildConf(Boolean decompose, Boolean check) {
144144
145145 List <UpstreamServer > upstreamServers = upstreamService .getUpstreamServers (upstream .getId ());
146146 for (UpstreamServer upstreamServer : upstreamServers ) {
147- ngxParam = new NgxParam ();
148- ngxParam .addValue ("server " + buildNodeStr (upstreamServer ));
149- ngxBlockServer .addEntry (ngxParam );
147+ if (upstreamServer .getEnable () == 1 ) {
148+ ngxParam = new NgxParam ();
149+ ngxParam .addValue ("server " + buildNodeStr (upstreamServer ));
150+ ngxBlockServer .addEntry (ngxParam );
151+ }
150152 }
151153
152154 // 自定义参数
@@ -400,9 +402,11 @@ public NgxBlock buildBlockUpstream(Upstream upstream) {
400402
401403 List <UpstreamServer > upstreamServers = upstreamService .getUpstreamServers (upstream .getId ());
402404 for (UpstreamServer upstreamServer : upstreamServers ) {
403- ngxParam = new NgxParam ();
404- ngxParam .addValue ("server " + buildNodeStr (upstreamServer ));
405- ngxBlockServer .addEntry (ngxParam );
405+ if (upstreamServer .getEnable () == 1 ) {
406+ ngxParam = new NgxParam ();
407+ ngxParam .addValue ("server " + buildNodeStr (upstreamServer ));
408+ ngxBlockServer .addEntry (ngxParam );
409+ }
406410 }
407411
408412 // 自定义参数
@@ -456,7 +460,7 @@ public void httpListenPort(Server server, NgxBlock ngxBlockServer, Boolean isIpv
456460 } else {
457461 ports = processPort (server .getListen ());
458462 }
459-
463+
460464 String listenKey = null ;
461465 if (isIpv6 ) {
462466 listenKey = "listen [::]:" ;
@@ -488,8 +492,7 @@ public void httpListenPort(Server server, NgxBlock ngxBlockServer, Boolean isIpv
488492 }
489493
490494 }
491-
492-
495+
493496 public void tcpListenPort (Server server , NgxBlock ngxBlockServer , Boolean isIpv6 ) {
494497 String host = null ;
495498 List <Integer > ports = null ;
@@ -501,7 +504,7 @@ public void tcpListenPort(Server server, NgxBlock ngxBlockServer, Boolean isIpv6
501504 } else {
502505 ports = processPort (server .getListen ());
503506 }
504-
507+
505508 String listenKey = null ;
506509 if (isIpv6 ) {
507510 listenKey = "listen [::]:" ;
@@ -510,7 +513,7 @@ public void tcpListenPort(Server server, NgxBlock ngxBlockServer, Boolean isIpv6
510513 } else {
511514 listenKey = "listen " ;
512515 }
513-
516+
514517 String value = "" ;
515518 for (Integer port : ports ) {
516519 NgxParam ngxParam = new NgxParam ();
@@ -738,13 +741,11 @@ public NgxBlock bulidBlockServer(Server server, ConfExt confExt) {
738741 } else {
739742 ngxBlockServer .addValue ("server" );
740743
741-
742744 // 监听端口
743745 tcpListenPort (server , ngxBlockServer , false );
744746 if (server .getIpv6 () == 1 ) {
745747 tcpListenPort (server , ngxBlockServer , true );
746748 }
747-
748749
749750 // 指向负载均衡
750751 Upstream upstream = sqlHelper .findById (server .getProxyUpstreamId (), Upstream .class );
0 commit comments