Merge pull request #6 from chuntaojun/develop

add polaris-php examples

Author: chuntaojun

.gitignore

@@ -40,4 +40,3 @@ tests/*/*.sh
 /php
 polaris.log
 build.sh
-polaris.yaml

doc/ApiDoc.md

@@ -0,0 +1,42 @@
+# QuickStart
+
+根据简单的 php socket 应用示例，演示 php 应用如何快速接入北极星。
+
+## 目录介绍
+
+> consumer
+
+php-client 端示例，负责发起 socket 请求。启动时先从北极星拉取一个对应 php-server 的服务地址并发起调用
+
+> provider
+
+php-server 端示例，负责处理 socket 请求。启动时进程1负责处理socket请求，进程2则进行服务实例的注册，并发送心跳维持
+实例的健康状态
+
+## 如何构建
+
+- 构建对应的 polaris-php 插件, [构建文档](../../doc/HowToBuild.md)
+
+## 如何使用
+
+### 创建服务
+
+预先通过北极星控制台创建对应的服务，如果是通过本地一键安装包的方式安装，直接在浏览器通过127.0.0.1:8091打开控制台。
+
+![create_service](./image/create_php_service.png)
+
+### 执行程序
+
+运行 php-server
+
+```shell
+cd provider
+php provider.php
+```
+
+运行 php-client
+
+```shell
+cd consumer
+php consumer.php
+```

example/README.md

@@ -0,0 +1,59 @@
+<?php
+$br = (php_sapi_name() == "cli")? "":"<br>";
+
+if(!extension_loaded('polaris')) {
+	dl('polaris.' . PHP_SHLIB_SUFFIX);
+}
+
+// 创建一个 polaris-client 实例
+$polaris = new PolarisClient(array(
+	"config_path" => "./polaris.yaml",
+	"log_dir" => "./"
+));
+
+$polaris -> InitConsumer();
+
+$get_req = array(
+	"namespace" => "default",
+	"service" => "polaris_php_test",
+
+);
+
+$res = $polaris->GetOneInstance($get_req, 5000, 1);
+
+$instances = $res["response"]["instances"];
+
+$address = $instances[0]['host'];
+$service_port = (int)$instances[0]["port"];
+
+// 创建并返回一个套接字（通讯节点）
+$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+if ($socket === false) {
+    echo "socket_create() failed, reason: ".socket_strerror(socket_last_error())."\n";
+} 
+
+echo "Attempting to connect to '$address' on port '$service_port'...";
+// 发起socket连接请求
+$result = socket_connect($socket, $address, $service_port);
+if($result === false) {
+    echo "socket_connect() failed, reason: ".socket_strerror(socket_last_error($socket))."\n";
+    exit(1);
+} else {
+    echo "Connect success. \n";
+}
+
+$input = "This is a message from client"."\n";
+
+// 向socket服务器发送消息
+socket_write($socket, $input, strlen($input));
+echo  "Client send success \n";
+
+echo "Reading response:\n";
+// 读取socket服务器发送的消息
+while ($out = socket_read($socket, 8192)) {
+    echo $out;
+}
+echo PHP_EOL;
+socket_close($socket); // 关闭socket连接
+
+?>

example/polaris_consumer.php

@@ -0,0 +1,4 @@
+global:
+  serverConnector:
+    addresses:
+      - 127.0.0.1:8091

example/polaris_provider.php

@@ -0,0 +1,4 @@
+global:
+  serverConnector:
+    addresses:
+      - 127.0.0.1:8091