Skip to content

Commit

Permalink
Websocket development 12-7-2019
Browse files Browse the repository at this point in the history
  • Loading branch information
@ttttonyhe
ttttonyhe committed Jul 12, 2019
1 parent e173ca0 commit 969bbb1
Show file tree
Hide file tree
Showing 6 changed files with 279 additions and 20 deletions.
3 changes: 2 additions & 1 deletion .gitignore
View file
@@ -1,4 +1,5 @@
/vendor
composer.lock
/node_modules
.sass-cache
.sass-cache
/node
5 changes: 4 additions & 1 deletion composer.json
View file
Expand Up @@ -2,6 +2,9 @@
"require": {
"greg0/lazer-database": "1.1.6",
"qiniu/php-sdk": "^7.2",
"cboden/ratchet": "^0.4.1"
"cboden/ratchet": "^0.4.1",
"psecio/jwt": "1.*",
"workerman/workerman": "^3.5",
"workerman/channel": "^1.0"
}
}
5 changes: 4 additions & 1 deletion package.json
View file
Expand Up @@ -15,5 +15,8 @@
"bugs": {
"url": "https://github.com/HelipengTony/pokers/issues"
},
"homepage": "https://github.com/HelipengTony/pokers#readme"
"homepage": "https://github.com/HelipengTony/pokers#readme",
"dependencies": {
"socket.io": "^2.2.0"
}
}
34 changes: 17 additions & 17 deletions statics/js/antd.js
View file

Large diffs are not rendered by default.

44 changes: 44 additions & 0 deletions ws/1.html
View file
@@ -0,0 +1,44 @@
<!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>Document</title>
</head>

<body>
<script>
ws = new WebSocket('ws://127.0.0.1:2000');
ws.onmessage = function (data) {
var re = eval('(' + data.data + ')');
if (re.status){
switch (re.op) {
case 'sent':
console.log(re.speaker_name + ' with ID('+ re.speaker +') says: ' + re.content);
break;
case 'send':
console.log('Sending...');
break;
case 'connect':
console.log('Connected');
break;
case 'join':
console.log('Joined thread: '+re.thread)
break;
default:
console.log('101');
break;
}
}else{
console.log(re.code);
}
};
ws.onopen = function () {
ws.send('{"action":"join", "thread_id":3, "class_id":3, "speaker":2,"speaker_name":"TonyHe"}');
};
</script>
</body>

</html>
208 changes: 208 additions & 0 deletions ws/jwt.php
View file
@@ -0,0 +1,208 @@
<?php

require '../vendor/autoload.php';
require_once '../vendor/workerman/workerman/Autoloader.php';
require_once '../vendor/workerman/channel/src/Server.php';
require_once '../vendor/workerman/channel/src/Client.php';
define('LAZER_DATA_PATH', dirname(dirname(__FILE__)) . '/data/');
use Lazer\Classes\Database as Lazer;
use Workerman\Worker;
//数据库创建与判断
try {
\Lazer\Classes\Helpers\Validate::table('messages')->exists();
} catch (\Lazer\Classes\LazerException $e) { //不存在则创建
Lazer::create('messages', array(
'id' => 'integer', //内容条段 id
'speaker' => 'integer', //发送者
'speaker_name' => 'string', //发送者名字,减少前端数据库请求
'is_super' => 'integer', //发送者级别,减少前端数据库请求
'belong_class' => 'integer', //主题对应班级
'content' => 'string', //内容
'thread' => 'integer', //班级下的主题 id
'emoji_1' => 'integer', //添加 emoji1
'emoji_2' => 'integer', //添加 emoji2
'emoji_3' => 'integer', //添加 emoji3
'img_url' => 'string', //类型为文本，但有图片附件
'date' => 'integer', //发送时间
'type' => 'string', //类型：文件 or 文本(+图片)
'file_url' => 'string', //类型为文件时文件的 url
'file_name' => 'string', //类型文文件时的文件名,用于判断展示图标
'log' => 'integer'
));
}
//数据库创建与判断
try {
\Lazer\Classes\Helpers\Validate::table('logs')->exists();
} catch (\Lazer\Classes\LazerException $e) { //不存在则创建
Lazer::create('logs', array(
'id' => 'integer', //内容条段 id
'speaker' => 'integer', //发送者
'speaker_name' => 'string', //发送者名字,减少前端数据库请求
'belong_class' => 'integer', //主题对应班级
'content' => 'string', //内容
'thread' => 'integer', //班级下的主题 id
'date' => 'integer', //发送时间
));
}
session_start();
$channel_server = new Channel\Server('127.0.0.1', 2206);
$worker = new Worker('websocket://127.0.0.1:2000');
$worker->count = 2;
// 全局群组到连接的映射数组
$group_con_map = array();

