PHP+swoole實現聊天群發功能

来源:https://www.cnblogs.com/a609251438/archive/2019/12/31/12127505.html
-Advertisement-
Play Games

本篇文章主要介紹PHP+swoole實現聊天群發功能,感興趣的朋友參考下,希望對大家有所幫助。 php代碼: $serv = new swoole_websocket_server("127.0.0.1",3999); //服務的基本設置 $serv->set(array( 'worker_num' ...


本篇文章主要介紹PHP+swoole實現聊天群發功能,感興趣的朋友參考下,希望對大家有所幫助。

php代碼:

$serv = new swoole_websocket_server("127.0.0.1",3999);

//服務的基本設置

$serv->set(array(

'worker_num' => 2,

'reactor_num'=>8,

'task_worker_num'=>1,

'dispatch_mode' => 2,

'debug_mode'=> 1,

'daemonize' => true,

'log_file' => __DIR__.'/log/webs_swoole.log',

'heartbeat_check_interval' => 60,

'heartbeat_idle_time' => 600,

));

$serv->on('connect', function ($serv,$fd){

// echo "client:$fd Connect.".PHP_EOL;

});

//測試receive

$serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){

// echo "receive#{$from_id}: receive $data ".PHP_EOL;

});

$serv->on('open', function($server, $req) {

// echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;;

// echo PHP_EOL;

});

$serv->on('message',function($server,$frame) {

// echo "message: ".$frame->data.PHP_EOL;

$msg=json_decode($frame->data,true);

switch ($msg['type']){

case 'login':

$server->push($frame->fd,"歡迎歡迎~");

break;

default:

break;

}

$msg['fd']=$frame->fd;

$server->task($msg);

});

$serv->on("workerstart",function($server,$workerid){

// echo "workerstart: ".$workerid.PHP_EOL;

// echo PHP_EOL;

});

$serv->on("task","on_task");

$serv->on("finish",function($serv,$task_id,$data){

return ;

});

$serv->on('close', function($server,$fd,$from_id) {

// echo "connection close: ".$fd.PHP_EOL;

// echo PHP_EOL;

});

$serv->start();

function on_task($serv,$task_id,$from_id,$data) {

switch ($data['type']){

case 'login':

$send_msg="說:我來了~";

break;

default:

$send_msg="說:{$data['msg']['speak']}";

break;

}

foreach ($serv->connections as $conn){

if ($conn!=$data['fd']){

if (strpos($data['msg']['name'],"游客")===0){

$name=$data['msg']['name']."_".$data['fd'];

}else{

$name=$data['msg']['name'];

}

}else{

$name="我";

}

$serv->push($conn,$name.$send_msg);

}

return;

}

function on_finish($serv,$task_id,$data){

return true;

}

前端代碼:

<!DOCTYPE html>

<html>

<head>

<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

<title>WebSocket測試</title> 

<script language="javascript"type="text/javascript" src="jquery-1.12.0.min.js"> 

</script>

</head>

<body>

<h2>WebSocket Test</h2> 

昵稱:<input type="text" id="name" size="5" value="游客"/> <input type="text" id="content"> 

<button onclick="speak_to_all()">發送</button>

<br/><br/>

<textarea id="message" style="overflow-x:hidden" rows="10" cols="50"></textarea> 

<p id="output"></p>

</body> 

<script language="javascript"type="text/javascript"> 

var wsUri ="ws://127.0.0.1:3999/"; 

var output; 

function init() { 

output = document.getElementById("output"); 

testWebSocket();

}

function testWebSocket() { 

websocket = new WebSocket(wsUri); 

websocket.onopen = function(evt) { 

onOpen(evt) 

}; 

websocket.onclose = function(evt) { 

onClose(evt) 

}; 

websocket.onmessage = function(evt) { 

onMessage(evt) 

}; 

websocket.onerror = function(evt) { 

onError(evt) 

}; 

}

function get_speak_msg(){

var name=document.getElementById("name").value;

var speak=document.getElementById("content").value;

var json_msg='{"name":"'+name+'","speak":\"'+speak+'"}';

return json_msg;

}

function pack_msg(type,msg){

return '{"type":"'+type+'","msg":'+msg+'}';

}

