PHP event_base_loop函数代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› PHP›PHP编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了PHP中event_base_loop函数的典型用法代码示例。如果您正苦于以下问题：PHP event_base_loop函数的具体用法？PHP event_base_loop怎么用？PHP event_base_loop使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了event_base_loop函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的PHP代码示例。

示例1: start

 public function start()
 {
     $this->onStart();
     $this->base = event_base_new();
     if ($this->_server) {
         $this->event = event_new();
         event_set($this->event, $this->_server, EV_READ | EV_PERSIST, array($this, 'accept'), $this->base);
         event_base_set($this->event, $this->base);
         event_add($this->event);
     }
     if ($this->_service) {
         $this->service_event = event_new();
         event_set($this->service_event, $this->_service, EV_READ | EV_PERSIST, array($this, 'service'), $this->base);
         event_base_set($this->service_event, $this->base);
         event_add($this->service_event);
     }
     if ($this->_master) {
         $this->master_event = event_new();
         event_set($this->master_event, $this->_master, EV_READ | EV_PERSIST | EV_WRITE, array($this, 'master'), $this->base);
         event_base_set($this->master_event, $this->base);
         event_add($this->master_event);
     }
     if ($this->timer) {
         $timer = event_timer_new();
         event_timer_set($timer, array($this, '_onTimer'), $timer);
         event_base_set($timer, $this->base);
         //event_timer_pending($timer, $this->timer * 1000000);
         event_timer_add($timer, $this->timer * 1000000);
     }
     event_base_loop($this->base);
 }

开发者ID:morozovsk，项目名称:websocket，代码行数:31，代码来源:GenericLibevent.php

示例2: EpollSocketServer

 function EpollSocketServer($port)
 {
     global $errno, $errstr;
     if (!extension_loaded('libevent')) {
         die("Please install libevent extension firstly/n");
     }
     if ($port < 1024) {
         die("Port must be a number which bigger than 1024/n");
     }
     $socket_server = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
     if (!$socket_server) {
         die("{$errstr} ({$errno})");
     }
     stream_set_blocking($socket_server, 0);
     // 非阻塞
     $base = event_base_new();
     $event = event_new();
     event_set($event, $socket_server, EV_READ | EV_PERSIST, array(__CLASS__, 'ev_accept'), $base);
     event_base_set($event, $base);
     event_add($event);
     event_base_loop($base);
     self::$connections = array();
     self::$buffers = array();
     self::$imei = array();
 }

开发者ID:noikiy，项目名称:mygit，代码行数:25，代码来源:php_socketserver_epoll2.php

示例3: __construct

 public function __construct($port)
 {
     global $errno, $errstr;
     if (!extension_loaded('libevent')) {
         die("Please install libevent extension firstly\n");
     }
     if ($port < 1024) {
         die("Port must be a number which bigger than 1024\n");
     }
     $socket_server = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
     if (!$socket_server) {
         die("{$errstr} ({$errno})");
     }
     stream_set_blocking($socket_server, 0);
     // 非阻塞
     // event_base_new — Create and initialize new event base
     $base = event_base_new();
     // event_new — Create new event
     $event = event_new();
     // event_set — Prepare an event
     event_set($event, $socket_server, EV_READ | EV_PERSIST, [__CLASS__, 'ev_accept'], $base);
     // event_base_set — Associate event base with an event
     event_base_set($event, $base);
     // event_add — Add an event to the set of monitored events
     event_add($event);
     // event_base_loop — Handle events
     event_base_loop($base);
     self::$connections = [];
     self::$buffers = [];
 }

开发者ID:CraryPrimitiveMan，项目名称:code-examples，代码行数:30，代码来源:epoll_server.php

示例4: start

 public function start()
 {
     $this->base = event_base_new();
     if ($this->_server) {
         $this->event = event_new();
         event_set($this->event, $this->_server, EV_READ | EV_PERSIST, array($this, 'accept'), $this->base);
         event_base_set($this->event, $this->base);
         event_add($this->event);
     }
     foreach ($this->_services as $serviceId => $service) {
         $event = event_new();
         event_set($event, $service, EV_READ | EV_PERSIST | EV_WRITE, array($this, 'service'), $this->base);
         event_base_set($event, $this->base);
         event_add($event);
         $this->events[$serviceId] = $event;
     }
     if ($this->timer) {
         $timer = event_timer_new();
         event_timer_set($timer, array($this, '_onTimer'), $timer);
         event_base_set($timer, $this->base);
         //event_timer_pending($timer, $this->timer * 1000000);
         event_timer_add($timer, $this->timer * 1000000);
     }
     event_base_loop($this->base);
 }