$worker->onWorkerStart = function () {
// Channel客户端连接到Channel服务端
Channel\Client::connect('127.0.0.1', 2206);

// 监听全局分组发送消息事件
Channel\Client::on('send', function ($event_data) {
$thread = $event_data['thread_id'];
$class = $event_data['class_id'];
$speaker = $event_data['speaker'];
$speaker_name = $event_data['speaker_name'];
$content = $event_data['message'];
$array = [
'op' => 'sent',
'status' => true,
'code' => 106,
'speaker' => $speaker,
'speaker_name' => $speaker_name,
'content' => $content,
];
global $group_con_map;
if (isset($group_con_map[$thread])) {
foreach ($group_con_map[$thread] as $con) {
$con->send(json_encode($array));
}
}
});
};

//发送消息
$worker->onMessage = function ($con, $data) {
$data = json_decode($data, true);
$cmd = $data['action'];
$user = $data['speaker'];
$user_name = $data['speaker_name'];
$thread = $data['thread_id'];
$class = $data['class_id'];
$type = $data['type'];
$content = $data['message'];

if (!empty($user_name) && !empty($thread) && !empty($class) && !empty($user)) {
$array = Lazer::table('classes')->limit(1)->where('id', '=', (int) $class)->find()->asArray();
if (!!$array) {
$array = Lazer::table('threads')->limit(1)->where('id', '=', (int) $thread)->andWhere('belong_class', '=', (int) $class)->find()->asArray();
if (!!$array) {
$array = Lazer::table('users')->limit(1)->where('id', '=', (int) $user)->andWhere('name', '=', (string) $user_name)->find()->asArray();
if (!!$array && in_array($class,explode(',',$array[0]['class']))) { //判断用户存在




if ($array[0]['type'] == 2) { //教师发送者
$is_super = 1;
} else { //学生发送者
$is_super = 0;
}

switch ($cmd) {
case "join":
global $group_con_map;
// 将连接加入到对应的群组数组里
$group_con_map[$thread][$con->id] = $con;
$array = [
'op' => 'join',
'thread' => $thread,
'status' => true,
'code' => 100
];
break;
case "send":
Channel\Client::publish('send', array(
'thread_id' => $thread,
'class_id' => $class,
'speaker' => $user,
'speaker_name' => $user_name,
'type' => $type,
'is_super' => $is_super,
'message' => $content
));
$array = [
'op' => 'send',
'status' => true,
'code' => 105
];
break;
default:
$array = [
'op' => 'send',
'status' => false,
'code' => 101,
'msg' => 'Illegal request'
];
break;
}
} else {
$array = [
'op' => 'send',
'status' => false,
'code' => 107,
'msg' => 'User does not exist'
];
}
} else {
$array = [
'op' => 'send',
'status' => false,
'code' => 102,
'msg' => 'Thread does not exist'
];
}
} else {
$array = [
'op' => 'send',
'status' => false,
'code' => 103,
'msg' => 'Class does not exist'
];
}
} else {
$array = [
'op' => 'send',
'status' => false,
'code' => 104,
'msg' => 'Illegal request'
];
}
$con->send(json_encode($array));
};

// 这里很重要，连接关闭时把连接从全局群组数据中删除，避免内存泄漏
$worker->onClose = function ($con) {
global $group_con_map;
if (isset($con->group_id)) {
unset($group_con_map[$con->group_id][$con->id]);
if (empty($group_con_map[$con->group_id])) {
unset($group_con_map[$con->group_id]);
}
}
var_dump($group_con_map);
};

$worker->onConnect = function ($con) {
$array = [
'op' => 'connect',
'status' => true
];
$con->send(json_encode($array));
};

Worker::runAll();

0 comments on commit 969bbb1

Please sign in to comment.