說明

自Workerman 4.x版本開始,加強了對HTTP服務的支援。引入了請求類、響應類、會話類以及SSE。如果你想使用Workerman的HTTP服務,強烈建議使用Workerman4.x或以上版本。

請注意以下都是Workerman4.x版本的用法,不相容Workerman3.x。

獲取Session對象

$session = $request->session();

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $session = $request->session();
    $session->set('name', 'tome');
    $connection->send($session->get('name'));
};

// 運行worker
Worker::runAll();

注意事項

  • Session必須在$connection->send()調用之前操作。
  • Session在物件被銷毀時會自動保存修改,所以不要把$request->session()返回的物件保存在全局陣列或者類成員中導致Session無法保存。
  • Session默認存儲在磁盤文件中,如果想要更好的性能建議使用redis。

獲取所有Session數據

$session = $request->session();
$all = $session->all();

返回的是一個陣列。如果沒有任何Session數據,則返回一個空陣列。

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $session = $request->session();
    $session->set('name', 'tom');
    $connection->send(var_export($session->all(), true));
};

// 運行worker
Worker::runAll();

獲取Session中某個值

$session = $request->session();
$name = $session->get('name');

如果數據不存在則返回null。

你也可以給get方法第二個參數傳遞一個默認值,如果Session陣列中沒找到對應值則返回默認值。例如:

$session = $request->session();
$name = $session->get('name', 'tom');

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $session = $request->session();
    $connection->send($session->get('name', 'tom'));
};

// 運行worker
Worker::runAll();

儲存Session數據

儲存某一項數據時用set方法。

$session = $request->session();
$session->set('name', 'tom');

set沒有返回值,Session物件銷毀時Session會自動保存。

當儲存多個值時使用put方法。

$session = $request->session();
$session->put(['name' => 'tom', 'age' => 12]);

同樣的,put也沒有返回值。

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $session = $request->session();
    $session->set('name', 'tom');
    $connection->send($session->get('name'));
};

// 運行worker
Worker::runAll();

刪除Session數據

刪除某個或者某些Session數據時用forget方法。

$session = $request->session();
// 刪除一項
$session->forget('name');
// 刪除多項
$session->forget(['name', 'age']);

另外系統提供了delete方法,與forget方法區別是,delete只能刪除一項。

$session = $request->session();
// 等同於 $session->forget('name');
$session->delete('name');

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $request->session()->forget('name');
    $connection->send('ok');
};

// 運行worker
Worker::runAll();

獲取並刪除Session某個值

$session = $request->session();
$name = $session->pull('name');

效果與如下代碼相同

$session = $request->session();
$value = $session->get($name);
$session->delete($name);

如果對應Session不存在,則返回null。

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $connection->send($request->session()->pull('name'));
};

// 運行worker
Worker::runAll();

刪除所有Session數據

$request->session()->flush();

沒有返回值,Session物件銷毀時Session會自動從存儲中刪除。

範例

use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Protocols\Http\Request;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('http://0.0.0.0:8080');

$worker->onMessage = function(TcpConnection $connection, Request $request)
{
    $request->session()->flush();
    $connection->send('ok');
};

// 運行worker
Worker::runAll();

判斷對應Session數據是否存在

$session = $request->session();
$has = $session->has('name');

以上當對應的Session不存在或者對應的Session值為null時返回false,否則返回true。

$session = $request->session();
$has = $session->exists('name');

以上代碼也是用來判斷Session數據是否存在,區別是當對應的Session項值為null時,也返回true。