开发者ID:JimboOneTwo，项目名称:websocket，代码行数:25，代码来源:WebsocketGenericLibevent.php

示例5: run

 /**
  * Runtime of Master process
  * @return void
  */
 public function run()
 {
     Daemon::$process = $this;
     $this->prepareSystemEnv();
     class_exists('Timer');
     // ensure loading this class
     gc_enable();
     $this->eventBase = event_base_new();
     $this->registerEventSignals();
     FS::initEvent();
     $this->fileWatcher = new FileWatcher();
     $this->workers = new ThreadCollection();
     $this->collections['workers'] = $this->workers;
     Daemon::$appResolver = (require Daemon::$config->path->value);
     $this->IPCManager = Daemon::$appResolver->getInstanceByAppName('IPCManager');
     Daemon::$appResolver->preload(true);
     $this->callbacks = new SplStack();
     $this->spawnWorkers(min(Daemon::$config->startworkers->value, Daemon::$config->maxworkers->value));
     Timer::add(function ($event) use(&$cbs) {
         $self = Daemon::$process;
         static $c = 0;
         ++$c;
         if ($c > 0xfffff) {
             $c = 1;
         }
         if ($c % 10 == 0) {
             $self->workers->removeTerminated(true);
             gc_collect_cycles();
         } else {
             $self->workers->removeTerminated();
         }
         if (isset(Daemon::$config->mpm->value) && is_callable(Daemon::$config->mpm->value)) {
             call_user_func(Daemon::$config->mpm->value);
         } else {
             // default MPM
             $state = Daemon::getStateOfWorkers($self);
             if ($state) {
                 $n = max(min(Daemon::$config->minspareworkers->value - $state['idle'], Daemon::$config->maxworkers->value - $state['alive']), Daemon::$config->minworkers->value - $state['alive']);
                 if ($n > 0) {
                     Daemon::log('Spawning ' . $n . ' worker(s).');
                     $self->spawnWorkers($n);
                     event_base_loopbreak($self->eventBase);
                 }
                 $n = min($state['idle'] - Daemon::$config->maxspareworkers->value, $state['alive'] - Daemon::$config->minworkers->value);
                 if ($n > 0) {
                     Daemon::log('Stopping ' . $n . ' worker(s).');
                     $self->stopWorkers($n);
                 }
             }
         }
         $event->timeout();
     }, 1000000.0 * Daemon::$config->mpmdelay->value, 'MPM');
     while (!$this->breakMainLoop) {
         while (!$this->callbacks->isEmpty()) {
             call_user_func($this->callbacks->shift(), $this);
         }
         event_base_loop($this->eventBase);
     }
 }

开发者ID:ruslanchek，项目名称:phpdaemon，代码行数:63，代码来源:Daemon_MasterThread.php

示例6: loop

 public function loop()
 {
     if (!($this->event_base = event_base_new())) {
         throw new RuntimeException("Can't create event base");
     }
     $this->addSocketEvent();
     event_base_loop($this->event_base);
 }

开发者ID:LookForwardPersistence，项目名称:appserver-in-php，代码行数:8，代码来源:LibEventUnbuffered.php

示例7: dispatch

 /**
  * {@inheritdoc}
  */
 protected function dispatch(bool $blocking)
 {
     $flags = EVLOOP_ONCE;
     if (!$blocking) {
         $flags |= EVLOOP_NONBLOCK;
     }
     event_base_loop($this->base, $flags);
     // Dispatch I/O, timer, and signal callbacks.
 }

开发者ID:kanzuka，项目名称:icicle，代码行数:12，代码来源:LibeventLoop.php

示例8: loop

 public function loop()
 {
     if (!($this->event_base = event_base_new())) {
         throw new RuntimeException("Can't create event base");
     }
     foreach ($this->addrs as $addr) {
         $this->addAddr($addr);
     }
     event_base_loop($this->event_base);
 }

