pack

fucongcong · Jul 25, 2017 · 25f0b0a · 25f0b0a
1 parent 2143d62
commit 25f0b0a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/config/app.php b/config/app.php
@@ -58,7 +58,7 @@
     //通信协议 eof：结束符, buf：自定义包头+包体
     'protocol' => 'buf',
     //包体的打包方式json,serialize
-    'pack' => 'json',
+    'pack' => 'serialize',
     //是否启用gzip压缩true,false
     'gzip' => true,
 

diff --git a/src/Admin/Process/HeartbeatProcess.php b/src/Admin/Process/HeartbeatProcess.php
@@ -6,8 +6,8 @@
 use Group\Process;
 use Group\Sync\Dao\Dao;
 use Group\Sync\SyncApp;
-use Group\Async\Client\Tcp;
 use Group\Protocol\Protocol;
+use Group\Protocol\Client;
 
 class HeartbeatProcess extends Process
 {
@@ -24,9 +24,10 @@ public function register()
 		        $res = $dao->querySql($sql, 'default')->fetchAll();
 
 		        foreach ($res as $serv) {
-		        	$client = new Tcp($serv['ip'], $serv['port']);
+		        	$client = new Client($serv['ip'], $serv['port']);
+		        	$client = $client->getClient();
 		        	$client->setTimeout(5);
-		        	$client->setData(Protocol::pack('', 'p'));
+		        	$client->setData(Protocol::pack('ping'));
 					$client->call(function($response, $error, $calltime) use ($serv, $dao) {
 						//服务挂了，或者异常了
 					    if (!$response) {