php極簡(jiǎn)框架 one 1.6.7發(fā)布，新增分布式并發(fā)模型Actor

劉明發(fā)布于2019-07-01 12:47 / 1176人閱讀

摘要：新增新增模型方法，主動(dòng)刷新數(shù)據(jù)表結(jié)構(gòu)緩存。分布式并發(fā)模型是什么是一種與共享內(nèi)存對(duì)應(yīng)的并發(fā)模型，具有資源獨(dú)占性。都分布在不同的機(jī)器上。

One - 極簡(jiǎn) . 高性能 . 松耦合 . 分布式 . 可運(yùn)行于多種環(huán)境(cli,apache/php-fpm,swoole)

碼云: https://gitee.com/vicself/one
github: https://github.com/lizhichao/one

適用場(chǎng)景

常規(guī)web/app后端服務(wù)器

游戲/im即時(shí)通訊服務(wù)器

tcp/udp物聯(lián)網(wǎng)服務(wù)器

綜合性項(xiàng)目，各種混合協(xié)議通訊

修復(fù)問題

使用文件(file)緩存時(shí)，不設(shè)置過期時(shí)間緩存失敗問題。

新增

新增模型方法flushTableInfo，主動(dòng)刷新數(shù)據(jù)表結(jié)構(gòu)緩存。

分布式并發(fā)模型Actor

Actor 是什么？

是一種與共享內(nèi)存對(duì)應(yīng)的并發(fā)模型，具有資源獨(dú)占性。可以理解為一個(gè)對(duì)象，它有屬性和方法。

主要方法

Actor::init() 創(chuàng)建Actor

Actor::drop($actor_id) 刪除Actor

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

適合場(chǎng)景

每個(gè)對(duì)象都在變化，對(duì)象之間有通訊的場(chǎng)景。

例1 游戲：

每個(gè)角色就是一個(gè)actor實(shí)例:
屬性：生命值,攻擊力
方法：生命值加/減

class UserActor extends Actor
{
    // 生命值
    private $life_value = 10;

    // 攻擊力
    private $power_value = 5;

    // 長(zhǎng)連接fd
    public $fd;

    // 返回自己的actor id
    public function getActorId()
    {
        return $this->actor_id;
    }

    // 改變生命值 并 通知客戶端
    public function changeLifeValue($n)
    {
        $this->life_value += $n;
        $this->noticeClient();
    }

    // 攻擊某個(gè) Actor =>  減少Actor的生命值
    // 被攻擊Actor可以其他進(jìn)程或者其他機(jī)器上
    public function fire($actor_id)
    {
        $this->call($actor_id,"changeLifeValue",[$this->power_value]);
    }

    // 通知客戶端當(dāng)前的生命值
    public function noticeClient()
    {
        self::$server->push($this->fd,$this->life_value);
    }
}

// 實(shí)例化一個(gè)角色
$user1 = UserActor::init();

// 獲取這個(gè)角色的actor_id
$actor_id = $user1->getActorId();

// 角色死亡 銷毀 actor
UserActor::drop($actor_id);

Vs 共享內(nèi)存方式

每個(gè)用戶的屬性需要儲(chǔ)存在一個(gè)公共的地方，每次存取都很麻煩。如果改變用戶的屬性值還需要考慮并發(fā)問題。如果屬性更多編寫起來將非常復(fù)雜。
例如：用戶a,b,c。都分布在不同的機(jī)器上。a和b同時(shí)打到了c;