StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POMulti-process php with libevent
text
Body
copied!<p>I am able to make a simple php websocket server with libevent , but I am stuck when I'm trying to make it multiprocessing.</p> <p>for example this is single processing </p> <pre><code><?php $socket = stream_socket_server ('tcp://0.0.0.0:2000', $errno, $errstr); stream_set_blocking($socket, 0); $base = event_base_new(); $event = event_new(); event_set($event, $socket, EV_READ | EV_PERSIST, 'ev_accept', $base); event_base_set($event, $base); event_add($event); event_base_loop($base); $GLOBALS['connections'] = array(); $GLOBALS['buffers'] = array(); function ev_accept($socket, $flag, $base) { static $id = 0; $connection = stream_socket_accept($socket); stream_set_blocking($connection, 0); $id += 1; $buffer = event_buffer_new($connection, 'ev_read', NULL, 'ev_error', $id); event_buffer_base_set($buffer, $base); event_buffer_timeout_set($buffer, 30, 30); event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff); event_buffer_priority_set($buffer, 10); event_buffer_enable($buffer, EV_READ | EV_PERSIST); // we need to save both buffer and connection outside $GLOBALS['connections'][$id] = $connection; $GLOBALS['buffers'][$id] = $buffer; } function ev_error($buffer, $error, $id) { event_buffer_disable($GLOBALS['buffers'][$id], EV_READ | EV_WRITE); event_buffer_free($GLOBALS['buffers'][$id]); fclose($GLOBALS['connections'][$id]); unset($GLOBALS['buffers'][$id], $GLOBALS['connections'][$id]); } function ev_read($buffer, $id) { while ($read = event_buffer_read($buffer, 256)) { var_dump($read); } } ?> </code></pre> <p>But when I do this in function ev_read </p> <pre><code> function ev_read($buffer, $id) { while ($read = event_buffer_read($buffer, 256)) { $pid = pcntl_fork(); switch ($pid) { case -1: // Error die('Fork failed, your system is b0rked!'); break; case 0: // Child event_buffer_write($buffer,"asdawdasd"); exit(0); break; } } } </code></pre> <p>it doesnt send the data...</p> <p>So how can I make a multiprocessing php socket server?</p>

Querying!

Guidance

An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload