Rated an average of 0 stars by 0 people

Php Application Server Based on Pthreads

Script Details:
Added on September 27, 2013 by naymin. Last modified September 27, 2013.
naymin accreditted the script to "http://appserver.io/."

Description:
Appserver.io is an open source project with the goal of creating a stable, scalable and high performance platform to provide PHP developers services that are needed in virtually all major projects. At this point of time it is possible to use the Servlet Engine (Webserver), the Persistence Container (Doctrine) and the MessageQueue. As the development is still in a very early stage, we do not recommend the usage on a live system. All Components are entirely developed with PHP and can be downloaded together with some example Applications (e. g. Magento CE) "https://github.com/techdivision". The components are also available as Composer bundle. Altogether this means that a developer can easily access the components, expand and adjust them if needed.

Tags: appserver, multi, php, thread

Instructions:
Https://dl.dropboxusercontent.com/s/n6foimfiyre20yk/Techtalk.pdf

Code:

find complete code at 
https://github.com/techdivision/TechDivision_ApplicationServer/tree/master/src/TechDivision/ApplicationServer

public techdivision/TechDivision_ApplicationServer

TechDivision_ApplicationServer / src / TechDivision / ApplicationServer / Server.php
wagnert a day ago
Add API

2 contributors
file 358 lines (316 sloc) 10.56 kb
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358     

<?php
# Snippet from PHP Share: http://www.phpshare.org

/** * TechDivisionApplicationServerServer * * NOTICE OF LICENSE * * This source file is subject to the Open Software License(OSL 3 . 0) * that is available through the world - wide - web at this URL: * http:// opensource . org / licenses / osl - 3 . 0 . php
*/
namespace TechDivisionApplicationServer;

use 
TechDivisionSocketClient;
use 
TechDivisionApplicationServerSplClassLoader;
use 
TechDivisionApplicationServerInitialContext;
use 
TechDivisionApplicationServerConfiguration;
use 
TechDivisionApplicationServerContainerThread;

