改名

Kafka/Socket.php

@@ -248,6 +248,7 @@ class Socket
 
         $this->readWatcher = \Amp\onReadable($this->stream, function () {
             do {
+	            try {
 		            if(!$this->isSocketDead($this->stream)){
 			            $newData = @fread($this->stream, self::READ_MAX_LEN);
 		            }else{
@@ -257,6 +258,9 @@ class Socket
 		            if ($newData) {
 			            $this->read($newData);
 		            }
+	            }catch (\Exception $exception){
+	            	var_dump($exception->getMessage());
+	            }
             } while ($newData);
         });