五月天激情丁香,国产精品2019,国产成人精品亚洲2020,国产精品免费视频一区二区三区,开心久久婷婷综合中文字幕,天堂视频在线观看免费完整版

NSQ客戶端

NSQ 是實時的分布式消息處理平臺,其設計的目的是用來大規模地處理每天數以十億計級別的消息。 它具有分布式和去中心化拓撲結構,該結構具有無單點故障、故障容錯、高可用性以及能夠保證消息的可靠傳遞的特征。

組件要求

  • php: >=5.3.0
  • ext-json: *
  • easyswoole/easyswoole: 3.x
  • easyswoole/http-client: ^1.2.5
  • easyswoole/pool: ^1.0
  • easyswoole/spl: ^1.1
  • monolog/monolog: ~1.0
  • react/react: >=0.2.1

安裝方法

composer require easyswoole/nsq

倉庫地址

easyswoole/nsq

基本使用

注冊Nsq服務

namespace EasySwoole\EasySwoole;

use App\Producer\Process as ProducerProcess;
use App\Consumer\Process as ConsumerProcess;
use EasySwoole\EasySwoole\Swoole\EventRegister;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\Http\Request;
use EasySwoole\Http\Response;

class EasySwooleEvent implements Event
{

    public static function initialize()
    {
        // TODO: Implement initialize() method.
        date_default_timezone_set('Asia/Shanghai');
    }

    public static function mainServerCreate(EventRegister $register)
    {
        // TODO: Implement mainServerCreate() method.
        // 生產者
        \EasySwoole\Component\Process\Manager::getInstance()->addProcess(new ProducerProcess());
        // 消費者
        \EasySwoole\Component\Process\Manager::getInstance()->addProcess(new ConsumerProcess());
    }

    ......

}

生產者

namespace App\Producer;

use EasySwoole\Component\Process\AbstractProcess;

class Process extends AbstractProcess
{
    protected function run($arg)
    {
        go(function () {
            $config = new \EasySwoole\Nsq\Config();
            $topic  = "topic.test";
            $nsqlookup = new \EasySwoole\Nsq\Lookup\Nsqlookupd($config->getNsqdUrl());
            $hosts = $nsqlookup->lookupHosts($topic);

            foreach ($hosts as $host) {
                $nsq = new \EasySwoole\Nsq\Nsq();
                for ($i = 0; $i < 10; $i++) {
                    $msg = new \EasySwoole\Nsq\Message\Message();
                    $msg->setPayload("test$i");
                    $nsq->push(
                        new \EasySwoole\Nsq\Connection\Producer($host, $config),
                        $topic,
                        $msg
                    );
                }
            }
        });
    }
}

消費者

namespace App\Consumer;

use EasySwoole\Component\Process\AbstractProcess;

class Process extends AbstractProcess
{
    protected function run($arg)
    {
        go(function () {
            $topic      = "topic.test";
            $config     = new \EasySwoole\Nsq\Config();
            $nsqlookup  = new \EasySwoole\Nsq\Lookup\Nsqlookupd($config->getNsqdUrl());
            $hosts      = $nsqlookup->lookupHosts($topic);
            foreach ($hosts as $host) {
                $nsq = new \EasySwoole\Nsq\Nsq();
                $nsq->subscribe(
                    new \EasySwoole\Nsq\Connection\Consumer($host, $config, $topic, 'test.consuming'),
                    function ($item) {
                        var_dump($item['message']);
                    }
                );
            }
        });
    }
}

附贈

  1. Nsq 集群部署 docker-compose.yml 一份,使用方式如下
    1. 保證4150,4151,4160,4161,4171端口未被占用(占用后可以修改compose文件中的端口號)
    2. 根目錄下,docker-compose up -d
    3. 訪問localhost:4171,可以查看Web版 nsqadmin 狀態。

https://github.com/easy-swoole/nsq/blob/master/docker-compose.yml

主站蜘蛛池模板: 久久久久久国产视频 | 五月婷婷丁香色 | 国产青草 | 五月婷婷丁香综合网 | 国产精品欧美一区二区 | 免费人成年短视频在线观看免费网站 | 韩日免费视频 | 欧洲精品一区二区三区 | 国产精品久久久久免费 | 久久中文字幕视频 | 五月激激激综合网色播免费 | 99精品国产第一福利网站 | 亚洲激情五月 | 国产99久久亚洲综合精品 | 六月丁香婷婷激情国产 | 爽爽影院在线看 | 深爱五月网 | 999成人精品视频在线 | 橘梨纱一区2区3区高清在线 | 九九国产精品视频 | 九月激情网| 啪啪自拍视频 | 四虎免费在线观看 | 国产欧美一区二区三区观看 | 四虎激情 | 国产欧美日韩高清专区手机版 | 精品视频在线免费 | 久久中国 | 国产欧美性综合视频性刺激 | 国产高清吹潮免费视频 | 欧美色视频网 | 欧美一区二区三区免费观看视频 | 深夜视频在线免费 | 99精品国产综合久久久久 | 182tv精品视频在线播放 | 久久一区二区三区免费 | 偷拍第一页 | 免费精品 | 福利不卡 | 午夜国产在线视频 | 久久午夜视频 |