使用環境: thinkphp5.0
#專案需求
前端下單,後台接受,並立即做出提示。例如:美團外賣,客戶端下單成功後,商家端就會立即有接單語音提示。
開發環境
- thinkphp5.0
- phpsocketio
(由於需要啟動socket服務,所以需要在能滿足shell的環境下使用)
socketio 優勢
這裡只是我的觀點,畢竟沒有怎麼深入研究socketio,所以只是淺顯的一點總結:
- 減少伺服器IO負載
- 長連線比
ajax
輪詢可靠度 - 服務穩定,支援動態
初略的看了一下,記憶體佔用很小,而且只有1個進程,根據官方報道來說1個進程也能容納1W人次的高並發,所以,對於我的專案來說,已經綽綽有餘
官方文件
https://github.com/walkor/php...
#開始開發
##安裝phpsocketio 首先cd到thinkphp的專案根目錄。使用以下指令composer require workerman/phpsocket.io( 這裡composer不做解釋,如果有什麼問題,度娘一下,應該能夠解決)
安裝好以後,vendor資料夾下面應該要有一個workerman的資料夾,如果存在,就恭喜你,已經安裝完畢了
socketio.php,開始編輯
#!/usr/bin/env php <?php define('APP_PATH', __DIR__ . '/application/'); define('BIND_MODULE','socketio/Server/index'); // 加载框架引导文件 require __DIR__ . '/thinkphp/start.php';這裡只要寫好就OK。後續的所有東西,可以忽略他的存在
創建服務控制器
#上一步的socketio.php檔案裡面,模組綁定到了
'socketio/Server/index',這裡就需要我們手動建立了。為了能理解,我用目錄展示
├─application 应用目录 │ ├─socketio 新创建目录 │ │ ├─controller │ │ │ ├─Server.php 启动文件Server.php入口檔案只是綁定到了這個控制器,所以這個是整個socketio的核心。
<?php /* * (c) U.E Dream Development Studio * * Author: 李益达 - Ekey.Lee <ekey.lee@gmail.com> * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace app\socketio\controller; require_once VENDOR_PATH . "workerman/phpsocket.io/src/autoload.php"; use PHPSocketIO\SocketIO; use Workerman\Worker; class Server { public function index() { $io = new SocketIO(8080);//socket的端口 $io->on('workerStart', function () use ($io) { $inner_http_worker = new Worker('http://0.0.0.0:5880');//这里IP不用改变,用的内网通讯,端口不能与socket端口想通 $inner_http_worker->onMessage = function ($http_connection, $data) use ($io) { $io->emit('new_msg', '44444');//这里写了固定数据,请根据自己项目需求去做调整,不懂这里的可以看看官方文档,很清楚 $http_connection->send('ok'); }; $inner_http_worker->listen(); }); // 当有客户端连接时 $io->on('connection', function ($socket) use ($io) { // 定义chat message事件回调函数 $socket->on('chat message', function ($msg) use ($io) { // 触发所有客户端定义的chat message from server事件 $io->emit('chat message from server', $msg); }); }); Worker::runAll(); } }
建立API 觸發socketio
同樣你可以在socketio下面新建一個API控制器,這裡僅供測試public function api() { // 推送的url地址,使用自己的服务器地址 $push_api_url = "http://0.0.0.0:5880";//这里同样不需要更改IP。只是端口一定需要和server.php onworker的一样 $post_data = array( "type" => "publish", "content" => "这个是推送的测试数据", ); $ch = curl_init (); curl_setopt ( $ch, CURLOPT_URL, $push_api_url ); curl_setopt ( $ch, CURLOPT_POST, 1 ); curl_setopt ( $ch, CURLOPT_HEADER, 0 ); curl_setopt ( $ch, CURLOPT_RETURNTRANSFER, 1 ); curl_setopt ( $ch, CURLOPT_POSTFIELDS, $post_data ); curl_setopt ($ch, CURLOPT_HTTPHEADER, array("Expect:")); $return = curl_exec ( $ch ); curl_close ( $ch ); var_export($return); }現在有了
server服務端,
API觸發端,接下來就需要顯示出來了,就是我們的前端
-
-
現在要寫的就是,商家端收到的提示。之前寫的
server服務端提供phpsocketio監控與socket服務,
API提供事件觸發,也就是有人下單後的觸發,下單作為事件去觸發伺服器socket,讓他回應到前端
程式碼開始前請注意:這裡的端口和域名比較的繞
<script src='//cdn.bootcss.com/socket.io/1.3.7/socket.io.js'></script> <script> // 连接服务端 var socket = io('http://xxxx.com:8080');//这里请填写你的域名,外网,端口为socket端口 // 后端推送来消息时 socket.on('new_msg', function (msg) {//这里的new_msg请一定要注意,官方文档都写的是content,但是后端发送的自定义是new_msg,后端定义成new_msg,前端却接受content的字段。所以是接受不了的 swal({ title: "包厢点餐提醒", text: "哆啦a梦包厢有新订单" }) //console.log("收到消息:" + msg); }); </script>
以上有兩個我之前出問題的地方
114.114.114.114的IP下面。這個網域就必須是在114.114.114.114
的IP下面。埠則是後端服務裡面new SocketIO的埠了。
socket.on()
部署完畢開始運行 |
---|
php socketio.php start
|
---|
php socketio.php start 啟動 |
---|
php socketio.php stop 停止 |
---|
php socketio.php restart
重啟