IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> PHP知识库 -> tp5.1+think-swoole搭建聊天 -> 正文阅读

[PHP知识库]tp5.1+think-swoole搭建聊天

1.我使用的是linux系统,首先需要安装think-swoole

composer require topthink/think-swoole

2.在项目根目录config目录下修改swoole_server.php,没有自己新建。

<?php
// +----------------------------------------------------------------------
// | Swoole设置 php think swoole:server 命令行下有效
// +----------------------------------------------------------------------
return [
	'swoole_class'	=>	'app\index\controller\Swoole',
];

3.因为上面指向新的swoole.php ,所以我们去index模块新建Swoole.php.

?4.自己重写Swoole.php

<?php
namespace app\index\controller;
common下的是我自己的模型,因为下面用到了用不到的可以去掉
use app\common\model\ImFriend;
use app\common\model\ImMessage;
use app\common\model\User;
///模型结束
use think\swoole\Server;
use think\Db;
class Swoole extends Server
{
	protected $host = '';  你的域名
	protected $port = 9500;
    protected $type = 'socket';
    protected $serverType = 'ssl';
    protected $mode = SWOOLE_PROCESS;
    protected $sockType = SWOOLE_SOCK_TCP | SWOOLE_SSL;
	protected $option = [ 
		'worker_num'=> 4,
		'daemonize'	=> false,
		'backlog'	=> 128,
		'ssl_key_file' => '', ///key证书
        'ssl_cert_file' => '',cert证书
		'heartbeat_check_interval' => 10,
        'heartbeat_idle_time' => 300,
        'buffer_output_size' => 4*1024*1024, // 发送输出缓存区内存
        'socket_buffer_size' => 4*1024*1024, // 配置客户端连接的缓存区长度
	];
    //心跳检测:每60秒遍历所有连接,强制关闭10分钟内没有向服务器发送任何数据的连接
   
   
    // 事件回调定义
    public function onOpen($server, $request) {
        //将user_id 和fd 传到数据库 (后面将使用redis)
        $date=date('Y-m-d H:i',time());
         目前使用的是自增id,后面改成token
        $user_id=$request->get['user_id'];
        /*插入之前将所有的该userid状态改为0*/
        Db::table('im_user_status')->where('user_id',$user_id)->update(['status'=>0,'update_time'=>$date]);
        Db::table('im_user_status')->insert(['user_id'=>$user_id,'fd'=>$request->fd,'create_time'=>$date]);
        $res['type']='success';//发送信息
        $res['msg']='连接成功';//发送信息
        $server->push($request->fd, json_encode($res)); 
           echo "client {$request->fd} 打开\n";
    }

    public function onMessage($server, $frame) {
        $data=json_decode($frame->data);
        //内容
		switch ($data->type) {
			    case 'check':
			     $res['type']='success';//发送信息
				 $res['msg']='检测成功';//检测是否连接
				 $server->push($frame->fd, json_encode($res)); 
					break;
				case 'user':
				 $this->send($server,$frame,$data); //发送点对点消息
					break;
				case 'system':
				 $this->systemsend($server,$frame,$data); //发送系统消息
					break;
				default:
				 $res['msg']='默认';
			};
    }

    public function onRequest($request, $response) {
        var_dump('onrequest'.$request);
        $response->end("<h1>Hello Swoole. #" . rand(1000, 9999) . "</h1>");
    }

