TP5.0框架websocket与前端uniapp做长链接通讯

adminadmin PHP 2023年10月11日
373 0
  1. 首先要去阿里云/腾讯云申请免费的SSL证书
  2. 配置网站参考基于 https://www.kancloud.cn/bishengzhu/twword/2056626
  3. 在根目录新增启动文件server.php<?php
    define('APP_PATH', __DIR__ . '/application/');
    define('BIND_MODULE','push/Worker');
    // 加载框架引导文件
    require __DIR__ . '/thinkphp/start.php';` 
  4. 新建application/socketio/controller/Server.php<?php
    namespace app\socketio\controller;

    use Workerman\Worker;
    use Workerman\Connection\TcpConnection;
    use app\admin\model\ChatMessage;
    use PHPSocketIO\SocketIO;
    use Workerman\Redis\Client;

    //聊天专用workerman
    class Server
    {
    public function index()
    {

    //证书最好是申请的证书
    $context = array(
    // 更多ssl选项请参考手册 http://php.net/manual/zh/context.ssl.php
    'ssl' => array(
    // 请使用绝对路径
    'local_cert' => 'xxxx.pem', // 也可以是crt文件
    'local_pk' => 'xxxx.key',// 也可以是crt文件
    'verify_peer' => false,
    // 'allow_self_signed' => true, //如果是自签名证书需要开启此选项
    )
    );
    // 这里设置的是websocket协议（端口任意，但是需要保证没被其它程序占用）
    $worker = new Worker('websocket://0.0.0.0:3120', $context);
    // 设置transport开启ssl，websocket+ssl即wss
    $worker->transport = 'ssl';
    // 启动1个进程对外提供服务
    $worker->count = 1;
    // 当收到客户端发来的数据后返回hello $data给客户端
    // $worker->onMessage = function(TcpConnection $connection, $data){
    // global $worker;
    // //推送给发送人新消息
    // $connection = $worker->data;
    // $connection->send('sss---'.$data);

    // };
    // 新增加一个属性，用来保存uid到connection的映射
    $worker->uidConnections = array();
    // 当有客户端发来消息时执行的回调函数
    $worker->onMessage = function($connection, $data)
    {
    global $worker;
    if(!isset($connection->uid)){
    $connection->uid = $data;
    $worker->uidConnections[$connection->uid] = $connection;
    }else{
    foreach($worker->uidConnections as $k=>$connection){
    if($k == $data){
    $connection->send('你好呀');
    }
    }
    }

    };
    // 当有客户端连接断开时
    $worker->onClose = function($connection)
    {
    global $worker;
    if(isset($connection->uid))
    {
    // 连接断开时删除映射
    unset($worker->uidConnections[$connection->uid]);
    }
    };

    //运行worker
    Worker::runAll();
    }

    }

     

  5. 运行停止指令 需在根目录下执行
    开启 : php server.php start
    关闭: php server.php stop
    重启: phh server.php restart
    查看状态: php server.php status
  6. 前端代码
    // 进入这个页面的时候创建websocket连接【整个页面随时使用】
    connectSocketInit() {
    // 创建一个this.socketTask对象【发送、接收、关闭socket都由这个对象操作】
    this.socketTask = uni.connectSocket({
    // 【非常重要】必须确保你的服务器是成功的,如果是手机测试千万别使用ws://127.0.0.1:9099【特别容易犯的错误】
    url: 'wss://xxxxx:3120/wss',
    success(data) {
    console.log("websocket连接成功");
    },
    });// 消息的发送和接收必须在正常连接打开中,才能发送或接收【否则会失败】
    this.socketTask.onOpen((res) => {
    var that = this;
    console.log("WebSocket连接正常打开中...！");
    this.is_open_socket = true;
    // 注：只有连接正常打开中 ，才能正常成功发送消息
    this.socketTask.send({
    data: that.userInfo.id+that.sort,
    async success() {
    console.log("消息发送成功");
    },
    });
    // 注：只有连接正常打开中 ，才能正常收到消息
    this.socketTask.onMessage((res) => {
    that.getmessage();
    console.log("收到服务器内容：" + res.data);
    });
    })
    // 这里仅是事件监听【如果socket关闭了会执行】
    this.socketTask.onClose(() => {
    console.log("已经被关闭了");
    var that = this;
    if (that.is_open_socket == true) {
    setTimeout(function() {
    that.reconnect()
    }, 5000);
    }

    })
    },
    // 关闭websocket【离开这个页面的时候执行关闭】
    closeSocket() {
    var that = this;
    that.is_open_socket = false;
    this.socketTask.close({
    success(res) {
    console.log("关闭成功", res)
    },
    fail(err) {
    that.is_open_socket = true;
    console.log("关闭失败", err)
    }
    })
    },
    //进入重新连接
    reconnect() {
    console.log('进入断线重连');
    // this.socketTask.close();
    this.socketTask = null;
    this.connectSocketInit()
    },
    // //发送消息
    sendSocketMessage(msg) {
    return new Promise((reslove, reject) => {
    this.socketTask.send({
    data: msg,
    success(res) {
    console.log('发送成功')
    reslove(res)
    },
    fail(res) {
    console.log('发送失败')
    console.log(res)
    reject(res)
    }
    });
    })
    },

  7. 页面关闭时必须关闭链接
    // 关闭websocket【必须在实例销毁之前关闭,否则会是underfined错误】
    this.closeSocket();

    来源:https://blog.csdn.net/weixin_43392900/article/details/132229377

本文由 我爱PHP169 作者：admin 发表，其版权均为 我爱PHP169 所有，文章内容系作者个人观点，不代表 我爱PHP169 对观点赞同或支持。如需转载，请注明文章来源。

相关文章

发表回复