基于swoole實現(xiàn)多人聊天室

第基于swoole實現(xiàn)多人聊天室$ch=curl_init();

curl_setopt($ch,CURLOPT_HTTP_VERSION,CURL_HTTP_VERSION_1_1);

curl_setopt($ch,CURLOPT_USERAGENT,'Mozilla/5.0(WindowsNT5.1)AppleWebKit/537.22(KHTML,likeGecko)Chrome/25.0.1364.172Safari/537.22');

curl_setopt($ch,CURLOPT_CONNECTTIMEOUT,30);

curl_setopt($ch,CURLOPT_TIMEOUT,30);

curl_setopt($ch,CURLOPT_RETURNTRANSFER,true);

if($ispost)

curl_setopt($ch,CURLOPT_POST,true);

curl_setopt($ch,CURLOPT_POSTFIELDS,$params);

curl_setopt($ch,CURLOPT_URL,$url);

else

if($params){

curl_setopt($ch,CURLOPT_URL,$url.''.$params);

}else{

curl_setopt($ch,CURLOPT_URL,$url);

//執(zhí)行

$response=curl_exec($ch);

if($response===FALSE){

//echo"cURLError:".curl_error($ch);

returnfalse;

$httpCode=curl_getinfo($ch,CURLINFO_HTTP_CODE);

$httpInfo=array_merge($httpInfo,curl_getinfo($ch));

//關(guān)閉url請求

curl_close($ch);

returnjson_decode($response,1);

}

客戶端client.php

php

namespaceapp\common;

classClient

public$msg='';

public$data=[];

publicfunctionlianjie(){

$cli=new\swoole_client(SWOOLE_SOCK_TCP);

//判斷連接狀態(tài)（同步連接模式）

$res=$cli-connect('',9502);

if(empty($res)){

return"連接失敗";

if(!empty($this-data)){

//發(fā)送消息給server

$rel=$cli-send(json_encode($this-data));

}else{

//發(fā)送消息給server

$rel=$cli-send($this-msg);

if(!empty($rel)){

return$rel;

}else{

returnflash;

}

控制器index.php

php

namespaceapp\index\controller;

useapp\common\Client;

useapp\common\Predis;

useapp\common\Sql;

useapp\index\model\User;

classIndex

//創(chuàng)建房間(添加拍賣倒計時)

publicfunctionchuangjian()

$data['time']=input("time");

$data['id']=input("id");

$cli=newClient();

$cli-data=[

'data'='chuangjian',

'arr'=$data

return$cli-lianjie();

//點擊添加哈希(進入房間)

publicfunctionjingru()

$data['name']=input("name");

$data['uid']=input("uid");

$cli=newClient();

$cli-data=[

'data'='jingru',

'arr'=$data

return$cli-lianjie();

//本房間推送(出價格成功并推送)

publicfunctionpushfan()

$data['fan']=input("fan");

$cli=newClient();

$cli-data=[

'data'=$data['fan'],

'msg'="恭喜用戶111,喜當(dāng)?shù)?!!!"

return$cli-lianjie();

//時間結(jié)束并指定推送

publicfunctionzhiding()

$data['fan']=input("fan");

$cli=newClient();

$cli-data