PHP 프레임 워 크 웹 소켓 온라인 채 팅 통신 시스템 구현
think-swoole Composer패 키 지 를 설치 해 야 합 니 다.전제 시스템 은 Swoole PECL 확장 이 설치 되 어 있 습 니 다.tp5 프로젝트 루트 디 렉 터 리 에서 composer 명령 을 실행 하여 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많은 PHPer 가 진급 할 때 문제 와 병목 에 부 딪 히 고 업무 코드 를 많이 써 서 방향 감각 이 없어 서 거기서 부터 향상 시 켜 야 할 지 모 르 겠 습 니 다.이에 대해 저 는 자 료 를 정 리 했 습 니 다.분포 식 구조,높 은 확장 가능,고성능,높 은 병발,서버 성능 향상,TP6,laravel,YII 2,Redis,Swole,Swoft,Kafka,Mysql 최적화,셸 스 크 립 트,Docker,마이크로 서비스,Nginx 등 여러 지식 포인트 고급 드라이 클 리 어 에 필요 한 것 은 무료 로 공유 할 수 있 습 니 다. ，필요했어 여기 찍 어 주세요. 총결산
위 에서 말 한 것 은 소 편 이 소개 한 PHP 프레임 워 크 로 웹 소켓 온라인 채 팅 통신 시스템 을 실현 하 는 것 입 니 다.여러분 에 게 도움 이 되 기 를 바 랍 니 다.궁금 한 점 이 있 으 시 면 메 시 지 를 남 겨 주세요.소 편 은 바로 답 해 드 리 겠 습 니 다.여기 서도 저희 사이트 에 대한 여러분 의 지지 에 감 사 드 립 니 다!
만약 당신 이 본문 이 당신 에 게 도움 이 된다 고 생각한다 면,전 재 를 환영 합 니 다.번 거 로 우 시 겠 지만 출처 를 밝 혀 주 십시오.감사합니다!
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Laravel - 변환된 유효성 검사 규칙으로 API 요청 제공동적 콘텐츠를 위해 API를 통해 Laravel CMS에 연결하는 모바일 앱(또는 웹사이트) 구축을 고려하십시오. 이제 앱은 CMS에서 번역된 콘텐츠를 받을 것으로 예상되는 다국어 앱이 될 수 있습니다. 일반적으로 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
