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

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

码云: gitee.com/vicself/one
github: github.com/lizhichao/o…git

适用场景github

  • 常规web/app后端服务器
  • 游戏/im即时通信服务器
  • tcp/udp物联网服务器
  • 综合性项目,各类混合协议通信

修复问题

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

新增

  • 新增模型方法flushTableInfo,主动刷新数据表结构缓存。
  • 分布式并发模型Actor

Actor 是什么?

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

主要方法

  1. Actor::init() 建立Actor
  2. Actor::drop($actor_id) 删除Actor
  3. 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;服务器

相关文章
相关标签/搜索