开发者ID:bermi，项目名称:akelos，代码行数:10，代码来源:LibEvent.class.php

示例9: worker_callback

 public function worker_callback(swoole_process $worker)
 {
     self::$worker_event_base[$worker->pipe] = event_base_new();
     $event = event_new();
     //$GLOBALS['worker'] = $worker;
     event_set($event, $worker->pipe, EV_READ | EV_PERSIST, array($this, 'worker_accept'), $worker);
     event_base_set($event, self::$worker_event_base[$worker->pipe]);
     event_add($event);
     event_base_loop(self::$worker_event_base[$worker->pipe]);
 }

开发者ID:zhangjingpu，项目名称:yaf-lib，代码行数:10，代码来源:Processpool.php

示例10: doRun

 private function doRun($flags = 0)
 {
     $this->isRunning = TRUE;
     event_base_loop($this->base, $flags);
     $this->isRunning = FALSE;
     if ($this->stopException) {
         $e = $this->stopException;
         throw $e;
     }
 }

开发者ID:medehghani，项目名称:alert，代码行数:10，代码来源:LibeventReactor.php

示例11: listen

 public function listen()
 {
     echo "Start listening port " . $this->opts['port'] . "\n";
     $socket = stream_socket_server('tcp://0.0.0.0:' . $this->opts['port'], $errno, $errstr);
     stream_set_blocking($socket, 0);
     $this->base = event_base_new();
     $listenerEvent = event_new();
     event_set($listenerEvent, $socket, EV_READ | EV_PERSIST, array($this, 'onAccept'), null);
     event_base_set($listenerEvent, $this->base);
     event_add($listenerEvent, -1);
     event_base_loop($this->base);
 }

开发者ID:sokal32，项目名称:ranch-cowboy-smoothie-php-draft，代码行数:12，代码来源:ranch_tcp.php

示例12: run

 public function run()
 {
     $this->init();
     //建立服务器端Socket
     $this->server_sock = $this->create("tcp://{$this->config['host']}:{$this->config['port']}");
     //设置事件监听，监听到服务器端socket可读，则有连接请求
     \event_set($this->server_event, $this->server_sock, EV_READ | EV_PERSIST, __CLASS__ . '::server_handle_connect', $this);
     \event_base_set($this->server_event, $this->base_event);
     \event_add($this->server_event);
     $this->client->onStart();
     \event_base_loop($this->base_event);
 }

开发者ID:tempbottle，项目名称:zphp，代码行数:12，代码来源:Php.php

示例13: listen

 /**
  * Start listening
  */
 public function listen()
 {
     $this->handle_ = stream_socket_server("tcp://{$this->host_}:{$this->port_}", $this->errno_, $this->errstr_);
     stream_set_blocking($this->handle_, 0);
     // no blocking
     $this->base_ = \event_base_new();
     $this->serverEvent_ = \event_new();
     \event_set($this->serverEvent_, $this->handle_, EV_READ | EV_PERSIST, array($this, 'onConnect'));
     \event_base_set($this->serverEvent_, $this->base_);
     \event_add($this->serverEvent_);
     \event_base_loop($this->base_);
 }

开发者ID:kaiyulee，项目名称:thrift-lib-php，代码行数:15，代码来源:TNonblockingServerSocket.php

示例14: run

 /**
  * 运行服务器程序
  * @return unknown_type
  */
 function run($setting)
 {
     $this->init();
     //建立服务器端Socket
     $this->server_sock = $this->create("tcp://{$this->host}:{$this->port}");
     //设置事件监听，监听到服务器端socket可读，则有连接请求
     event_set($this->server_event, $this->server_sock, EV_READ | EV_PERSIST, array($this, "event_connect"));
     event_base_set($this->server_event, $this->base_event);
     event_add($this->server_event);
     $this->spawn($setting);
     $this->protocol->onStart($this);
     event_base_loop($this->base_event);
 }

开发者ID:foolkaka，项目名称:soaphp-framework，代码行数:17，代码来源:EventTCP.php

