• hyperf框架WebSocket 服务

    1：安装

    composer require hyperf/websocket-server

    2：配置 Server   修改 config/autoload/server.php，增加以下配置。

    1.  
    2. return [
    3.     'servers' => [
    4.         [
    5.             'name' => 'ws',
    6.             'type' => Server::SERVER_WEBSOCKET,
    7.             'host' => '0.0.0.0',
    8.             'port' => 9502,
    9.             'sock_type' => SWOOLE_SOCK_TCP,
    10.             'callbacks' => [
    11.                 Event::ON_HAND_SHAKE => [Hyperf\WebSocketServer\Server::class, 'onHandShake'],
    12.                 Event::ON_MESSAGE => [Hyperf\WebSocketServer\Server::class, 'onMessage'],
    13.                 Event::ON_CLOSE => [Hyperf\WebSocketServer\Server::class, 'onClose'],
    14.             ],
    15.         ],
    16.     ],
    17. ];

    3：配置路由 在 config/routes.php 文件内增加对应 ws 的 Server 的路由配置，这里的 ws 值取决于您在 config/autoload/server.php 内配置的 WebSocket Server 的 name 值。

    1. Router::addServer('ws', function () {
    2.     Router::get('/', 'App\Controller\WebSocketController');
    3. });

    4：创建控制器

    2. declare(strict_types=1);
    3.  
    4. namespace App\Controller;
    5.  
    6. use Hyperf\Contract\OnCloseInterface;
    7. use Hyperf\Contract\OnMessageInterface;
    8. use Hyperf\Contract\OnOpenInterface;
    9. use Hyperf\WebSocketServer\Constant\Opcode;
    10. use Swoole\Server;
    11. use Swoole\WebSocket\Server as WebSocketServer;
    12.  
    13. class WebSocketController implements OnMessageInterface, OnOpenInterface, OnCloseInterface
    14. {
    15.     public function onMessage($server, $frame): void
    16.     {
    17.         // $frame->data 前端发过来的数据
    18.         $data = [
    19.             "小敏!",
    20.             "小明",
    21.             "小米",
    22.             "华维",
    23.             "苹果"
    24.         ];
    25.         $rand = rand(0,4);
    26.         $server->push($frame->fd, '后端: ' . $data[$rand]);
    27.     }
    28.  
    29.     public function onClose($server, int $fd, int $reactorId): void
    30.     {
    31.         echo $fd . '断开连接,处理线程是 ' . $reactorId . PHP_EOL;
    32.     }
    33.  
    34.     public function onOpen($server, $request): void
    35.     {
    36.         $server->push($request->fd, $request->fd . ' 号客户端已连接!' . PHP_EOL);
    37.     }
    38. }

    5：前端页面测试

    1. html>
    2. <html lang="en">
    3. <head>
    4.     <meta charset="UTF-8">
    5.     <meta name="viewport"
    6.           content="width=device-width, user-scalable=no, initial-scale=1.0, maximum-scale=1.0, minimum-scale=1.0">
    7.     <meta http-equiv="X-UA-Compatible" content="ie=edge">
    8.     <title>websockettitle>
    9. head>
    10. <body>
    11. <div>
    12.     <textarea name="content" id="content" cols="30" rows="10">textarea>
    13.     <button onclick="send();">发送button>
    14. div>
    15. <ul id="messageList">ul>
    16.  
    17. <script>
    18.     let ws = new WebSocket('ws://127.0.0.1:9101')
    19.     ws.onopen = event => {
    20.         console.log('连接服务器成功');
    21.     }
    22.  
    23.     ws.onmessage = event => {
    24.         let data = event.data;
    25.         let ul = document.getElementById('messageList');
    26.         let li = document.createElement('li');
    27.         li.innerHTML = data;
    28.         ul.appendChild(li);
    29.     }
    30.  
    31.     ws.onclose = event => {
    32.         console.log('客户端连接关闭');
    33.     }
    34.  
    35.     function send() {
    36.         let obj = document.getElementById('content');
    37.         let content = obj.value;
    38.  
    39.         let ul = document.getElementById('messageList');
    40.         let li = document.createElement('li');
    41.         li.innerHTML = "我："+content;
    42.         ul.appendChild(li);
    43.  
    44.         ws.send(content);
    45.         obj.value = '';
    46.     }
    47. script>
    48. body>
    49. html>

  • 相关阅读:
    学习java第二天
    腾讯云服务器如何手动搭建java web环境？
    爬取小说章节，并制作成词云进行宣传
    有没有遇到el-date-picker的清空之坑
    leetcode(力扣) 718. 最长重复子数组 & 1143. 最长公共子序列 (动态规划)
    匿名信小程序版源码一封来信你的Ta的一封来信表白祝福道歉短信下载源码
    C++ DAY08 异常
    verilog 实现常用加法器
    【Hyper-V】Windows的Hyper-V管理器创建的虚拟机上怎么复制粘贴文件
    HashMap在JDK1.7和JDK1.8中有哪些不同？HashMap的底层实现
  • 原文地址：https://blog.csdn.net/qq_33212312/article/details/133746816