PHP event_base_loop函数代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› 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

librespeed/speedtest: Self-hosted Speedt

1 CVE-2022-33691

A possible race condition vulnerability in score driver prior to SMR Jul-2022 Re

阅读：534|2022-07-29

2 librespeed/speedtest: Self-hosted Speedt

librespeed/speedtest: Self-hosted Speedtest for HTML5 and more. Easy setup, exam

阅读：1274|2022-08-30

3 wtklbm/rust-library-i18n: Rust 核心库和

wtklbm/rust-library-i18n: Rust 核心库和标准库中文翻译，可作为 IDE 工具的智能提示

阅读：1233|2022-08-15

4 avehtari/BDA_m_demos: Bayesian Data Anal

avehtari/BDA_m_demos: Bayesian Data Analysis demos for Matlab/Octave

阅读：1186|2022-08-17

5 四维彩超怎么看性别？四维看男孩女孩诀窍

女人怀孕后，为了有一个健康聪明的宝宝，经历各种体检、筛查。其实这些体检和筛查中的

阅读：987|2022-11-06

6 medfreeman/markdown-it-toc-and-anchor: m

medfreeman/markdown-it-toc-and-anchor: markdown-it plugin to add a toc and ancho

阅读：1382|2022-08-18

7 sydney0zq/covid-19-detection: The implem

sydney0zq/covid-19-detection: The implementation of A Weakly-supervised Framewor

阅读：507|2022-08-16

8 世界上哪个国家离中国最远？

离中国最远的国家是阿根廷。从太平洋直线计算，即往东线走，北京到阿根廷的布宜诺斯艾

阅读：668|2022-11-06

9 shem8/MaterialLogin: Login view with mat

shem8/MaterialLogin: Login view with material design

阅读：749|2022-08-17

10 5-微信小程序列表渲染 wx:for

wx:for 在组件上使用amp;#160;wx:foramp;#160;控制属性绑定一个数组，即可使用数组中

阅读：500|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

请发表评论

全部评论

上一篇：

下一篇：

微信小程序之map地图使用

librespeed/speedtest: Self-hosted Speedt

CVE-2022-0167

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

librespeed/speedtest: Self-hosted Speedt

微信小程序wxs的简单应用

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

单的笔顺,解说单的笔画,详解单的部首

medfreeman/markdown-it-toc-and-anchor: m

关于我们

产品与服务

解决方案

139-2527-9053