imap

@@ -62,16 +62,16 @@ class Imap {
         // 打开连接
         // 打开连接
         try {
         try {
             $this->client->open();
             $this->client->open();
-        }catch (\Throwable $e){
-            return (new Login($this));
-        }
 
 
+            //有的服务器是强制要求设置id属性 已知 163 有的服务器没有id命令  这里就不处理结果了
+            $this->client->request('ID ("name" "测试本地 Client" "version" "1" "os" "测试本地" "os-version" "1.0")');
 
 
-        //有的服务器是强制要求设置id属性 已知 163 有的服务器没有id命令  这里就不处理结果了
-        $this->client->request('ID ("name" "测试本地 Client" "version" "1" "os" "测试本地" "os-version" "1.0")');
+            // 登录
+            return (new Login($this))->exec();
 
 
-        // 登录
-        return (new Login($this))->exec();
+        }catch (\Throwable $e){
+            return (new Login($this))->setMsg($e->getMessage());
+        }
 
 
     }
     }
 
 

@@ -21,11 +21,19 @@ class ImapClient {
      */
      */
     public int $tagNum = 0;
     public int $tagNum = 0;
 
 
+    /**
+     * 是否是非阻塞模式
+     * @var bool
+     */
+    public $isBlocking = false;
+
     public function __construct(string $host){
     public function __construct(string $host){
         $this->host = $host;
         $this->host = $host;
         $this->socket = false;
         $this->socket = false;
     }
     }
 
 
+
+
     public function open(){
     public function open(){
         $content = stream_context_create([
         $content = stream_context_create([
             'ssl' => [
             'ssl' => [
@@ -45,6 +53,9 @@ class ImapClient {
             $content
             $content
         );
         );
 
 
+        // 设置为非阻塞模式
+        $this->isBlocking = stream_set_blocking($this->socket, false);
+
         if($error){
         if($error){
             throw new \Exception($error);
             throw new \Exception($error);
         }
         }
@@ -90,7 +101,30 @@ class ImapClient {
      * @time 2024/9/13 15:49
      * @time 2024/9/13 15:49
      */
      */
     protected function readLine(){
     protected function readLine(){
-        $str = fgets($this->socket,2048);
+        $i = 50; // 非阻塞模式下，只等待5秒，没返回数据就返回
+        $str = false;
+        while ($i>0){
+            $str = fgets($this->socket,2048);
+            // 非阻塞模式
+            if($this->isBlocking && $str === false){
+                $i--;
+                // 兼容下swoole
+                if(function_exists('go') && \co::getCid()>0){
+                    \co::sleep(0.1);
+                }else{
+                    // 等待 100 毫秒
+                    usleep(100000);
+                }
+
+            }else{
+                break;
+            }
+        }
+        // 超时了，异常
+        if(!$i && $str===false){
+            throw new \Exception('read time out');
+        }
+
         if($this->debug){
         if($this->debug){
             echo 'read: '.$str;
             echo 'read: '.$str;
         }
         }

@@ -24,6 +24,16 @@ class Login extends Request{
     }
     }
 
 
 
 
+    /**
+     * @param string $msg
+     * @return $this
+     * @author：dc
+     * @time 2025/3/14 10:16
+     */
+    public function setMsg(string $msg){
+        $this->message = $msg;
+        return $this;
+    }
 
 
 
 
 }
 }