    public function onClose($ser, $fd) {
        Db::table('im_user_status')->where('fd',$fd)->where('status',1)->update(['status'=>0]);
        echo "client {$fd} closed为啥呢\n";
    }
	public function onReceive($server, $fd, $from_id, $data)
	{
	    echo "name {$data}";
		$server->send($fd, 'Swoole: '.$data);
	}
	//用户的信息发送
	public function send($server,$frame,$data){
	    $type=$data->msg->type;  //信息类型
	    $length=0; //录音长度
	    	switch ($type) {
			    case 'text':
			        $name='text';
			        $content=$data->msg->content->text;
					break;
				case 'img':
				    $name='url';
			        $content=$data->msg->content->url;
					break;
				case 'voice':
				    $name='url';
			        $content=$data->msg->content->url;
			        $length=$data->msg->content->length;
			        break;
				default:
			    $content=$data->msg->content->text;
			};
        //来源的id
        $fromid=$data->fromid;
        //要发送的id
        $toid=$data->toid;
        $username=$data->msg->userinfo->username;
        $avatar=$data->msg->userinfo->face;
        $date=date('Y-m-d H:i:s',time());
        //var_dump($frame);
        // var_dump($data);
        // echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
        $a=ImFriend::where('user_id',$data->fromid)->where('friend_id',$data->toid)->find();
        //表示不是好友自动加
        if(empty($a)){
             $a=ImFriend::create(['user_id',$data->fromid,'friend_id',$data->toid]);
        }
        //将信息插入表中
        $id=ImMessage::create(['message_content'=>$content,'voice_length'=>$length,'type'=>$type,'from_user_id'=>$fromid,'from_user_name'=>$username,'from_user_avatar'=>$avatar,'to_user_id'=>$toid]);
        //查找朋友的fd
        $f=Db::table('im_user_status')->where('user_id',$toid)->where('status',1)->field('fd')->find();
         echo $f['fd'];
        if(!is_null($f)){
            /*表示查到了意味着在线*/
            $res['message']['sendmethod']='user';
            $res['message']['type']='user';
            $res['message']['fromid']=$fromid;
            $res['message']['msg']['type']=$type;
            $res['message']['msg']['content'][$name]=$content;
            $res['message']['msg']['content']['length']=$length;
            $res['message']['msg']['id']=$id->id;
            $res['message']['msg']['time']=$date;
            $res['message']['msg']['userinfo']['uid']=$fromid;
            $res['message']['msg']['userinfo']['username']=$username;
            $res['message']['msg']['userinfo']['face']=$avatar;
            $res['type']='getmessage';//发送信息
            $server->push($f['fd'], json_encode($res));
            echo "发送信息成功";
        }else {
            /*如果不在线则需要进行下一步操作如缓存消息*/
        }
        return ;
	}
	public function systemsend($server,$frame,$data)
	{
	    $type=$data->msg->type;  //信息类型
	    $length=0; //录音长度
	    	switch ($type) {
			    case 'text':
			        $name='text';
			        $content=$data->msg->content->text;
					break;
				case 'img':
				    $name='url';
			        $content=$data->msg->content->url;
					break;
				case 'voice':
				    $name='url';
			        $content=$data->msg->content->url;
			        $length=$data->msg->content->length;
			        break;
				default:
			    $content=$data->msg->content->text;
			};
        //来源的id
        $fromid=$data->fromid;
        //要发送的id
        $toid=$data->toid;
        $username=$data->msg->userinfo->username;
        $avatar=$data->msg->userinfo->face;
        $date=date('Y-m-d H:i:s',time());
        //将信息插入表中
        $id=ImMessage::create(['message_content'=>$content,'voice_length'=>$length,'type'=>$type,'from_user_id'=>$fromid,'to_user_id'=>$toid]);
            //根据id或者关键字查找答案
        $ids=$data->msg->content->content_id;
        $systemcontent=Db::table('im_system_content')->where('id',$ids)->find();
        $res['message']['sendmethod']='system';
        $res['message']['type']='system';
        $res['message']['fromid']=$fromid;
        $res['message']['toid']=$toid;
        $res['message']['msg']['type']=$type;
        $res['message']['msg']['content'][$name]=$systemcontent['content'];
        $res['message']['msg']['id']=$id->id;
        $res['message']['msg']['time']=$date;
        $res['message']['msg']['userinfo']['uid']=$toid;
        $res['type']='getmessage';//发送信息
        $server->push($frame->fd, json_encode($res)); 
        
        return ;
	    
	}
}
  

5.我们还需要一个测试端,我直接写在了php里,

<!DOCTYPE html>
<html lang="en">

<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <meta http-equiv="X-UA-Compatible" content="ie=edge">
    <title>websocket client</title>
</head>
<button type="button" id="send">发送</button>
<body>
<h1>swoole-ws测试</h1>
<script>
    var wsUrl = 'wss://aaa.xw.com:9500';
    var websocket = new WebSocket(wsUrl);

    websocket.onopen = function (evt) {
        console.log("ws client 连接成功!");
    };

    document.getElementById('send').onclick = function () {
        websocket.send('{"url":"index/index/websocket"}');
        console.log('ws client 发送数据');
    };

    websocket.onmessage = function (evt) {
        console.log("server return data: " + evt.data);
    };

    websocket.onclose = function (evt) {
        console.log("connect close");
    };

    websocket.onerror = function (evt, e) {
        console.log("error: " +JSON.stringify(evt));
    }
</script>
</body>

</html>

6.启动php服务 使用命令?

php think swoole:server

?

7.测试是否链接成功

?

  PHP知识库 最新文章
Laravel 下实现 Google 2fa 验证
UUCTF WP
DASCTF10月 web
XAMPP任意命令执行提升权限漏洞(CVE-2020-
[GYCTF2020]Easyphp
iwebsec靶场 代码执行关卡通关笔记
多个线程同步执行,多个线程依次执行,多个
php 没事记录下常用方法 (TP5.1)
php之jwt
2021-09-18
上一篇文章      下一篇文章      查看所有文章
加:2021-09-23 11:13:30  更:2021-09-23 11:16:06 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年12日历 -2024/12/29 4:43:26-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码
数据统计