linger优化

easy-swoole · Dec 11, 2020 · 1eff6a8 · 1eff6a8
1 parent e3016fa
commit 1eff6a8
Show file tree

Hide file tree

Showing 4 changed files with 36 additions and 0 deletions.
diff --git a/src/Process/Socket/AbstractTcpProcess.php b/src/Process/Socket/AbstractTcpProcess.php
@@ -25,6 +25,7 @@ public function run($arg)
         $socket = new Socket(AF_INET,SOCK_STREAM,0);
         $socket->setOption(SOL_SOCKET,SO_REUSEPORT,true);
         $socket->setOption(SOL_SOCKET,SO_REUSEADDR,true);
+        $socket->setOption(SOL_SOCKET,SO_LINGER,$this->getConfig()->getLinger());
         $ret = $socket->bind($this->getConfig()->getListenAddress(),$this->getConfig()->getListenPort());
         if(!$ret){
             throw new Exception(static::class." bind {$this->getConfig()->getListenAddress()}:{$this->getConfig()->getListenPort()} fail case ".$socket->errMsg);

diff --git a/src/Process/Socket/AbstractUnixProcess.php b/src/Process/Socket/AbstractUnixProcess.php
@@ -27,6 +27,7 @@ public function run($arg)
             unlink($this->getConfig()->getSocketFile());
         }
         $socketServer = new Socket(AF_UNIX,SOCK_STREAM,0);
+        $socketServer->setOption(SOL_SOCKET,SO_LINGER,$this->getConfig()->getLinger());
         if(!$socketServer->bind($this->getConfig()->getSocketFile())){
             throw new Exception(static::class.' bind '.$this->getConfig()->getSocketFile(). ' fail case '.$socketServer->errMsg);
         }

diff --git a/src/Process/Socket/TcpProcessConfig.php b/src/Process/Socket/TcpProcessConfig.php
@@ -11,6 +11,23 @@ class TcpProcessConfig extends Config
     protected $listenAddress = '0.0.0.0';
     protected $listenPort;
     protected $asyncCallback = true;
+    protected $linger = [ 'l_linger' => 0, 'l_onoff' => 0];
+
+    /**
+     * @return int[]
+     */
+    public function getLinger(): array
+    {
+        return $this->linger;
+    }
+
+    /**
+     * @param int[] $linger
+     */
+    public function setLinger(array $linger): void
+    {
+        $this->linger = $linger;
+    }
 
     /**
      * @return string

diff --git a/src/Process/Socket/UnixProcessConfig.php b/src/Process/Socket/UnixProcessConfig.php
@@ -10,6 +10,23 @@ class UnixProcessConfig extends Config
 {
     protected $socketFile;
     protected $asyncCallback = true;
+    protected $linger = [ 'l_linger' => 0, 'l_onoff' => 0];
+
+    /**
+     * @return int[]
+     */
+    public function getLinger(): array
+    {
+        return $this->linger;
+    }
+
+    /**
+     * @param int[] $linger
+     */
+    public function setLinger(array $linger): void
+    {
+        $this->linger = $linger;
+    }
 
     /**
      * @return mixed