swoole之tcp服务器:
//创建tcp服务器new swoole_server(string $host,int $port,int $mode=SWOOLE_PROCESS,int $sock_type=SWOOLE_SOCK_TCP);
//事件bool swoole_server->on(string $event,mixed $callback);
//开启tcp服务器bool swoole_server->start();
//发送数据bool swoole_server->send(int $fd,string $data,int $reactorThreadld=0);
function swoole_server->set(array $setting);
参数说明：//$host的值：内网127.0.0.1、外网ip、0.0.0.0、ipv4或ipv6。//$port端口：1024以下需要root权限,习惯用9501。//$mode：默认SWOOLE_PROCESS多进程方式。//$socl_type:默认SWOOLE_SOCK_TCP。
//$event: connect建立链接时（回调函数有2个参数:$serv服务器信息、$fd客户端信息）； receive接收到数据（回调函数有4个参数:$serv服务器信息、$fd客户端信息、$from_id客户端id、$data接收的数据）； close关闭连接（回调函数有2个参数:$serv服务器信息、$fd客户端信息）；
可以使用网络调式助手软件、要关闭服务器防火墙。=========================================================================swoole之udp服务器:
//创建UDP服务器，和创建tcp服务器最后一个参数不一样。new swoole_server(string $host,int $port,int $mode=SWOOLE_PROCESS,int $sock_type=SWOOLE_SOCK_UDP);
//接收到数据bool swoole_server->on(string $event,mixed $callback); $event:'packet'，接收数据
//发送数据bool swoole_server->sendto(string $ip,int $port,string $data,int $server_socket=-1);
示例：//创建服务$serv = new swoole_server("0.0.0.0",9502,SWOOLE_PROCESS,SWOOLE_SOCK_UDP);//监听接收数据$serv->on('packet',function($serv,$data,$fd){ //发送回去数据 $serv->sendto($fd['address'],$fd['port'],"收到数据：$data");});//启动服务$serv->start();=======================================================================================swoole之web服务器
new swoole_http_server();swoole_http_Server 继承来自swoole_server.参数1：string $host 监听ip地址参数2：int $port 监听的端口on/start函数。
示例：$serv = new swoole_http_server("0.0.0.0",9501);//获取请求$serv->on('request',function($request,$response){ $response->header("Content-Type","text/html;charset=utf-8");//设置返回头 $response->end("hello".json_encode($request));});$serv->start();
在浏览器测试：xxx.xxx.xxx.xxx:9501。======================================================================================swoole之WebSocket服务器
new swoole_websocket_server();swoole_websocket_server 继承自swoole_http_server;on/start函数；open/message/close；//on函数的事件参数push()发送数据。
示例：
//服务端$serv = new swoole_websocket_server("0.0.0.0",9501);$serv->on('open',function($serv,$client_info){ $serv->push($client_info->fd,"hello");});$serv->on('message',function($serv,$client_info){ echo "接收到客户端消息：".$client_info; $serv->push($client_info->fd,"收到消息");});$serv->on('close',function($serv,$client_info){ echo "close".$client_info;});
$serv->start();
//前端websocket<script> var webSocketUrl = "ws://xxx.xxx.xxx.xxx:9501"; var webSocketServer = new WebSocket(webSocketUrl); webSocketServer.onopen = function(event){ console.log('连接成功'); } webSocketServer.onclose = function(event){ console.log('关闭'); } webSocketServer.onmessage = function(event){ console.log(event.data); } webSocketServer.onerror = function(event,e){ console.log('错误'); }</script>============================================================================swoole之定时器js的setInterval()方法linux的crontab
循环触发函数：swoole_timer_tick()参数1：int $after_time_ms 指定时间【毫秒】参数2：mixed $callback function 执行的函数参数3：mixed $user_param 用户参数
清除定时器函数：bool swoole_timer_clear(int $timer_id).
单次触发函数:swoole_timer_after()参数与循环触发函数一样。
示例：循环执行swoole_timer_tick(3000,function($timer_id){ echo $timer_id;});
单次执行swoole_timer_after(3000,function(){ echo '单次';});=================================================================================swoole之异步TCP服务器
task()函数 //投递异步任务on('事件',function(){}) //异步执行的事件函数finish()函数 //任务处理完成后结果
示例：$serv = new swoole_server("0.0.0.0",9501);//设置异步，进程工作数$serv->set(array('task_worker_num'=>4));//投递异步任务$serv->on("receive",function($serv,$fd,$from_id,$data){ $task_id = $serv->task($data);//异步ID echo "异步ID：".$task_id;});
//处理异步任务$serv->on('task',function($serv,$task_id,$from_id,$data){ echo "异步ID：".$task_id; $serv->finish("$data ok");});
//处理结果$serv->on('finish',function($serv,$task_id,$data){ echo "执行成功";});
$serv->start();===========================================================================swoole之tcp客户端
new swoole_client();
示例：//创建客户端$client = new swoole_client(SWOOLE_SOCK_TCP);//连接服务器$client->connect('xxx.xxx.xxxx.xxx',9501,5) or die('连接失败');//发送数据$client->send('hello') or die('发送失败');//接收数据$data = $client->recv();//关闭客户端$client->close();=======================================================================================swoole之tcp异步客户端
new swoole_client()SWOOLE_SOCK_TCP //TCP协议SWOOLE_SOCK_ASYNC //异步支持
示例：$client = new swoole_client(SWOOLE_SOCK_TCP,SWOOLE_SOCK_ASYNC);//注册连接成功的回调$client->on('connect',function($cli){ $cli->send('hello');});//注册数据接收$client->on('receive',function($cli,$data){ echo $data;});//注册连接失败$client->on('error',function($cli){ echo '失败';});//注册关闭$client->on('close',function($cli){ echo '关闭';});//发起连接$client->connect('xxx.xxx.xxx.xxx',9501,10);==============================================================================swoole之进程
new swoole_process().参数1：mixed $function 子进程创建成功后执行的函数。参数2：$redirect_stdin_stdout 重定向子进程的标准输入输出。启动此选项后，在进程 内echo将不是打印到屏幕，而是写入到管道。读取键盘输入将变成从管道中读取 ，默认为阻塞读取。参数3：$create_pipe 是否创建管道， $redirect_stdin_stdout后，此选项将忽略用户参数，强制为true，如果子进程内没有 进程间通信，可以设置为false。
示例：//进程调用的执行函数function doProcess(swoole_process $worker){ echo "PID".$worker_pid;}
//创建进程$process = new swoole_process("doProcess");$pid = $process->start();//创建第二个进程$process = new swoole_process("doProcess");$pid = $process->start();//创建第三个进程$process = new swoole_process("doProcess");$pid = $process->start();
//等待结束swoole_process::wait();=============================================================================swoole进程事件：swoole_event_add();参数1：int $sockint 文件描述符mixed $read_callback 就是stream_socket_client/fsockopen 创建的资源sockets资源，就是sockets扩展中socket_create创建的资源，需要在编译时加入.configure --enable-sockets参数2：可读回调函数
示例：
//进程调用的执行函数function doProcess(swoole_process $worker){ $process->write('pid'.$worker->pid);//子进程写入管道pipe echo "写入信息：￥worker->pid $worker->callback";}
$workers = [];//进程池$worker_num = 3;//进程数量for($i=0;$i<$worker_num;$i++){ $process = new swoole_process('doProcess');//创建新进程 $pid = $process->start();//启动进程并获取进程id $workers[$pid] = $process;//放入数组}
//添加进程事件，向每一个子进程添加需要执行的动作foreach($workers as $process){ //添加 swoole_event_add($process->pipe,function($pipe) use($process){ $data = $process->read(); echo '接收到'.$data; })}=============================================================================swoole进程队列通信
string swoole_process->pop(int $maxsize=8192);//取数据bool swoole_process->push(string $data);//放数据array swoole_process::wait(bool $blocking=true);
示例：$workers = [];//进程仓库$worker_num = 2;//最大进程数for($i=0;$i<$worker_num;$i++){ $process = new swoole_process('doProcess',false,false);//创建新进程 $process->useQueue();//开启队列，类似于全局函数 $pid = $process->start();//启动进程并获取进程id $workers[$pid] = $process;//放入数组}
//进程调用的执行函数function doProcess(swoole_process $worker){ $recv = $process->pop();//默认8192 echo "从主进程获取导数据：$recv"; sleep(5); $process->exit(0);}//主进程向子进程添加数据foreach($workers as $pid=>$process){ $process->push("hello 子进程 $pid");}//等待子进程结束，回收资源for($i=0;$i<$worker_num;$i++){ $ret = swoole_process::wait();//等待执行完成 $pid = $ret['pid']; unset($workers[$pid]); echo "子进程$pid退出";}===============================================================================进程信号触发器bool swoole_process::signal(int $signo,callable $callback);
function swoole_process::alarm(int $interval_usec,int $type=ITIMER_REAL):bool.
示例：//触发函数，异步执行的，swoole_process::signal(SIGALRM,function(){ echo '123';});
//定时信号swoole_process::alarm(100*1000);//100毫秒后执行
//如果达到10次停止swoole_process::signal(SIGALRM,function(){ static $i=0; echo '123'; $i++; if($i>10){ swoole_process::alarm(-1);//清除定时器 }});===============================================================================swoole之锁机制
$lock = new swoole_lock(SWOOLE_MUTEX); 参数：文件锁、读写锁、信号量、互斥锁、自旋锁。lock();unlock();
示例：//创建锁对象$lock = new swoole_lock(SWOOLE_MUTEX);//互斥锁echo '创建互斥锁';$lock->lock();//开始锁定 主进程if(pcntl_fork() > 0){ sleep(1); $lock->unlock();//解锁}else{ echo '子进程在等待锁'; $lock->lock();//上锁 echo "子进程获取锁"; $lock->unlock();//释放锁 exit('子进程退出');}echo '主进程释放锁';unset($lock);sleep(1);echo "子进程退出";================================================================================swoole之DNS查询
语法：swoole_async_dns_lookup('域名地址',function($host,$ip));
示例：swoole_async_dns_lookup('www.baidu.com',function($host,$ip){ echo 'host='.$host .' ip='.$ip;});================================================================================swoole之异步文件读取
语法：函数方式：swoole_async_readfile(string $filename,mixed $callback);面向对象方式：Swoole\Async::readFile(string $filename,mixed $callback);
示例：swoole_async_readfile(__DIR__.'/1.txt',function($filename,$content){ echo $filename . ':'.$content;});===================================================================================swoole之异步文件写入语法：swoole_async_writefile(string $filename,string $fileContent, callable $callback=null,int $flags=0);
参数一：文件的名字，必须有可写权限；参数二：要写入的内容，最大4M;参数三：写入后的回调函数，可选；参数四：写入选项，可以使用FILE_APPEND表示追加到文件末尾；
示例：swoole_async_writefile(__DIR__.'/1.txt','hello',function($filename){ echo $filename;},0);==========================================================================================swoole之异步事件语法：bool swoole_event_add(int $sock,mixed $read_callback,mixed $write_callback=null,int $flags=null);示例：$fp = stream_socket_client("tcp://www.qq.com:80",$error,$errstr,30);fwrite($fp,"GET / HTTP/1.1\r\nHost:www.qq.com\r\n\r\n");//添加异步事件swoole_event_add($fp,function($fp){ $resp = fread($fp,8192); var_dump($resp); swoole_event_del($fp); fclose($fp);});
echo "这个是异步的";==========================================================================================swoole之异步mysql操作语法：swoole_mysqlconnectonescapequery示例：$db = new swoole_mysql();$config = [ 'host' => '192.168.10.1', 'user' => 'root', 'password' => '123456', 'database' => 'mysql', 'charset' => 'utf8'];//连接数据$db->connect($config,function($db,$result){ if($result === false){ var_dump($db->connect_errno,$db->connect_error); die('失败'); } //成功 $sql = 'show tables'; $db->query($sql,function(swoole_mysql $db,$res){ if($res === false){ var_dump($db->error); die('查询失败'); }else if($res === true){ var_dump($db->affected_rows,$db->insert_id); } var_dump($res); $db->close(); });});=======================================================================================swoole之聊天的简单实现：服务器端代码：//创建websocket服务器$ws = new swoole_websocket_server("0.0.0.0",9502);$ws->on('open',function($ws,$request){ echo '新用户：'.$request->fd .'加入'; //设置用户id，存入全局变量 $GLOBALS['fd'][$request->fd]['id'] = $request->fd; $GLOBALS['fd'][$request->fd]['name'] = '匿名用户';});$ws->on('message',function($ws,$request){ $msg = $GLOBALS['fd'][$request->fd]['name'].":".$request->data."\n"; if(strstr($request->data,"#name#")){ //用户设置昵称 $GLOBALS['fd'][$request->fd]['name'] = str_replace("#name#",'',$request->data); }else{ //发送给每一个客户端 foreach($GLOBALS['fd'] as $val){ $ws->push($val['id'],$msg); } }});$ws->on('close',function(){ echo '客户端断开连接:'.$request; unset($GLOBALS['fd'][$request]);});
$ws->start();
客户端：引入jquery.js、webSocket.js。var msg = document.getElementById('msg');var wsSwever = 'ws://192.168.10.1:9502';var websocket = new WebSocket(wsServer);websocket.onopen = function(evt){ //显示登录服务器成功 //msg.innerHTML = websocket.readState; //websocket.readState属性： //CONNECTING 0 The connection is not yet open. //OPEN 1 The connection is open and ready to communite. //CLOSEING 2 The connection is in the process of closing。 //CLOSED 3 The connection is closed or couldn't be opened. }
websocket.onmessage = function(evt){ msg.innerHTML += evt.data +'<br>';//不断递增的数据 console.log('从服务器获取到的数据：'+evt.data);};//监听连接关闭websocket.onclose = function(evt){ console.log('服务器拒绝');};//监听连接错误信息websocket.onerror = function(evt){ console.log('错误：'.evt.data);}//发送信息function send_msg(){ var text = document.getElementById('text').value;//获取数据 websocket.send(text); document.getElementById('text').value = '';}//发送昵称function send_name(){ var text = document.getElementById('text').value;//获取数据 websocket.send("#name#"+text);//向服务器发送数据 document.getElementById('text').value = ''; var myTitle = document.getElementById("myTitle"); myTitle.innerHtml = "IM "+text; alert("设置成功");}
转载于:https://www.cnblogs.com/gyfluck/p/10442470.html