示例15: run

 /**
  * 运行服务器程序
  * @return unknown_type
  */
 function run()
 {
     //初始化事件系统
     $this->init();
     //建立服务器端Socket
     $this->server_sock = $this->create("udp://{$this->host}:{$this->port}");
     //设置事件监听，监听到服务器端socket可读，则有连接请求
     event_set($this->server_event, $this->server_sock, EV_READ | EV_PERSIST, "sw_server_handle_recvfrom", $this);
     event_base_set($this->server_event, $this->base_event);
     event_add($this->server_event);
     $this->protocol->onStart();
     event_base_loop($this->base_event);
 }

开发者ID:jasonshaw，项目名称:framework-1，代码行数:17，代码来源:EventUDP.php

示例16: listen

 public function listen()
 {
     if (!$this->client_type) {
         throw new \Exception('Client type was not defined, please call setClientType() with the type of client (ie \\Beehive\\Clients\\Telnet) before listen()');
     }
     if (!is_callable($this->read_callback)) {
         throw new \Exception('Read callback is not defined with a valid callback, please call setReadCallback() with a valid callback');
     }
     $this->connection = stream_socket_server('tcp://' . $this->host . ':' . $this->port, $errno, $errstr);
     stream_set_blocking($this->connection, 0);
     $event = event_new();
     event_set($event, $this->connection, EV_READ | EV_PERSIST, [$this, 'addClient'], $this->event_base);
     event_base_set($event, $this->event_base);
     event_add($event);
     event_base_loop($this->event_base);
 }

开发者ID:danielmunro，项目名称:beehive，代码行数:16，代码来源:Server.php

示例17: run

 /**
  * 运行服务器程序
  * @return unknown_type
  */
 function run($num = 1)
 {
     //初始化事件系统
     if (!$this->protocol instanceof Swoole_TCP_Server_Protocol) {
         return error(902);
     }
     $this->init();
     //建立服务器端Socket
     $this->server_sock = $this->create("tcp://{$this->host}:{$this->port}");
     //设置事件监听，监听到服务器端socket可读，则有连接请求
     event_set($this->server_event, $this->server_sock, EV_READ | EV_PERSIST, "sw_server_handle_connect", $this);
     event_base_set($this->server_event, $this->base_event);
     event_add($this->server_event);
     if ($num - 1 > 0) {
         sw_spawn($num - 1);
     }
     $this->protocol->onStart();
     event_base_loop($this->base_event);
 }

开发者ID:superwmh，项目名称:swoole，代码行数:23，代码来源:EventTCP.class.php

示例18: libevent_serverAction

 public function libevent_serverAction()
 {
     function print_line($fd, $events, $arg)
     {
         echo "callback fired" . PHP_EOL;
         var_dump($arg[0]->recv());
         $arg[0]->send("got msg " . ZmqController::$msgs);
         if (ZmqController::$msgs++ >= 10) {
             event_base_loopexit($arg[1]);
         }
     }
     $base = event_base_new();
     $event = event_new();
     $context = new ZMQContext();
     $rep = $context->getSocket(ZMQ::SOCKET_REP);
     $rep->bind("tcp://127.0.0.1:5555");
     $fd = $rep->getSockOpt(ZMQ::SOCKOPT_FD);
     event_set($event, $fd, EV_READ | EV_PERSIST, "print_line", array($rep, $base));
     event_base_set($event, $base);
     event_add($event);
     event_base_loop($base);
 }

开发者ID:stonegithubs，项目名称:yaf-lib，代码行数:22，代码来源:Zmq.php

示例19: EpollSocketServer

 function EpollSocketServer($port)
 {
     if (!extension_loaded('libevent')) {
         self::$errstr = "请先安装libevent扩展库。";
         return;
     }
     if ($port < 1024) {
         self::$errstr = "端口号不应小于1024";
         return;
     }
     set_time_limit(0);
     $socket_server = stream_socket_server("tcp://0.0.0.0:{$port}", self::$errno, self::$errstr);
     stream_set_blocking($socket_server, 0);
     // 非阻塞
     $base = event_base_new();
     $event = event_new();
     event_set($event, $socket_server, EV_READ | EV_PERSIST, array(__CLASS__, 'ev_accept'), $base);
     event_base_set($event, $base);
     event_add($event);
     event_base_loop($base);
     self::$connections = array();
     self::$buffers = array();
 }

开发者ID:jumboluo，项目名称:tracking，代码行数:23，代码来源:EpollSocketServer.class.php

