|
@@ -9,7 +9,8 @@ Workerman is a library for event-driven programming in PHP. It has a huge number
|
|
|
|
|
|
|
|
## Usage
|
|
## Usage
|
|
|
|
|
|
|
|
-create test.php
|
|
|
|
|
|
|
+### A tcp server
|
|
|
|
|
+test.php
|
|
|
```php
|
|
```php
|
|
|
require_once './Workerman/Autoloader.php';
|
|
require_once './Workerman/Autoloader.php';
|
|
|
use Workerman\Worker;
|
|
use Workerman\Worker;
|
|
@@ -25,7 +26,16 @@ $tcp_worker->onMessage = function($connection, $data)
|
|
|
$connection->send("hello $data \n");
|
|
$connection->send("hello $data \n");
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
-// #### another http worker ####
|
|
|
|
|
|
|
+Worker::runAll();
|
|
|
|
|
+```
|
|
|
|
|
+
|
|
|
|
|
+### A http server
|
|
|
|
|
+test.php
|
|
|
|
|
+```
|
|
|
|
|
+require_once './Workerman/Autoloader.php';
|
|
|
|
|
+use Workerman\Worker;
|
|
|
|
|
+
|
|
|
|
|
+// #### http worker ####
|
|
|
$http_worker = new Worker("http://0.0.0.0:2345");
|
|
$http_worker = new Worker("http://0.0.0.0:2345");
|
|
|
$http_worker->count = 4;
|
|
$http_worker->count = 4;
|
|
|
$http_worker->onMessage = function($connection, $data)
|
|
$http_worker->onMessage = function($connection, $data)
|
|
@@ -34,6 +44,15 @@ $http_worker->onMessage = function($connection, $data)
|
|
|
$connection->send("hello world \n");
|
|
$connection->send("hello world \n");
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
|
|
+// run all workers
|
|
|
|
|
+Worker::runAll();
|
|
|
|
|
+```
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+### websocket server
|
|
|
|
|
+```
|
|
|
|
|
+require_once './Workerman/Autoloader.php';
|
|
|
|
|
+use Workerman\Worker
|
|
|
// #### websocket worker ####
|
|
// #### websocket worker ####
|
|
|
$ws_worker = new Worker("websocket://0.0.0.0:5678");
|
|
$ws_worker = new Worker("websocket://0.0.0.0:5678");
|
|
|
$ws_worker->onMessage = function($connection, $data)
|
|
$ws_worker->onMessage = function($connection, $data)
|
|
@@ -66,5 +85,4 @@ php test.php reload
|
|
|
[jsonRpc](https://github.com/walkor/workerman-JsonRpc)
|
|
[jsonRpc](https://github.com/walkor/workerman-JsonRpc)
|
|
|
[thriftRpc](https://github.com/walkor/workerman-thrift)
|
|
[thriftRpc](https://github.com/walkor/workerman-thrift)
|
|
|
[web-msg-sender](https://github.com/walkor/web-msg-sender)
|
|
[web-msg-sender](https://github.com/walkor/web-msg-sender)
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
|
|
+[queue](https://github.com/walkor/workerman-queue)
|