/** * * @package TechDivisionApplicationServer * @copyright Copyright(c) 2010 < info@techdivision . com > -TechDivision GmbH * @license http:// opensource . org / licenses / osl - 3 . 0 . php * Open Software License(OSL 3 . 0) * @author Tim Wagner < tw@techdivision . com > */
class Server
{
    
/** * XPath expression
    for the container configurations . * * @var string
    */
    
const XPATH_CONTAINERS '/ appserver / containers / container';
    
    
/** * XPath expression
    for the container's base directory configuration . * * @var string
    */
    
const XPATH_BASE_DIRECTORY '/ appserver / baseDirectory';
    
    
/** * XPath expression
    for the initial context configuration . * * @var string
    */
    
const XPATH_INITIAL_CONTEXT '/ appserver / initialContext';
    
    
/** * XPath expression
    for the system logger configuration . * * @var string
    */
    
const XPATH_SYSTEM_LOGGER '/ appserver / systemLogger';
    
    
/** * Initialize the array
    for the running threads . * * @var array
    */
    
protected $threads = array();
    
    
/** * The container configuration . * * @var TechDivisionApplicationServerConfiguration
    */
    
protected $configuration;
    
    
/** * The server's initial context instance . * * @var TechDivisionApplicationServerInitialContext
    */
    
protected $initialContext;
    
    
/** * The server's logger instance . * * @var PsrLogLoggerInterface
    */
    
protected $systemLogger;
    
    
/** * The mutex toprevent PHAR deployment errors * * @var Mutex
    */
    
protected $mutex;
    
    
/** * Initializes the the server with the base directory . * * @param string $baseDirectory * The application servers base directory * @param string $configurationFile * The path to the configuration file relativ to the base directory * @return void
    */
    
public function __construct($configuration)
    {
        
// initialize the configuration and the base directory
        
$this->configuration $configuration;
        
        
// initialize the mutex to prevent PHAR deployment errors
        
$this->mutex Mutex:: create(false);
        
        
// initialize the server
        
$this->init();
    }
    
    
/** * Destroys the mutexes . * * @return void
    */
    
public function __destruct()
    {
        
Mutex:: unlock($this->mutex);
        
Mutex:: destroy($this->mutex);
    }
    
    
/** * Initialize's the server instance . * * @return void
    */
    
protected function init()
    {
        
$this->initInitialContext();
        
$this->initSystemLogger();
        
$this->initContainers();
    }
    
    
/** * Initialize the system logger . * * @return void
    */
    
protected function initSystemLogger()
    {
        
// initialize the logger instance itself
        
$systemLoggerConfiguration $this->getSystemLoggerConfiguration();
        
$this->systemLogger $this->newInstance($systemLoggerConfiguration->getType(), array($systemLoggerConfiguration->getChannelName()));
        
        
// initialize the processors
        
        
foreach ($systemLoggerConfiguration->getChilds('/ systemLogger / processors / processor') as $processorConfiguration)
        {
            
$params = array();
            
            if (
$processorConfiguration->getParams() != null)
            {
                foreach (
$processorConfiguration->getParams()->getChilds('/ params / param') as $param)
                {
                    
$value $param->getValue();
                    
settype($value$param->getType());
                    
$params[$param->getName()] = $value;
                }
            }
            
            
$processor $this->newInstance($processorConfiguration->getType(), $params);
            
$this->systemLogger->pushProcessor($processor);
        }
        
        
// initialize the handlers
        
        
foreach ($systemLoggerConfiguration->getChilds('/ systemLogger / handlers / handler') as $handlerConfiguration)
        {
            
$params = array();
            
            if (
$handlerConfiguration->getParams() != null)
            {
                foreach (
$handlerConfiguration->getParams()->getChilds('/ params / param') as $param)
                {
                    
$value $param->getValue();
                    
settype($value$param->getType());
                    
$params[$param->getName()] = $value;
                }
            }
            
            
$handler $this->newInstance($handlerConfiguration->getType(), $params);
            
            
// initialize the handlers formatter
            
$params = array();
            
$formatterConfiguration $handlerConfiguration->getFormatter();
            
            if (
$formatterConfiguration->getParams() != null)
            {
                foreach (
$formatterConfiguration->getParams()->getChilds('/ params / param') as $param)
                {
                    
$value $param->getValue();
                    
settype($value$param->getType());
                    
$params[$param->getName()] = $value;
                }
            }
            
            
// set the handlers formatter and add the handler to the logger
            
$handler->setFormatter($this->newInstance($formatterConfiguration->getType(), $params));
            
$this->systemLogger->pushHandler($handler);
        }
    }
    
    
/** * Initialize the initial context instance . * * @return void
    */
    
protected function initInitialContext()
    {
        
$reflectionClass = new ReflectionClass($this->getInitialContextConfiguration()->getType());
        
$this->initialContext $reflectionClass->newInstanceArgs(array($this->getInitialContextConfiguration()));
        
        
// add the system configuration to the initial context
        
$this->initialContext->setSystemConfiguration($this->configuration);
    }
    
    
/** * Initialize the container threads . * * @return void
    */
    
protected function initContainers()
    {
        
// start each container in his own thread
        
        
foreach ($this->getContainerConfiguration() as $containerConfiguration)
        {
            
// pass the base directory through to the container configuration
            
$containerConfiguration->addChild($this->getBaseDirectoryConfiguration());
            
            
// initialize the container configuration with the base directory and pass it to the thread
            
$params = array($this->getInitialContext(), $containerConfiguration$this->mutex);
            
            
$threadType $containerConfiguration->getThreadType();
            
$this->threads[] = $this->newInstance($threadType$params);
        }
    }
    
    
/** * Returns the running container threads . * * @return array < TechDivisionApplicationServerContainerThread > Array with the running container threads
    */
    
public function getThreads()
    {
        return 
$this->threads;
    }
    
    
/** * Returns the container configuration . * * @return TechDivisionApplicationServerConfiguration The container configuration
    */
    
public function getConfiguration()
    {
        return 
$this->configuration;
    }
    
    
/** * Returns the initial context instance . * * @return TechDivisionApplicationServerInitialContext The initial context instance
    */
    
public function getInitialContext()
    {
        return 
$this->initialContext;
    }
    
    
/** * Returns the server's base directory . * * @return string The server's base directory * @see TechDivisionApplicationServerServer:: getBaseDirectoryConfiguration()
        */
    
public function getBaseDirectory()
    {
        return 
$this->getBaseDirectoryConfiguration()->getValue();
    }
    
    
/** * Returns the server's base directory configuration . * * @return TechDivisionApplicationServerConfiguration The server's base directory configuration
    */
    
public function getBaseDirectoryConfiguration()
    {
        return 
$this->getConfiguration()->getChild(self:: XPATH_BASE_DIRECTORY);
    }
    
    
/** * Return's the initial context configuration . * * @return TechDivisionApplicationServerConfiguration The initial context configuration
    */
    
public function getInitialContextConfiguration()
    {
        return 
$this->getConfiguration()->getChild(self:: XPATH_INITIAL_CONTEXT);
    }
    
    
/** * Return's the system logger configuration . * * @return TechDivisionApplicationServerConfiguration The system logger configuration
    */
    
public function getSystemLoggerConfiguration()
    {
        return 
$this->getConfiguration()->getChild(self:: XPATH_SYSTEM_LOGGER);
    }
    
    
/** * Return's the container configuration . * * @return array < TechDivisionApplicationServerConfiguration > The container configuration
    */
    
public function getContainerConfiguration()
    {
        return 
$this->getConfiguration()->getChilds(self:: XPATH_CONTAINERS);
    }
    
    
/** * Return's the system logger instance . * * @return PsrLogLoggerInterface
    */
    
public function getSystemLogger()
    {
        return 
$this->systemLogger;
    }
    
    
/** * Start the container threads . * * @return void
    */
    
public function start()
    {
        foreach (
$this->getThreads() as $thread)
        {
            
$thread->start();
        }
        
        foreach (
$this->getThreads() as $thread)
        {
            
$thread->join();
        }
    }
    
    
/** * Returns a new instance of the passed class name . * * @param string $className * The fully qualified class name to return the instance
    for * @param array $args * Arguments to pass to the constructor of the instance * @return object The instance itself * @todo Has to be refactored to avoid registering autoloader on every call
    */
    
public function newInstance($className, array $args = array())
    {
        return 
$this->getInitialContext()->newInstance($className$args);
    }
}

 2013 GitHubInc Terms
Privacy
Security
Contact 
<?php
# Snippet from PHP Share: http://www.phpshare.org

?>

Review this PHP Script:

Rating:

Comments:


Login

User:
Pass:

Register

Not a member? Register today and receive the many free benefits of being a member!

Advertisements