码迷,mamicode.com
首页 > 其他好文 > 详细

swoole聊天室

时间:2019-09-16 12:09:48      阅读:86      评论:0      收藏:0      [点我收藏+]

标签:bsp   信息   ring   root   ESS   聊天   ati   idt   函数   

服务端:

<?php
class Chat
{
    const HOST = ‘0.0.0.0‘;//ip地址 0.0.0.0代表接受所有ip的访问
    const PART = 8080;//端口号

    private $server = null;//单例存放websocket_server对象

    public function __construct()
    {
        //实例化swoole_websocket_server并存储在我们Chat类中的属性上,达到单例的设计
        $this->server = new swoole_websocket_server(self::HOST, self::PART);
        //监听连接事件
        $this->server->on(‘open‘, [$this, ‘onOpen‘]);
        //监听接收消息事件
        $this->server->on(‘message‘, [$this, ‘onMessage‘]);
        //监听关闭事件
        $this->server->on(‘close‘, [$this, ‘onClose‘]);
        //设置允许访问静态文件
        $this->server->set([
            ‘document_root‘ => ‘/www/chat1‘,//这里传入静态文件的目录
            ‘enable_static_handler‘ => true//允许访问静态文件
        ]);


        //开启服务
        $this->server->start();
    }

    /**
     * 连接成功回调函数
     * @param $server
     * @param $request
     */
    public function onOpen($server, $request)
    {
        echo $request->fd . ‘连接了‘ . PHP_EOL;//打印到我们终端
    }

    /**
     * 接收到信息的回调函数
     * @param $server
     * @param $frame
     */
    public function onMessage($server, $frame)
    {
        echo $frame->fd . ‘来了,说:‘ . $frame->data . PHP_EOL;//打印到我们终端
        foreach ($server->connections as $fd) {//遍历TCP连接迭代器,拿到每个在线的客户端id
            //将客户端发来的消息,推送给所有用户,也可以叫广播给所有在线客户端
            $server->push($fd, json_encode([‘no‘ => $frame->fd, ‘msg‘ => $frame->data]));
        }
    }

    /**
     * 断开连接回调函数
     * @param $server
     * @param $fd
     */
    public function onClose($server, $fd)
    {
        echo $fd . ‘走了‘ . PHP_EOL;//打印到我们终端
    }

}

$obj = new Chat();

  客户端

<!doctype html>

<html>

<head>

    <meta charset="utf-8">

    <title>聊天室</title>

    <script src="http://libs.baidu.com/jquery/1.9.1/jquery.min.js"></script>

</head>

<body>

<textarea class="log" style="width: 100%; height: 500px;">

=======聊天室======

</textarea>

<input type="button" value="连接" onClick="link()">

<input type="button" value="断开" onClick="dis()">

<input type="text" id="text">

<input type="button" value="发送" onClick="send()">

<script>

    function link(){

        var url=‘ws://192.168.33.60:8080‘;

        socket=new WebSocket(url);

        socket.onopen=function(){log1(‘连接成功‘)}

        socket.onmessage=function(msg){log(msg.data);console.log(msg);}

        socket.onclose=function(){log1(‘断开连接‘)}

    }

    function dis(){

        socket.close();

        socket=null;

    }

    function log1(var1) {
        $(‘.log‘).append(var1+‘\r\n‘);
    }
    function log(var1){
        var  v=$.parseJSON(var1)
        $(‘.log‘).append(‘用户‘+v[‘no‘]+‘说:‘+v[‘msg‘]+‘\r\n‘);
    }

    function send(){
        var text=$(‘#text‘).val();

        socket.send(text);
    }

    function send2(){

        var json = JSON.stringify({‘type‘:‘php‘,‘msg‘:$(‘#text2‘).attr(‘value‘)})

        socket.send(json);

    }

</script>

</body>

</html>

  

服务端 启动

php Chat.php

 

访问客户端的html 浏览器打开

技术图片

 

 

 

参考 https://www.jianshu.com/p/ac77f05bee56

swoole聊天室

标签:bsp   信息   ring   root   ESS   聊天   ati   idt   函数   

原文地址:https://www.cnblogs.com/php-linux/p/11526305.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!