1. Swoole-Dienst installieren
1. Laden Sie den Swoole-Quellcode herunter, Download-Adresse: https://github.com/swoole/swoole-src/releases
2. Laden Sie das TAR-Paket nach /usr/local/src/swoole hoch, wo die Installationsquelldateien gespeichert sind.
3. Dekomprimieren Sie die Quelldatei, tar –xvfswoole.tar
4. Geben Sie den Befehl phpize ein.
Hinweis: phpize ist php -devel Es kann dynamisch Erweiterungen zu PHP hinzufügen. Stellen Sie daher bitte sicher, dass das Paket php-devel auf Ihrem Computer installiert ist.
6. Geben Sie dann nacheinander die folgenden Befehle ein: ./configure, führen Sie die Kompilierung und Erkennung von Make aus und kompilieren Sie swoole
7. Es fehlen pcre- und pcre-devel-bezogene Softwarepakete. Installieren Sie sie einfach.
8.sudo make install
9.php.ini wird im Allgemeinen unter usw. kompiliert und installiert. Nach erfolgreicher Installation müssen wir auch php.ini ändern und die Erweiterung swoole.so hinzufügen it:
10.extension=swoole.so
11. Geben Sie php -m ein und Sie können swoole sehen, was anzeigt, dass die Erweiterung erfolgreich installiert wurde.
2. Apache installieren und den swoole-Dienst starten
(1) Testen Sie, ob die Installation korrekt ist und starten Sie den swoole-PHP-Dienst
(2) Fügen Sie die server.php hinzu Datei in Apache und Client-.php-Dateien. Das allgemeine Verzeichnis befindet sich unter var/www/html
(3) Öffnen Sie zwei Terminals. Öffnen Sie diese beiden Dateien in dem Verzeichnis, in dem sich diese beiden Dateien befinden, um einen Socket-langen Verbindungsdienst zu erreichen.
Installieren Sie lsof: yum -y install lsof
3. Konfigurieren Sie die Serverseite
class WebSocketService {
private static $instance = NULL;
public $tagindex = 0;
public $server = null;
public $office_cache = null;
public $timer_arr = []; //该变量保存所有的定时器任务ID，每一个客户端可以通过$timer_arr[客户端ID]
得到该客户端建立的所有定时器
public $conf = [
'host' => '0.0.0.0',
'port' => 9999, //服务使用端口
'worker_num' => 2, //启动worker进程数
'task_worker_num' => 8, //启动task进程数
'is_daemonize' => 0, //是否后台运行：0-否，1-是
'log_file' =>'/tmp/swoole_webSocket_server.log', //日志文件路径
'abc' =>0,
];
public function getTagIndex() {
return $this->conf['abc'];
}
public function setSetTagIndex($index) {
$this->conf['abc'] = 100;
echo $this->getTagIndex();
}
public function __construct($config = []) {
$this->office_cache = array('1' => '1', '3'=>'2');
$this->conf = array_merge($this->conf, (array)$config);
}
//静态方法，返回此类唯一实例
public static function getInstance(){
if(empty(self::$instance)){
echo "instance \n";
self::$instance=new WebSocketService();
}
return self::$instance;
}
/**
* 服务器端运行webSocket的入口
*/
public function run() {
try {
$this->server = new \swoole_websocket_server($this->conf['host'],$this->conf['port']);
$this->server->set(
[
'worker_num' => $this->conf['worker_num'],
'task_worker_num' =>$this->conf['task_worker_num'],
'daemonize' => $this->conf['is_daemonize'],
'log_file' => $this->conf['log_file'],
]
);
//注册方法列表
$this->server->on('open', [$this, 'open']);
$this->server->on('message', [$this, 'message']);
$this->server->on('task', [$this, 'task']);
$this->server->on('finish', [$this, 'finish']);
$this->server->on('close', [$this, 'close']);
$this->server->start();
} catch (\Exception $e) {
var_dump($e->getCode() . ':' . $e->getMessage());
}
}
/**
* 建立socket链接时，执行方法
* @param $server
* @param $request
*/
public function open($server, $request) {
$data = [
'client_id' => $request->fd,
'request' => $request
];
echo 'open<<'.$data['client_id'];
$this->doOpen($data);
}
/**
* 发送消息时，执行方法
* @param $server
* @param $frame
*/
public function message($server, $frame) {
echo "GET_mesage\n";
$data = [
'client_id' => $frame->fd,
'data' => $frame->data,
'frame' => $frame,
];
$this->doMessage($data);
}
/**
* 执行具体任务
* @param $server
* @param $task_id
* @param $from_id
* @param $data
*/
public function task($server, $task_id, $from_id, $data) {
$data['task_id'] = $task_id;
$data['from_id'] = $from_id;
$this->doTask($data);
}
/**
* 任务结果处理
* @param $server 服务器对象
* @param $taskId 任务进程ID
* @param $data
*/
public function finish($server, $taskId, $data) {
$data['task_id'] = $taskId;
$this->doFinish($data);
}
/**
* 关闭链接
* @param $server 服务器对象
* @param $client_id 客户端唯一标识
*/
public function close($server, $client_id) {
$data = [
'client_id' => $client_id
];
$this->doClose($data);
}
/**
* 客户端成功连接到服务器时，会触发该方法
* 子类根据需求重写该方法
* @param $data
* [
* 'client_id', //客户端唯一标识
* 'data', //一些请求数据
* 'frame', //swoole的数据
* ];
*/
public function doOpen($data) {
echo "建立连接成功";
}
/**
* 得到Swoole Websocket Server
*
* @return null|\swoole_websocket_server
*/
public function getServer()
{
return $this->server;
}
/**
* 收到客户端发来的消息，会触发该方法
* 子类根据需求重写该方法
* @param $data
* [
* 'client_id', //客户端唯一标识
* 'data', //客户端发送过来的消息(数据)
* 'frame', //swoole的数据
* ];
*/
public function doMessage($data) {
$info = json_decode($data['data'],true);
$officeid = $info['officeid'];
$client_id = $data['client_id'];
echo"<<<<".$officeid.">>>>".$client_id."\r\n";
if ($officeid == 1) {
$this->sendMsgToClient('2',array('msg' =>'我是1号场地发送给你数据'));
} else {
$this->sendMsgToClient('1',array('msg' =>'我是3号场地发送给你数据'));
}
}
/**
* 具体的工作任务。需要通过 $this->doJob()来触发
* 子类根据需求重写该方法
* @param $data
* [
* 'client_id', //客户端唯一标识
* ];
*/
public function doTask($data) {
}
/**
* 工作的结果处理。
* 子类根据需求重写该方法
* @param $data
* [
* 'client_id', //客户端唯一标识
* ];
*/
public function doFinish($data) {
}
/**
* 客户端断开时会自动触发该方法
* 子类根据需求重写该方法
* @param $data
* [
* 'client_id', //客户端唯一标识
* ];
*/
public function doClose($data) {
}
/**
* 发送任务
* @param $data 必须是数组，且要有$data['client_id']
*/
public function doJob($data) {
$this->server->task($data);
}
public function finishJob($data) {
$this->server->finish($data);
}
/**
* 发送消息到客户端
* @param $client_id
* @param $msg
*/
public function sendMsgToClient($client_id, $msg) {
echo "发送信息给客户端：{$client_id} | {$msg['action']['name']} | " . date('Y-m-dH:i:s') . "\r\n";
$this->server->push($client_id, json_encode($msg));
}
/**
* 关闭客户端链接
* @param $client_id
*/
public function closeClient($client_id) {
$this->server->close($client_id);
}
/**
* 添加定时器
* @param $client_id
* @param $tick_time
*/
public function addTimer($client_id, $tick_time) {
//暂未实现,先使用swoole原生写法
}
/**
* 清除定时器
* @param $client_id
* @param $arr
*/
public function clearTimer($client_id, &$arr) {
if (is_array($arr)) {
foreach ($arr[$client_id] as $val) {
if (is_array($val)) {
foreach ($val as $v) {
swoole_timer_clear($v);
}
} else {
swoole_timer_clear($val);
}
}
}
unset($arr[$client_id]);
}
}4. Konfigurieren Sie das HTML-Frontend
$(document).ready(function(){
varwsurl = "ws://182.92.101.206:9999/";
console.log(wsurl);
varwebsocket = new WebSocket(wsurl);
websocket.onopen= function(evt){
console.log('Server: 打开WebSocket连接');
};
websocket.onclose= function(evt){
console.log('Server: 关闭WebSocket连接');
};
websocket.onmessage= function(evt){
varres = JSON.parse(evt.data);
console.log('Server: 收到消息(来自：'+res+'请求)');
console.log(res);
};
websocket.οnerrοr= function(evt){
console.log('Server: 出现错误');
console.log(evt.data);
}
functiondoSend(msg){
console.log('Client:发送消息 ' + msg);
websocket.send(msg);
}
});5. Starten Sie die Datei start.php, wechseln Sie mit der CD in das angegebene Verzeichnis, und dann führt PHP-CLI php start.php aus. Bei dieser Methode ist der Thread-Schutz nicht aktiviert und der Thread ist nach Programmende weiterhin belegt.
require'src/WebSocketSwoole/WebSocketService.php'; // require './WebSocketService.php'; session_start(); // $demoService = new\WebSocketSwoole\WebSocketService(); $demoService =\WebSocketSwoole\WebSocketService::getInstance(); $demoService->run();
PHP chinesische Website, eine große Anzahl kostenloser Swoole-Einführungs-Tutorials, willkommen zum Online-Lernen!
Das obige ist der detaillierte Inhalt vonGrundlegende Schritte zum Erstellen eines Swoole-Dienstes unter Linux. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
