心跳

fucongcong · Jul 25, 2017 · 2143d62 · 2143d62
1 parent 90c0c4e
commit 2143d62
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Admin/Process/HeartbeatProcess.php b/src/Admin/Process/HeartbeatProcess.php
@@ -7,6 +7,7 @@
 use Group\Sync\Dao\Dao;
 use Group\Sync\SyncApp;
 use Group\Async\Client\Tcp;
+use Group\Protocol\Protocol;
 
 class HeartbeatProcess extends Process
 {
@@ -25,7 +26,7 @@ public function register()
 		        foreach ($res as $serv) {
 		        	$client = new Tcp($serv['ip'], $serv['port']);
 		        	$client->setTimeout(5);
-		        	$client->setData("p\r\n");
+		        	$client->setData(Protocol::pack('', 'p'));
 					$client->call(function($response, $error, $calltime) use ($serv, $dao) {
 						//服务挂了，或者异常了
 					    if (!$response) {