composer require workerman/phpsocket.io

#!/usr/bin/env php
?php
define('APP_PATH', __DIR__ . '/application/');
define('BIND_MODULE','socketio/Server/index');
// 加載框架引導(dǎo)文件
require __DIR__ . '/thinkphp/start.php';

├─application      應(yīng)用目錄
│ ├─socketio      新創(chuàng)建目錄
│ │ ├─controller   
│ │ │ ├─Server.php  啟動(dòng)文件

?php
/*
 * (c) U.E Dream Development Studio
 *
 * Author: 李益達(dá) - 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不用改變，用的內(nèi)網(wǎng)通訊，端口不能與socket端口想通
      $inner_http_worker->onMessage = function ($http_connection, $data) use ($io) {
        
        $io->emit('new_msg', '44444');//這里寫(xiě)了固定數(shù)據(jù)，請(qǐng)根據(jù)自己項(xiàng)目需求去做調(diào)整，不懂這里的可以看看官方文檔，很清楚
        $http_connection->send('ok');
      };
      $inner_http_worker->listen();
    });

    // 當(dāng)有客戶(hù)端連接時(shí)
    $io->on('connection', function ($socket) use ($io) {
      // 定義chat message事件回調(diào)函數(shù)
      $socket->on('chat message', function ($msg) use ($io) {
        // 觸發(fā)所有客戶(hù)端定義的chat message from server事件
        $io->emit('chat message from server', $msg);
      });
    });

    Worker::runAll();
  }
}

 public function api()
  {
    // 推送的url地址，使用自己的服務(wù)器地址
    $push_api_url = "http://0.0.0.0:5880";//這里同樣不需要更改IP。只是端口一定需要和server.php onworker的一樣
    $post_data = array(
      "type" => "publish",
      "content" => "這個(gè)是推送的測(cè)試數(shù)據(jù)",
    );
    $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);
  }

 script src='//cdn.bootcss.com/socket.io/1.3.7/socket.io.js'>/script>
 script>
      // 連接服務(wù)端
      var socket = io('http://xxxx.com:8080');//這里請(qǐng)?zhí)顚?xiě)你的域名，外網(wǎng)，端口為socket端口
     // 后端推送來(lái)消息時(shí)
      socket.on('new_msg', function (msg) {//這里的new_msg請(qǐng)一定要注意，官方文檔都寫(xiě)的是content，但是后端發(fā)送的自定義是new_msg，后端定義成new_msg，前端卻接受content的字段。所以是接受不了的
        swal({ title: "包廂點(diǎn)餐提醒", text: "哆啦a夢(mèng)包廂有新訂單" })
        //console.log("收到消息：" + msg);
      });

/script>