ThinkPHP 5.1下使用PHPSocket.IO實現websocket通訊

本文轉載自查看原文 2020-01-13 15:10 1659

PHPSocket.IO的官方介紹：

PHPSocket.IO是PHP版本的Socket.IO服務端實現，基於workerman開發，用於替換node.js版本Socket.IO服務端。PHPSocket.IO底層采用websocket協議通訊，如果客戶端不支持websocket協議，則會自動采用http長輪詢的方式通訊。PHPSocket.IO實現的Polling通信機制包括Adobe Flash Socket、AJAX長輪詢、JSONP輪詢等。具體采用哪種機制通訊對於開發者完全透明，開發者使用的是統一的接口。

項目`github`地址https://github.com/hsu1943/thinksocketio，項目已經做了很多更新，請按照項目`readme`使用。

下面我們使用ThinkPHP5.1框架來整合PHPSocket.IO實現客戶端和服務端的通訊。

使用的本地開發環境是PHP5.6.30 + Apache2.4.25

創建新項目

// 使用ThinkPHP5.1新建項目thinksocket；
$ composer create-project topthink/think thinksocket 5.1.*; // 進入項目，下載workerman/phpsocket.i包； $ cd thinksocket $ composer require workerman/phpsocket.io

這樣你的安裝工作就做好了。接下來配置需要的模

配置模塊

結合前陣子的文章：ThinkPHP 5.1自動生成模塊及目錄、文件
我們編輯好build.php文件：

return [ // 生成應用公共文件 '__file__' => ['common.php'], // 定義socketio模塊的自動生成 'socketio' => [ '__file__' => ['common.php'], '__dir__' => ['controller', 'model', 'view'], 'controller' => ['Index', 'Server'], 'model' => [], 'view' => ['index/index'], ], // 其他更多的模塊定義 ];

然后運行

$ php think build
Successed

這樣就有了socketio模塊下面controller有Index.php和Server.php兩個控制器和view下一個index/index一個視圖。

創建服務端

編輯控制器Server.php為（具體參考注釋）:

<?php namespace app\socketio\controller; use Workerman\Worker; use PHPSocketIO\SocketIO; use think\Db; class Server{ public function index(){ // 在2021端口創建服務 $io = new SocketIO(2021); $io->on('connection', function($socket)use($io){ $socket->on('chat message', function($msg)use($io){ $io->emit('chat message', $msg); }); // 監聽到新的客戶端連接即在服務端輸出'new connection' echo 'new connection'."\n"; // 並向服務端發送'連接成功' $socket->emit('success', '連接成功'); // 服務端發送消息過來 $socket->on('sendMsg', function($msg)use($io){ // 在服務端輸出消息 echo $msg."\n"; // 在收到的消息前面拼接'收到'后向客戶端發送回去 $io->emit('sendMsg', '收到"'.$msg.'"'); // 將接受到的消息存儲到數據庫 $data['msg'] = $msg; Db::table('msg')->insert($data); }); }); // 啟動服務 Worker::runAll(); } // 測試數據庫鏈接 public function ceshi(){ $msg = Db::table('msg')->select(); var_dump($msg); } }

為了測試，在數據庫新建了一張表msg用來存儲客戶端發送過來的消息。

CREATE TABLE `msg` ( `id` int(10) unsigned NOT NULL AUTO_INCREMENT, `msg` varchar(250) DEFAULT NULL, `create_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4;

這樣一個可以返回連接成功消息、接收消息、回復消息、存儲消息的簡單服務端就做好了。

創建客戶端

我們在Index.php控制器中這樣寫:

<?php namespace app\socketio\controller; use think\Controller; class Index extends Controller { public function index() { return view(); } }

在對應的模版文件view/index/index.html中代碼：

<!DOCTYPE html> <html lang="en"> <head> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8" /> <title>測試WebSocket</title> </head> <body> <input type="text" name="" id="msg"> <button id='send'>發送消息</button> </body> <script src='https://cdn.bootcss.com/socket.io/2.0.3/socket.io.js'></script> <script src="https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js"></script> <script> // 如果服務端不在本機，請把127.0.0.1改成服務端ip var socket = io('http://127.0.0.1:2021'); // 當連接服務端成功時觸發connect默認事件 socket.on('connect', function(){ console.log('connect success'); }); socket.on('success', function(msg){ // 連接后彈出服務端返回的消息'連接成功' alert(msg); }); socket.on('sendMsg', function(msg){ // 將服務端返回的消息輸出到控制台 console.log(msg); }); // 向服務端發送消息 $('#send').on('click', function(){ var text = $('#msg').val(); socket.emit('sendMsg', text); // alert(text); }) </script> </html>

到這里，一個具備連接服務端，發送消息，接受並輸出消息到控制台的簡單websocket客戶端就建好了。

為服務端綁定入口文件

在項目的public文件夾下新建一個入口文件server.php並將其綁定到socketio模塊的Server控制器index方法；
入口文件server.php代碼:

<?php // [ 應用入口文件 ] namespace think; // 加載基礎文件 require __DIR__ . '/../thinkphp/base.php'; // 執行應用並響應（綁定） Container::get('app')->bind('socketio/Server')->run()->send();

測試通訊

運行服務端
直接運行項目public目錄下的server.php；

D:\xampp\htdocs\thinksocket\public>php server.php ----------------------- WORKERMAN ----------------------------- Workerman version:3.5.11 PHP version:5.6.30 ------------------------ WORKERS ------------------------------- worker listen processes status PHPSocketIO socketIO://0.0.0.0:2021 1 [ok]

ThinkPHP 5.1下使用PHPSocket.IO實現websocket通訊
這個輸出表示PHPSocketIO已經成功在2021端口運行監聽中。
我們打開瀏覽器打開http://localhost/thinksocket/public/index.php/socketio/頁面；
可以看到頁面會彈出‘鏈接成功’，同時可以看到服務端cmd終端上打印出new connection，同事瀏覽器控制台會輸出connect success，代表已經成功與服務端連接上。
測試發送消息
在頁面輸入框內輸入任意信息，服務端cmd終端將會打印信息，代表服務端收到信息，然后服務端控制台將會輸出‘收到’+發送的信息。
至此，我們的測試完成。

溫馨提示：對程序修改后需要重新啟動服務端才能生效

以上只是簡單的利用ThinkPHP5.1的框架測試PHPSocket.IO通訊。

源代碼地址：https://github.com/hsu1943/thinksocketio
供大家參考。

update （代碼以Github為准）

2019/01/22：Github項目代碼已經更新，加入了用戶唯一表示記錄以及向指定用戶推送消息。詳情看：ThinkPHP 5.1+PHPSocket.IO實現websocket搭建聊天室+私聊
2019-06-19 增加在線人數統計，在線用戶列表，修改昵稱，添加系統主動推送接口（廣播或私信）；

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 websocket 后台新訂單通知 —— Laravel 5.8 workman PHPSocket.IO教程淺談一下ThinkPHP5.1實現事務嵌套的特性 thinkphp5.1在php7.3下使用phpmailer報錯 Uniapp使用GoEasy實現websocket即時通訊 thinkphp5.1常量定義使用如何使用Git安裝ThinkPHP5.1 Composer + thinkphp5.1安裝與使用用PHP和Websocket實現實時通訊 Websocket實現即時通訊 SpringBoot集成Netty實現websocket通訊