feat:gateway
parent
3de0fd93db
commit
f99da99405
@ -0,0 +1,21 @@
|
||||
<?php
|
||||
|
||||
namespace App\Http\Controllers;
|
||||
|
||||
use Illuminate\Http\Request;
|
||||
use GatewayClient\Gateway;
|
||||
use Yo;
|
||||
|
||||
$register = env('GATEWAY_REGISTER');
|
||||
Gateway::$registerAddress = "127.0.0.1:$register";
|
||||
|
||||
class GatewayController extends Controller
|
||||
{
|
||||
public function close(Request $request)
|
||||
{
|
||||
$client_id = $request->post('client');
|
||||
return Yo::echo([
|
||||
'client_id' => $client_id
|
||||
]);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,5 @@
|
||||
/vendor
|
||||
composer.lock
|
||||
/.idea
|
||||
/.vscode
|
||||
|
||||
@ -0,0 +1,139 @@
|
||||
<?php
|
||||
require_once __DIR__ . '/Tool.php';
|
||||
|
||||
class Db
|
||||
{
|
||||
public $db;
|
||||
private static $instance = array();
|
||||
|
||||
public function __construct($data)
|
||||
{
|
||||
$dsn = "mysql:dbname=" . $data['dbname'] . ";host=" . $data['dbhost'];
|
||||
$this->db = new \PDO($dsn, $data['dbuser'], $data['dbpassword']);
|
||||
$this->db->query('set character set utf8mb4;');
|
||||
$this->db->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
|
||||
}
|
||||
|
||||
public static function get($key = ''): Db
|
||||
{
|
||||
$database['dbname'] = Tool::ini($key . 'DB_DATABASE');
|
||||
$database['dbuser'] = Tool::ini($key . 'DB_USERNAME');
|
||||
$database['dbpassword'] = Tool::ini($key . 'DB_PASSWORD');
|
||||
$database['dbhost'] = Tool::ini($key . 'DB_HOST');
|
||||
if (!isset(self::$instance[$database['dbname']]) || !self::$instance[$database['dbname']] instanceof self) {
|
||||
self::$instance[$database['dbname']] = new Db($database);
|
||||
} else {
|
||||
try {
|
||||
//断线重连
|
||||
self::$instance[$database['dbname']]->db->getAttribute(\PDO::ATTR_SERVER_INFO);
|
||||
} catch (\PDOException $e) {
|
||||
if (strpos($e->getMessage(), 'MySQL server has gone away') !== false) {
|
||||
self::$instance[$database['dbname']] = new Db($database);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return self::$instance[$database['dbname']];
|
||||
}
|
||||
|
||||
|
||||
/*********PDO**********/
|
||||
public function count($sql, $parameters = null): int
|
||||
{
|
||||
return $this->exeupdate($sql, $parameters);
|
||||
}
|
||||
|
||||
public function querysql($sql, $parameters = null)
|
||||
{
|
||||
return $this->exeupdate($sql, $parameters);
|
||||
}
|
||||
|
||||
|
||||
public function querysqlinsertid($sql, $parameters = null)
|
||||
{
|
||||
if ($this->exeupdate($sql, $parameters)) {
|
||||
return $this->db->lastInsertId();
|
||||
} else {
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public function getRow($sql, $parameters = null)
|
||||
{
|
||||
$res = $this->exequery($sql, $parameters);
|
||||
if (count($res) > 0) {
|
||||
|
||||
return $res[0];
|
||||
} else {
|
||||
return array();
|
||||
}
|
||||
}
|
||||
|
||||
public function getAll($sql, $parameters = null)
|
||||
{
|
||||
$res = $this->exequery($sql, $parameters);
|
||||
if (count($res) > 0) {
|
||||
return $res;
|
||||
} else {
|
||||
return array();
|
||||
}
|
||||
}
|
||||
|
||||
public function beginTransaction()
|
||||
{
|
||||
$this->db->beginTransaction();
|
||||
}
|
||||
|
||||
public function rollback()
|
||||
{
|
||||
$this->db->rollback();
|
||||
}
|
||||
|
||||
public function commit()
|
||||
{
|
||||
$this->db->commit();
|
||||
}
|
||||
|
||||
public function exequery($sql, $parameters = null)
|
||||
{
|
||||
$conn = $this->db;
|
||||
$stmt = $conn->prepare($sql);
|
||||
$stmt->execute($parameters);
|
||||
$rs = $stmt->fetchall(\PDO::FETCH_ASSOC);
|
||||
$stmt = null;
|
||||
$conn = null;
|
||||
return $rs;
|
||||
}
|
||||
|
||||
public function exeupdate($sql, $parameters = null)
|
||||
{
|
||||
$stmt = $this->db->prepare($sql);
|
||||
$stmt->execute($parameters);
|
||||
$affectedrows = $stmt->rowcount();
|
||||
$stmt = null;
|
||||
$conn = null;
|
||||
return $affectedrows;
|
||||
}
|
||||
|
||||
public function checklink()
|
||||
{
|
||||
$res = $this->db->getAttribute(\PDO::ATTR_SERVER_INFO);
|
||||
if (strpos($res, 'server has gone away') !== false) {
|
||||
$this->db = null;
|
||||
return false;
|
||||
} else {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
public function getinsertid()
|
||||
{
|
||||
return $this->db->lastInsertId();
|
||||
}
|
||||
|
||||
public function close()
|
||||
{
|
||||
return $this->db = null;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,42 @@
|
||||
<?php
|
||||
|
||||
class Db2
|
||||
{
|
||||
public static function i($db, $table, $array)
|
||||
{
|
||||
$insertArr = array();
|
||||
$sql = "insert into `{$table}`(";
|
||||
$sql1 = 'values(';
|
||||
foreach ($array as $key => $value) {
|
||||
$sql .= "`{$key}`,";
|
||||
$sql1 .= "?,";
|
||||
$insertArr[] = $value;
|
||||
}
|
||||
$sql = trim($sql, ',');
|
||||
$sql1 = trim($sql1, ',');
|
||||
$sql .= ")" . $sql1 . ")";
|
||||
$db->querysql($sql, $insertArr);
|
||||
return $db->getinsertid();
|
||||
}
|
||||
|
||||
public static function u($db, $table, $array, $where, $where_a = [])
|
||||
{
|
||||
$updateArr = array();
|
||||
$sql = "update `{$table}` set ";
|
||||
foreach ($array as $key => $value) {
|
||||
$sql .= "`{$key}`=?,";
|
||||
$updateArr[] = $value;
|
||||
}
|
||||
$sql = trim($sql, ',');
|
||||
$where = ' ' . $where;
|
||||
$sql .= $where;
|
||||
$updateArr = array_merge($updateArr, $where_a);
|
||||
return $db->querysql($sql, $updateArr);
|
||||
}
|
||||
|
||||
public static function d($db, $table, $where, $where_a = [])
|
||||
{
|
||||
$sql = "delete from `{$table}` " . $where;
|
||||
$db->querysql($sql, $where_a);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,88 @@
|
||||
<?php
|
||||
|
||||
class Tool
|
||||
{
|
||||
public static $env = null;
|
||||
|
||||
// region 获取 UUID
|
||||
public static function uuid($break = '-'): string
|
||||
{
|
||||
$chars = md5(uniqid(mt_rand(), true));
|
||||
$chars_arr = [
|
||||
substr($chars, 0, 8),
|
||||
substr($chars, 8, 4),
|
||||
substr($chars, 12, 4),
|
||||
substr($chars, 16, 4),
|
||||
substr($chars, 20, 12),
|
||||
];
|
||||
return implode($break, $chars_arr);
|
||||
}
|
||||
// endregion
|
||||
|
||||
// region 发送POST请求
|
||||
public static function post($url, $data = [], $decode = true, $type = 'json')
|
||||
{
|
||||
$curl = curl_init();
|
||||
curl_setopt($curl, CURLOPT_URL, $url);
|
||||
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
|
||||
curl_setopt($curl, CURLOPT_POST, true);
|
||||
if ($type === 'data') {
|
||||
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
|
||||
curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
|
||||
curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
|
||||
}
|
||||
if ($type === 'json') {
|
||||
$data_string = json_encode($data, JSON_UNESCAPED_UNICODE);
|
||||
curl_setopt($curl, CURLOPT_HTTPHEADER, [
|
||||
'Content-Type: application/json; charset=utf-8',
|
||||
'Content-Length: ' . strlen($data_string)
|
||||
]);
|
||||
curl_setopt($curl, CURLOPT_POSTFIELDS, $data_string);
|
||||
}
|
||||
$r = curl_exec($curl);
|
||||
curl_close($curl);
|
||||
if ($decode) {
|
||||
return json_decode($r, true);
|
||||
} else {
|
||||
return $r;
|
||||
}
|
||||
}
|
||||
// endregion
|
||||
|
||||
// region 读取 Config ini
|
||||
public static function ini($key, $default = false)
|
||||
{
|
||||
if (!$key) return $default;
|
||||
if (!self::$env) {
|
||||
$config_file_path = dirname(__DIR__, 3) . '/.env';
|
||||
$env_content = file_get_contents($config_file_path);
|
||||
$env_ini = parse_ini_string($env_content);
|
||||
self::$env = $env_ini;
|
||||
}
|
||||
return (isset(self::$env[$key])) ? self::$env[$key] : $default;
|
||||
}
|
||||
// endregion
|
||||
|
||||
// region 10位时间戳 格式化
|
||||
public static function date($time = false, $format = "Y-m-d H:i:s")
|
||||
{
|
||||
if (!$time) $time = time();
|
||||
return date($format, $time);
|
||||
}
|
||||
// endregion
|
||||
|
||||
|
||||
// region 去除空格
|
||||
public static function ge($str)
|
||||
{
|
||||
return preg_replace("/\s+/", ' ', $str);
|
||||
}
|
||||
// endregion
|
||||
|
||||
// region 毫秒时间戳
|
||||
public static function time()
|
||||
{
|
||||
return floor(microtime(true) * 1000);
|
||||
}
|
||||
// endregion
|
||||
}
|
||||
@ -0,0 +1,21 @@
|
||||
The MIT License
|
||||
|
||||
Copyright (c) 2009-2015 walkor<walkor@workerman.net> and contributors (see https://github.com/walkor/workerman/contributors)
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in
|
||||
all copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||
THE SOFTWARE.
|
||||
@ -0,0 +1,37 @@
|
||||
GatewayClient
|
||||
=================
|
||||
`composer install`
|
||||
|
||||
`composer require workerman/gatewayclient`
|
||||
|
||||
```php
|
||||
use GatewayClient\Gateway;
|
||||
|
||||
Gateway::$registerAddress = '127.0.0.1:3238';
|
||||
|
||||
Gateway::bindUid($client_id, $uid);
|
||||
Gateway::joinGroup($client_id, $group_id);
|
||||
|
||||
Gateway::sendToUid($uid, $message);
|
||||
Gateway::sendToGroup($group, $message);
|
||||
|
||||
Gateway::sendToAll($data);
|
||||
Gateway::sendToClient($client_id, $data);
|
||||
Gateway::closeClient($client_id);
|
||||
Gateway::isOnline($client_id);
|
||||
Gateway::bindUid($client_id, $uid);
|
||||
Gateway::isUidOnline($uid);
|
||||
Gateway::getClientIdByUid($uid);
|
||||
Gateway::unbindUid($client_id, $uid);
|
||||
Gateway::sendToUid($uid, $data);
|
||||
Gateway::joinGroup($client_id, $group);
|
||||
Gateway::sendToGroup($group, $data);
|
||||
Gateway::leaveGroup($client_id, $group);
|
||||
Gateway::getClientCountByGroup($group);
|
||||
Gateway::getClientSessionsByGroup($group);
|
||||
Gateway::getAllClientCount();
|
||||
Gateway::getAllClientSessions();
|
||||
Gateway::setSession($client_id, $session);
|
||||
Gateway::updateSession($client_id, $session);
|
||||
Gateway::getSession($client_id);
|
||||
```
|
||||
@ -0,0 +1,15 @@
|
||||
{
|
||||
"name" : "workerman/gateway-worker-demo",
|
||||
"keywords": ["distributed","communication"],
|
||||
"homepage": "http://www.workerman.net",
|
||||
"license" : "MIT",
|
||||
"require": {
|
||||
"workerman/gateway-worker" : ">=3.0.0"
|
||||
},
|
||||
"autoload": {
|
||||
"psr-4": {
|
||||
"" : "./",
|
||||
"" : "./Applications/YourApp/"
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,2 @@
|
||||
php Applications\YourApp\start_register.php Applications\YourApp\start_gateway.php Applications\YourApp\start_businessworker.php
|
||||
pause
|
||||
Loading…
Reference in New Issue