示例20: init

 public static function init()
 {
     Daemon::$eventBase = event_base_new();
     $args = $_SERVER['argv'];
     if (!isset($args[1]) || !isset($args[2])) {
         Terminal::drawStr('usage: php xxx.php sArea (start|stop|restart|reload|status)' . "\n");
         exit(-1);
     }
     // todo run multi app in one daemon.
     $sArea = $args[1];
     $command = $args[2];
     $appName = Config::get('socket_server_class', null, true);
     Daemon::$runName = $appName;
     $runAppInstance = array($appName => $appName);
     if ($command == 'start') {
         // fork later
         self::$pid = posix_getpid();
         Debug::log('start');
         foreach ($runAppInstance as $appName) {
             $obj = new $appName();
         }
         while (!Daemon::$breakEventLoop) {
             event_base_loop(daemon::$eventBase, EVLOOP_ONCE);
             // 清空本次写状态数组
             gc_collect_cycles();
             //daemon::debug('<== evet_base_loop() ending');
         }
     } elseif ($command == 'stop') {
         // cat pid, stop
     } elseif ($command == 'status') {
         // cat pid, show status
     } elseif ($command == 'restart') {
         //self::stop();
         //self::start();
     }
 }

开发者ID:ansendu，项目名称:ansio，代码行数:36，代码来源:Daemon.php

注：本文中的event_base_loop函数示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

PHP event_base_loopexit函数代码示例发布时间：2022-05-15

PHP event_add函数代码示例发布时间：2022-05-15

krishnaik06/Machine-Learning-in-90-days

1 theindianappguy/machine_learning_flutter

theindianappguy/machine_learning_flutter_app: Learn how to build a tensorflow mo

阅读：815|2022-08-18

2 samaxes/minify-maven-plugin: Combine and

samaxes/minify-maven-plugin: Combine and minimize JavaScript and CSS files for f

阅读：765|2022-08-16

3 挨打的读音是什么？是āi dǎ还是ái dǎ？

挨打的读音是什么?很多人在拼音的时候导致错误，这是因为挨为多音字，读i，还有读音ā

阅读：1061|2022-11-06

4 【小程序】小程序的循环遍历

js文件中数据: wxml 中读取数据：

阅读：785|2022-07-18

5 nacika-ins/nanachibot: nanachibot is Rus

nacika-ins/nanachibot: nanachibot is Rust based Mastodon bot client.

阅读：855|2022-08-18

6 CVE-2022-32284

Use of insufficiently random values vulnerability exists in Vnet/IP communicatio

阅读：800|2022-07-08

7 音速是多少公里每小时

日常中马赫是表示飞机速度的量词，马赫数一，即一倍音速，通常指天上飞行器的速度，如

阅读：553|2022-07-30

8 satoru-takeuchi/linux-in-practice

satoru-takeuchi/linux-in-practice

阅读：816|2022-08-15

9 doka-guide/content: Контент До

doka-guide/content: Контент Доки: статьи, картинки, д

阅读：738|2022-08-18

10 Matlab---读取 .txt文件

Matlab读取 .txt文件这里提供两种方法：1，load()函数。2，importdata()函数。一、

阅读：536|2022-07-18

客服电话

电子邮件

PHP event_base_loop函数代码示例

示例1: start

示例2: EpollSocketServer

示例3: __construct

示例4: start

示例5: run

示例6: loop

示例7: dispatch

示例8: loop

示例9: worker_callback

示例10: doRun

示例11: listen

示例12: run

示例13: listen

示例14: run

示例15: run

示例16: listen

示例17: run

示例18: libevent_serverAction

示例19: EpollSocketServer

示例20: init

请发表评论

全部评论

上一篇：

下一篇：

bradtraversy/iweather: Ionic 3 mobile we

joaomh/curso-de-matlab

断牙刷新位置时间（断牙属性及刷新位置介绍

Java小程序—录屏小程序(上半场)

rugk/mastodon-simplified-federation: Sim

krishnaik06/Machine-Learning-in-90-days

Matlab“错误使用mex以及received fatal al

armancodv/building-energy-model-matlab:

美元符号为什么是“$”

FGRibreau/import-tweets-to-mastodon: How

CVE-2022-32318

关于我们

产品与服务

解决方案

139-2527-9053