function onOpen(evt) {

append_speak("已經聯通伺服器.........");

speak_msg=get_speak_msg();

send_msg=pack_msg("login",speak_msg);

doSend(send_msg);

}

function onClose(evt) { 

append_speak("俺老孫去也!");

} 

function onMessage(evt) {

append_speak(evt.data);

}

function onError(evt) {

alert(evt.data);

}

function doSend(message) { 

websocket.send(message);

}

function append_speak(new_msg){

document.getElementById("message").value=document.getElementById("message").value+new_msg+"\n";

document.getElementById('message').scrollTop = document.getElementById('message').scrollHeight;

}

function speak_to_all(){

send_msg=pack_msg("speak",get_speak_msg());

if(document.getElementById("content").value==""){

return;

}

doSend(send_msg);

document.getElementById("content").value="";

}

init();

</script>

</html>

總結:以上就是本篇文的全部內容,希望能對大家的學習有所幫助。

以上內容希望幫助到大家,很多PHPer在進階的時候總會遇到一些問題和瓶頸,業務代碼寫多了沒有方向感,不知道該從那裡入手去提升,對此我整理了一些資料,包括但不限於:分散式架構、高可擴展、高性能、高併發、伺服器性能調優、TP6,laravel,YII2,Redis,Swoole、Swoft、Kafka、Mysql優化、shell腳本、Docker、微服務、Nginx等多個知識點高級進階乾貨需要的可以免費分享給大家,需要的可以加入我的官方群點擊此處


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • ©Copyright 蕃薯耀 2019年12月31日 http://fanshuyao.iteye.com/ 使用方法: ©Copyright 蕃薯耀 2019年12月31日 http://fanshuyao.iteye.com/ ...
  • Iframe 高度自適應, js控制Iframe 高度自適應, iframe自適應高度 ©Copyright 蕃薯耀 2019年12月31日 http://fanshuyao.iteye.com/ 方法一:js控制Iframe 高度自適應 這個方法之前一直都在用,沒有問題,但最新發現有些情況不行(具 ...
  • JS內置對象【字元串】 // charAt() 返回字元 // charCodeAt() 返回字元的unicode編碼 var str="hello world"; console.log(str.charCodeAt(4)); // indexOf() 返回出現的位置 // 沒找到則返回-1 va ...
  • 12306 結合日曆時間,推出了“按小時為基準的定時、批量、放票的策略,先到者得”的系統邏輯。 這就導致,所有購票人,都要在搶在某個時間點,比如 10:00:00 , 十幾秒內,或者最好在零點幾秒內,完成購票操作。 ... “電腦隨機抽簽模式”的好處在於: 購票人可以不用急急忙忙地購票,... ...
  • 昨天我們聊了 架構是什麼 ?今天我們來看看架構的前世今生。客戶端-伺服器(C/S)、瀏覽器-伺服器(B/S)、面向服務架構(SOA)、微服務(Microservice)、無伺服器(Serverless)、函數計算(FaaS)等,我們都聽說過不少架構相關的名詞,但它們之間究竟是什麼關係,哪種架構更好?... ...
  • 架構師,老兵哥剛參加工作那些年業界還沒有這個職位,那時候跟技術相關的崗位就是開發工程師、測試工程師和系統工程師,後來隨著軟體規模不斷增長而產生的,尤其是在互聯網浪潮下用戶數和訪問量都是海量化的。在各種機緣巧合下,老兵哥結合個人喜好選擇了走架構師路徑,從懵懵懂懂邊做邊學,到現在總算摸出了些門道,回顧這... ...
  • 1.泛型類 普通的類 這樣的代碼是完全可以執行了,那為什麼還需要泛型類? 1.安全性 上面的代碼編譯是完全可以通過的,但是執行的時候就會出現ClassCastException異常 2.可讀性好,省去了反覆的強制類型轉換。 對於泛型類,java編譯器會將泛型代碼轉換成普通的非泛型代碼, 所以對於虛擬 ...
  • 一、Spring Data JPA 1、簡介 (1)官網地址: https://spring.io/projects/spring-data-jpa參考文檔: https://docs.spring.io/spring-data/jpa/docs/2.2.3.RELEASE/reference/ht ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...