ThinkPHP 5.0 프레임 워 크 는 Swoole 개발 과 결합 하여 WebSocket 온라인 채 팅 사례 에 대한 상세 한 설명 을 실현 합 니 다.
10114 단어 ThinkPHP5.0SwooleWebSocket온라인 채 팅
ThinkPHP 는 Swoole 을 사용 하려 면 think-swoole Composer 패 키 지 를 설치 해 야 합 니 다.전제 시스템 은 Swoole PECL 확장 이 설치 되 어 있 습 니 다.(관련 글:Linux 에서 원본 패키지 설치 시 Swole 확장 사용
tp5 프로젝트 루트 디 렉 터 리 에서 coposer 명령 을 실행 하여 think-swoole 설치:
composer require topthink/think-swoole
설치 성공:
할 말 이 많 지 않 으 니 코드 를 직접 입력 하 세 요.
새 WebSocket.php 컨트롤 러:
(감청 포트 는 서버 의 운행 을 확인 하고 보탑 환경 에 보안 그룹 규칙 을 추가 해 야 합 니 다)
<?php
namespace app\home\controller;
use think\swoole\Server;
class WebSocket extends Server
{
protected $host = '0.0.0.0'; //
protected $port = 9501; // 9501
protected $serverType = 'socket';
protected $option = [
'worker_num'=> 4, // Worker
'daemonize' => false, // ( true)
'backlog' => 128, //Listen
'dispatch_mode' => 2, // , worker
// : 60 , 10
'heartbeat_check_interval' => 60,
'heartbeat_idle_time' => 600
];
//
public function onOpen($server,$req)
{
$fd = $req->fd;//
$uid = $req->get['uid'];// id
$token = $req->get['token'];// token
// token ......
if (!$token) {
$arr = array('status'=>2,'message'=>'token ');
$server->push($fd, json_encode($arr));
$server->close($fd);
return;
}
// fd ......
echo " {$uid} , {$fd}
";
}
//
public function onMessage($server,$frame)
{
$fd = $frame->fd;
$message = $frame->data;
// fd uid ......
$uid = 666;
$data['uid'] = $uid;
$data['message'] = ' '.$uid.' :'.$message;
$data['post_time'] = date("m/d H:i",time());
$arr = array('status'=>1,'message'=>'success','data'=>$data);
//
//$server->push($fd, json_encode($arr));
//
foreach($server->connections as $fd) {
$server->push($fd, json_encode($arr));
}
}
//
public function onClose($server,$fd)
{
echo " {$fd}
";
}
}
전단 데모 페이지:(컨트롤 러 가 로그 인 상 태 를 판단 하고 데이터 논 리 를 분배 하 는 것 을 생략 합 니 다...)
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8" />
<meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1" />
<meta name="viewport" content="width=device-width,initial-scale=1,minimum-scale=1,maximum-scale=1,user-scalable=no" />
<title>Chat</title>
<link rel="stylesheet" type="text/css" href="/static/liaotian/chat.css" rel="external nofollow" />
<script src="/static/liaotian/js/jquery.min.js"></script>
<script src="/static/liaotian/js/flexible.js"></script>
</head>
<body>
<header class="header">
<a class="back" href="javascript:history.back()" rel="external nofollow" ></a>
<h5 class="tit"> </h5>
<a href=""><div class=" rel="external nofollow" right"> </div></a>
</header>
<!-- start-->
<div class="message"> </div>
<!-- end-->
<!-- start-->
<div class="footer">
<img id="setbtn" src="/static/liaotian/images/hua.png" alt="" />
<img src="/static/liaotian/images/xiaolian.png" alt="" />
<input type="text" id="msg" value="" maxlength="300">
<p style="background: rgb(17, 79, 142);" id="sendBtn"> </p>
</div>
<!-- end-->
</body>
</html>
<script src="http://apps.bdimg.com/libs/jquery/2.1.4/jquery.min.js"></script>
<script src="https://cdn.bootcss.com/layer/3.1.0/layer.js"></script>
<script type="text/javascript">
$(function () {
var uid = 666;// id
var token = 'abcdefg';// token
// WebSocket
var supportsWebSockets = 'WebSocket' in window || 'MozWebSocket' in window;
if (supportsWebSockets) {
// WebSocket (ip ip)
var ws = new WebSocket("ws://127.0.0.1:9501?uid="+uid+"&token="+token);
ws.onopen = function () {
layer.msg(' ',{shade:0.1,icon:1,time:600});
};
ws.onerror = function () {
layer.msg(' ',{shade:0.1,icon:2,time:600});
};
ws.onmessage = function (evt) {
var data = $.parseJSON(evt.data);
//
if(data.status != 1){
layer.alert(data.message,{icon:2});
return;
}
//
if (data.status==1 && data.data.message!='') {
var html = "";
if (data.data.uid == uid) {
html += "<div style='word-break:break-all' class=\"show\"><div class=\"time\">"+data.data.post_time+"</div><div class=\"msg\"><img src=\""+data.data.head_img+"\" alt=\"\" /><p><i clas=\"msg_input\"></i>"+data.data.message+"</p></div></div>";
}else{
html += "<div style='word-break:break-all' class=\"send\"><div class=\"time\">"+data.data.post_time+"</div><div class=\"msg\"><img src=\""+data.data.head_img+"\" alt=\"\" /><p><i clas=\"msg_input\"></i>"+data.data.message+"</p></div></div>";
}
}
$(".message").append(html);
setTimeout(function () {
($('.message').children("div:last-child")[0]).scrollIntoView();//
},100);
};
ws.onclose = function (res) {
};
//
$("#sendBtn").click(function () {
var contents = $("#msg").val().trim();
if(contents == null || contents == ""){
layer.msg(' ',{shade:0.1,icon:2,time:600});
return false;
}else{
ws.send(contents);
$("#msg").val("");
}
});
//
$("#msg").keydown(function (evel) {
var that = $(this);
if (evel.keyCode == 13) {
evel.cancelBubble = true;
evel.preventDefault();
evel.stopPropagation();
var contents = that.val().trim();
if(contents == null || contents == ""){
layer.msg(' ',{shade:0.1,icon:2,time:600});
return false;
}else{
ws.send(contents);
that.val("");
}
}
});
}else{
layer.alert(" WebSocket!");
}
});
</script>
서버 가 프로젝트 루트 디 렉 터 리 로 이동 하여 서 비 스 를 시작 합 니 다:php public/index.php Websocket/start
(이 경 로 는 홈 모듈 을 기본 모듈 로 연결 하기 때 문 입 니 다.tp5 기본 상황 은:php public/index.php index/Websocket/start
오픈 성공,포트 가 감청 되 었 음 확인:lsof -i:9501
데모 효 과 는 다음 과 같 습 니 다.
서버 감청 은 다음 과 같 습 니 다.
사용자 가 새로 고침 할 때마다 fd 표 지 는 변 합 니 다.
thinkpHP 와 관련 된 내용 에 관심 이 있 는 독자 들 은 본 사이트 의 주 제 를 볼 수 있 습 니 다.,,,,,ThinkpHP 입문 강좌,thinkpHP 템 플 릿 조작 기법 요약,ThinkPHP 상용 방법 총화,codeigniter 입문 강좌,CI(CodeIgniter)프레임 워 크 진급 강좌과Zend FrameWork 프레임 워 크 입문 강좌.
본 고 는 ThinkPHP 프레임 워 크 를 기반 으로 한 PHP 프로 그래 밍 에 도움 이 되 기 를 바 랍 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Swoole, Websocket 채팅방 만들기.1. 프런트엔드 CSS 코드 2. 서버측 Server.php, php Server를 실행합니다.php...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.