1.首先安裝swoole擴展
Swoole-1.x需要 PHP-5.3.10 或更高版本
Swoole-2.x需要 PHP-7.0.0 或更高版本
公司環(huán)境是php5.6.31所以比較麻煩需要編譯安裝途戒，7以上直接使用命令
(pecl install swoole)
wget https://github.com/swoole/swoole-src/archive/v1.10.1.tar.gz
tar -zxvf v1.10.1.tar.gz
cd swoole-src-1.10.1
phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make && make install
然后在php.ini添加swoole.so擴展即可
2.使用laravel的artisan創(chuàng)建命令
php artisan make:command Swoole #創(chuàng)建一個命令swoole并會在app/Console/Commands增加一個Swoole.php的文件
Commands\Swoole::Class #在Kernel.php里增加命令列表
3.運行socket服務
1.編輯app/Console/Command里的Swoole.php文件
<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
class Swoole extends Command
{
public $ws;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'swoole {action?}';
/**
* The console command description.
*
* @var string
*/
protected $description = 'swoole';
/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
}
/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
$action = $this->argument('action');
switch ($action) {
case 'close':
break;
default:
$this->start();
break;
}
}
public function start()
{
//創(chuàng)建websocket服務器對象芥映，監(jiān)聽0.0.0.0:9502端口
$this->ws = new \swoole_websocket_server("0.0.0.0", 9502);
//監(jiān)聽WebSocket連接打開事件
$this->ws->on('open', function ($ws, $request) {
var_dump($request->fd . "連接成功");
// $ws->push($request->fd, "hello, welcome\n");
});
//監(jiān)聽WebSocket消息事件
$this->ws->on('message', function ($ws, $frame) {
// echo "Message: {$frame->data}\n";
// $ws->push($frame->fd, "server: {$frame->data}");
// var_dump($ws->connection_info($frame->fd));
//fd綁定客戶端傳過來的標識uid
$ws->bind($frame->fd, $frame->data);
});
$this->ws->on('request', function ($request, $response) {
// 接收http請求從post獲取參數(shù)
// 獲取所有連接的客戶端糯彬，驗證uid給指定用戶推送消息
// token驗證推送來源捎琐，避免惡意訪問
if ($request->post['token'] == ### ) {
$clients = $this->ws->getClientList();
$clientId = [];
foreach ($clients as $value) {
$clientInfo = $this->ws->connection_info($value);
if (array_key_exists('uid', $clientInfo) && $clientInfo['uid'] == $request->post['s_id']) {
$clientId[] = $value;
}
}
if (!empty($clientId)) {
foreach ($clientId as $v) {
$this->ws->push($v, $request->post['info']);
}
}
}
});
//監(jiān)聽WebSocket連接關閉事件
$this->ws->on('close', function ($ws, $fd) {
echo "client:{$fd} is closed\n";
});
$this->ws->start();
}
}
【注】此處為了結合app上傳數(shù)據(jù)時使用curl觸發(fā)request回調通知web端的實例所以使用了httpserver的onrequest事件患雏，如果以后有更好的辦法去觸發(fā)服務端實時主動推送蹋宦。
2.編輯html
<div id="test">
<a href="javascript:void(0)">運行websocket</a>
</div>
$('#test').click(function(){
if("WebSocket" in window){
console.log("您的瀏覽器支持websocket\n");
var ws = new WebSocket("ws://66.66.66.66:9502");//創(chuàng)建websocket對象
ws.onopen = function(){
// ws.send("連接已建立\n");
ws.send($("#content").attr("js-sid"));
console.log("數(shù)據(jù)發(fā)送中");
}
ws.onmessage = function(evt){
var recv_msg = evt.data;
console.log("接受到的數(shù)據(jù)為:"+recv_msg);
}
ws.onerror = function(evt,e){
console.log("錯誤信息為"+e);
}
ws.onclose = function(){
console.log("連接已關閉");
}
}else{
console.log("您的瀏覽器不支持websocket\n");
}
});
3.curl方法（調用就行）
public function swooletest($param = ['s_id'=>2, 'info'=>'info'])
{
$param['token'] = ###;
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, "http://127.0.0.1:9502");
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_HEADER, 1);
curl_setopt($ch, CURLOPT_POST, 1);
//設置post數(shù)據(jù)
$post_data = $param;
curl_setopt($ch, CURLOPT_POSTFIELDS, $post_data);
curl_exec($ch);
curl_close($ch);
}
4.測試的時候直接在laravel的artisan所在目錄使用命令php artisan swoole即可啟動socket服務衔肢，然后頁面運行客戶端若专，最后調用curl推送數(shù)據(jù)久信。
4.成功之后
用supervisor守護swoole命令窖杀，或者nohup后臺啟動。
supervisor配置麻煩不過可以自動重啟裙士，nohup一條命令解決
nohup php artisan swoole & #一條命令解決
此處說明幾個問題
1.此處我采用的是bind方法入客，當客戶端連接的時候send一個uid過來，然后在服務端處理的時候把uid和fd綁定在一起腿椎，當你想向某個客戶端發(fā)送數(shù)據(jù)時傳一個uid桌硫，通過uid找到fd進行指定發(fā)送，但是此處我用的是遍歷getClientList所有連接用戶（方法欠佳）的信息connection_info進行判定啃炸。希望能改善這種方法
2.因為是curl訪問httpserver的形式铆隘，所以為了避免惡意訪問，加一個token驗證肮帐。
3.推送的信息轉換成json再傳咖驮，即info值
4.本實例的賬戶可能會在多個終端登錄，有多個fd綁定uid训枢，所以遍歷推送push
