共计 4031 个字符,预计需要花费 11 分钟才能阅读完成。
去年在网上发了一篇《我用 php 构建了魔兽世界服务器, 只为证实 php 是世界上最好的语言》的帖子反应还不错,github 骗了不少赞。年初因为疫情在家里待了很久,无聊之中又开了一个新我的项目筹备持续骗赞~ 哈哈哈
说起传奇,8090 的童鞋预计都有所接触,这可是比魔兽世界还早的网络游戏,记得那时候中国区开服,网吧里基本上都是玩传奇的童鞋,楼主那时候还小,一个叔叔带着我玩了一段时间,每次玩到 7 级就换号,没钱去充值,哈哈哈,然而感觉也很有乐趣~
随着年纪越来越大,工作越来越忙,玩游戏的工夫简直没有,偶然灵机一动去玩玩,感觉也是物是人非,玩着玩着也没什么意思了,然而仍旧喜爱游戏,那就罗唆本人写点游戏过过瘾吧
言归正传,看看怎么用 php 实现传奇服务端吧
咱们选用的扩大仍然为 Swoole,框架应用 Hyperf 做底层,这个框架不错,很多货色不必本人再去写了,比方连接池、依赖注入容器、注解、AOP 面向切面、基于 PSR-15 的中间件、自定义过程等等
相比于之前的魔兽世界模拟器用户验证服务及游戏服务,本次传奇模仿服务端将多个 Worker 过程作为网关服务,而后将数据包转发到游戏过程(其实就是一个自定义过程),在多过程模式下存在过程内存隔离,不同过程之间无奈同步
对应的解决方案就是应用内部存储服务:
数据库,如:MySQL、MongoDB
缓存服务器,如:Redis、Memcache
磁盘文件,多过程并发读写时须要加锁。
一般的数据库和磁盘文件操作,存在较多 IO 等待时间。
Redis 内存数据库,读写速度十分快,然而有 TCP 连贯等问题,性能也不是最高的。
/dev/shm 内存文件系统,读写操作全副在内存中实现,无 IO 耗费,性能极高,然而数据不是格式化的,还有数据同步的问题。
最初还要扩大内置的 Swoole\Table, 然而这种计划是须要先设置内存大小和字段类型不够灵便。
最初通过各种折腾决定应用自定义过程多协程的计划,网关能够开任意个过程解决并发业务,自定义过程去解决外围的数据业务,单过程多协程解决内存隔离问题同时也满足了性能要求~
接下来看看 TCP 数据的解包与封包
传奇应用 BinaryReader 来进行数据包的封包与解包,但 php 如同没有相干的类,但能够用 pack/unpack 函数去封装
<?php
namespace App\Controller\Packet;
class BinaryReader
{
private $packetString = [
'string' => 'c',
'int8' => 'c',
'int16' => 's',
'int32' => 'l',
'int64' => 'q',
'uint8' => 'C',
'uint16' => 'v',
'uint32' => 'V',
'uint64' => 'P',
'bool' => 'c',
'float32' => 'f',
];
public function unPackString(string $type, string $packet)
{return unpack($this->packetString[$type], $packet)[1];
}
public function packString(string $type, string $packet)
{return pack($this->packetString[$type], $packet);
}
public function read(array $struct, string $packet): array
{$data = [];
foreach ($struct as $k => $v) {switch ($v) {
case 'string':
if ($packet) {$len = $this->unPackString($v, $packet);
$data[$k] = substr($packet, 1, $len);
$packet = substr($packet, $len + 1);
} else {$data[$k] = '';
}
break;
case 'int8':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 1);
} else {$data[$k] = 0;
}
break;
case 'int16':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 2);
} else {$data[$k] = 0;
}
break;
case 'int32':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 4);
} else {$data[$k] = 0;
}
break;
case 'int64':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 8);
} else {$data[$k] = 0;
}
break;
case 'uint8':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 1);
} else {$data[$k] = 0;
}
break;
case 'uint16':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 2);
} else {$data[$k] = 0;
}
break;
case 'uint32':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 4);
} else {$data[$k] = 0;
}
break;
case 'uint64':
if ($packet) {$data[$k] = $this->unPackString($v, $packet);
$packet = substr($packet, 8);
} else {$data[$k] = 0;
}
break;
case '[]int8':
if ($packet) {$len = strlen($packet);
$info = [];
for ($i = 0; $i < $len; $i++) {$info[] = $this->unPackString('int8', $packet);
$packet = substr($packet, 1);
}
$data[$k] = $info;
} else {$data[$k] = 0;
}
break;
case '[]int32':
if ($packet) {
$len = 4;
$info = [];
for ($i = 0; $i < $len; $i++) {$info[] = $this->unPackString('int8', $packet);
$packet = substr($packet, $len);
}
$data[$k] = $info;
} else {$data[$k] = 0;
}
break;
}
}
return $data;
}
public function write(array $struct, array $packet)
{
$data = '';
foreach ($struct as $k => $v) {if (isset($packet[$k]) && $packet[$k] !== null) {if (is_array($v)) {if (!empty($packet[$k][0]) && is_array($packet[$k][0])) {foreach ($packet[$k] as $k1 => $v1) {$data .= $this->write($v, $v1);
}
} else {$data .= $this->write($v, $packet[$k]);
}
} else {switch ($v) {
case 'string':
$len = $this->packString($v, strlen($packet[$k]));
$data .= $len . $packet[$k];
break;
case 'bool':
$packet[$k] = $packet[$k] ? 1 : 0;
$data .= $this->packString($v, $packet[$k]);
break;
case '[]int32':
if (is_array($packet[$k])) {foreach ($packet[$k] as $k1 => $v1) {$data .= $this->packString('int32', $v1);
}
}
break;
case '[]uint8':
if (is_array($packet[$k])) {foreach ($packet[$k] as $k1 => $v1) {$data .= $this->packString('uint8', $v1);
}
}
break;
case '[]string':
if (is_array($packet[$k])) {foreach ($packet[$k] as $k1 => $v1) {$len = $this->packString('string', strlen($v1));
$data .= $len . $v1;
}
}
break;
default:
$data .= $this->packString($v, $packet[$k]);
break;
}
}
}
}
return $data;
}
}
封装了 11 中数据格式,能够满足大部分游戏的封包及解包了,看看是如何应用的
比方先定义好一个数据包的构造,依据字段对应的类型进行封包或解包就能获取数据
到此就能够去写业务逻辑了~
放出地址,具体代码曾经开源,有须要的童鞋能够去试试,记得点赞哈~ 求赞求赞求赞:https://github.com/fan3750060/pmir2