健康状态检测

Author: caden-chen

src/Rpc/Consul.php

@@ -3,6 +3,7 @@
 namespace Leafpoda\JsonRpcClient\Rpc;
 
 use Consul\Services\Agent;
+use Consul\Services\Health;
 use Exception;
 use Leafpoda\JsonRpcClient\Exception\JsonrpcException;
 
@@ -17,12 +18,18 @@ class Consul
     public function getNode($serviceName): string
     {
         try {
-            $kv = new Agent();
-            $services = $kv->services()->getBody();
+            //获取健康的services的id
+            $agent = new Health();
+            $checks = $agent->state('passing')->getBody();
+            $checks = json_decode($checks,true);
+            $passServiceId = array_column($checks,'ServiceID');
+            //获取services详细信息
+            $agent = new Agent();
+            $services = $agent->services()->getBody();
             $services = json_decode($services,true);
             $nodes = [];
-            foreach ($services as $service){
-                if ($service['Service']==$serviceName){
+            foreach ($services as $serviceId => $service){
+                if ($service['Service']==$serviceName && in_array($serviceId,$passServiceId)){
                     $nodes[] = $service;
                 }
             }