Linux에서 swoole 서비스를 구축하는 기본 단계
- 爱喝马黛茶的安东尼앞으로
- 2019-11-22 16:15:273532검색
1. swoole 서비스 설치
1. 다운로드 주소: https://github.com/swoole/ swoole- src/releases
2. 설치 소스 파일이 저장된 /usr/local/src/swoole에 tar 패키지를 업로드합니다.
3. 소스 파일 tar –xvfswoole.tar
4의 압축을 풀고 phpize
5 명령을 입력합니다. 참고: phpize는 PHP에 동적으로 확장을 추가할 수 있는 php-devel의 기능이므로 php-devel 패키지가 컴퓨터에 설치되어 있는지 확인하세요.
6 그런 다음 ./configure, 컴파일 및 감지 make 실행, swoole
7 명령을 차례로 입력합니다. -관련 소프트웨어 패키지를 개발하고 설치하세요. 그게 다입니다.
8.sudo make install
9.php.ini는 일반적으로 etc.에서 컴파일 및 설치됩니다. 성공적으로 설치한 후에는 php.ini를 수정하고 swoole을 추가해야 합니다. .so 확장자를 추가합니다. ：
10.extension=swoole.so
11을 입력하면 swoole이 확장 프로그램이 설치되었음을 알 수 있습니다. 성공적으로.
2. Apache 설치 및 swoole 서비스 시작
(1) 설치가 제대로 되었는지 테스트하고 swoole Php 서비스 시작
(2 ) Apache .php 파일과 client.php 파일에 서버를 추가합니다. 일반 디렉터리는 var/www/html
아래에 있습니다. (3) 두 개의 터미널을 엽니다. 소켓 긴 연결 서비스를 구현하려면 이 두 파일이 있는 디렉터리 아래에서 이 두 파일을 엽니다.
lsof 설치: yum -y install lsof
3. 서버 측 구성
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. #
$(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. start.php 파일을 시작하고 지정된 디렉터리로 이동한 다음 PHP-CLI를 사용하여 php start.php를 실행합니다. 이 방법에서는 스레드 보호가 활성화되지 않으며 프로그램이 끝난 후에도 스레드가 여전히 점유되어 있습니다. require'src/WebSocketSwoole/WebSocketService.php'; // require './WebSocketService.php'; session_start(); // $demoService = new\WebSocketSwoole\WebSocketService(); $demoService =\WebSocketSwoole\WebSocketService::getInstance(); $demoService->run();
PHP 중국어 웹사이트, 다수의 무료
swoole 입문 튜토리얼위 내용은 Linux에서 swoole 서비스를 구축하는 기본 단계의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
성명：
이 기사는 csdn.net에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제
이전 기사：한 기사에서 Swoole 설치 방법 알아보기다음 기사：한 기사에서 Swoole 설치 방법 알아보기