当前位置: 首页 > 工具软件 > Actor IM > 使用案例 >

php模型上线,php极简框架 one 1.6.7发布,新增分布式并发模型Actor

雷晋
2023-12-01

One - 极简 . 高性能 . 松耦合 . 分布式 . 可运行于多种环境(cli,apache/php-fpm,swoole)

适用场景

常规web/app后端服务器

游戏/im即时通讯服务器

tcp/udp物联网服务器

综合性项目,各种混合协议通讯

修复问题

使用文件(file)缓存时,不设置过期时间缓存失败问题。

新增

新增模型方法flushTableInfo,主动刷新数据表结构缓存。

分布式并发模型Actor

Actor 是什么?

是一种与共享内存对应的并发模型,具有资源独占性。可以理解为一个对象,它有属性和方法。

主要方法

Actor::init() 创建Actor

Actor::drop($actor_id) 删除Actor

Actor::call($actor_id, $method, $args) Actor通讯

适合场景

每个对象都在变化,对象之间有通讯的场景。

例1 游戏:

每个角色就是一个actor实例:

属性:生命值,攻击力

方法:生命值加/减

class UserActor extends Actor

{

// 生命值

private $life_value = 10;

// 攻击力

private $power_value = 5;

// 长连接fd

public $fd;

// 返回自己的actor id

public function getActorId()

{

return $this->actor_id;

}

// 改变生命值 并 通知客户端

public function changeLifeValue($n)

{

$this->life_value += $n;

$this->noticeClient();

}

// 攻击某个 Actor => 减少Actor的生命值

// 被攻击Actor可以其他进程或者其他机器上

public function fire($actor_id)

{

$this->call($actor_id,'changeLifeValue',[$this->power_value]);

}

// 通知客户端当前的生命值

public function noticeClient()

{

self::$server->push($this->fd,$this->life_value);

}

}

// 实例化一个角色

$user1 = UserActor::init();

// 获取这个角色的actor_id

$actor_id = $user1->getActorId();

// 角色死亡 销毁 actor

UserActor::drop($actor_id);

Vs 共享内存方式

每个用户的属性需要储存在一个公共的地方,每次存取都很麻烦。如果改变用户的属性值还需要考虑并发问题。如果属性更多编写起来将非常复杂。

例如:用户a,b,c。 都分布在不同的机器上。a和b同时打到了c;

 类似资料: