service-demo-account
所属分类：微服务
开发工具：PHP
文件大小：0KB
下载次数：0
上传日期：2018-01-17 07:46:05
上 传 者：
sh-1993
说明： 微服务测试 - 账户中心微服务,
(Micro service test - account center micro service,)
文件列表:
.env.example (1499, 2018-01-16)
.htaccess (119, 2018-01-16)
LICENSE (1065, 2018-01-16)
RELEASENOTE.md (6320, 2018-01-16)
app/ (0, 2018-01-16)
app/DI.php (1736, 2018-01-16)
app/Sys.php (631, 2018-01-16)
app/biz/ (0, 2018-01-16)
app/biz/User.php (1167, 2018-01-16)
app/biz/User/ (0, 2018-01-16)
app/biz/User/Github.php (2866, 2018-01-16)
app/bootstrap.php (1081, 2018-01-16)
app/common/ (0, 2018-01-16)
app/common/Enums/ (0, 2018-01-16)
app/common/Enums/ErrorCode.php (1072, 2018-01-16)
app/config/ (0, 2018-01-16)
app/config/app.php (1567, 2018-01-16)
app/config/config.ini (638, 2018-01-16)
app/config/config.php (11734, 2018-01-16)
app/config/loader.php (1673, 2018-01-16)
app/config/routes/ (0, 2018-01-16)
app/config/routes/_auto.php (730, 2018-01-16)
app/config/routes/baidu.php (792, 2018-01-16)
app/config/routes/common.php (584, 2018-01-16)
app/config/routes/user.php (1727, 2018-01-16)
app/controllers/ (0, 2018-01-16)
app/controllers/AuthController.php (1137, 2018-01-16)
app/controllers/Baidu/ (0, 2018-01-16)
app/controllers/Baidu/IndexController.php (1098, 2018-01-16)
app/controllers/Baidu/TiebaController.php (619, 2018-01-16)
app/controllers/Common/ (0, 2018-01-16)
app/controllers/Common/ImageController.php (950, 2018-01-16)
app/controllers/Controller.php (1287, 2018-01-16)
app/controllers/IndexController.php (893, 2018-01-16)
app/controllers/Traits/ (0, 2018-01-16)
... ...
# PHALCON框架结构
[](https://packagist.org/packages/limingxinleo/phalcon-project)
[](https://packagist.org/packages/limingxinleo/phalcon-project)
[](https://packagist.org/packages/limingxinleo/phalcon-project)
[](https://packagist.org/packages/limingxinleo/phalcon-project)
[Phalcon 官网](https://docs.phalconphp.com/zh/latest/index.html)
[wiki](https://github.com/limingxinleo/simple-subcontrollers.phalcon/wiki)
## 安装
1. 安装项目
~~~
composer create-project limingxinleo/thrift-go-phalcon-project
~~~
2. 使用Composer安装Thrift扩展后，把go的扩展包拷贝到GOPATH中(或建立软连接)。
~~~
ln -s /your/path/to/thrift-go-phalcon-project/vendor/apache/thrift/lib/go/thrift thrift
~~~
3. 编译服务
- Go 使用 thrift -r --gen go:thrift_import=thrift App.thrift
- Php 使用 thrift -r --gen php:server,psr4 App.thrift
4. Go服务安装
~~~
从GO官网下载编译好的压缩包 例如 go1.8.3.linux-amd64.tar.gz
$ tar -xzf go1.8.3.linux-amd64.tar.gz
$ mv go /usr/local/go/1.8.3
$ vim /etc/profile
export GOROOT='/usr/local/go/1.8.3' # 没有文件夹则新建
export GOPATH='/usr/local/go/libs/' # 没有文件夹则新建
export PATH=$GOROOT/bin:$PATH
$ go get -u github.com/kardianos/govendor
$ cd /usr/local/go/libs/src/github.com/kardianos/govendor/
$ go build
$ cd /usr/local/bin
$ ln -s /usr/local/go/libs/src/github.com/kardianos/govendor/govendor govendor
~~~
## Go&Swoole RPC 服务
* Go
thrift/gen-go/main.go
~~~
# RPC服务注册方法
server.RegisterProcessor("app", service.NewAppProcessor(&impl.App{}));
~~~
* Swoole
app/tasks/Thrift/Service.php
~~~
$handler = new AppHandler();
$processor->registerProcessor('app', new AppProcessor($handler));
~~~
## 服务实现
* Swoole
app/thrift/Services/AppHandle.php
~~~php
config->version;
}
}
~~~
## 负载均衡
- Nginx Stream负载均衡已经十分强大了，自带健康检查。[TCP负载均衡](https://github.com/limingxinleo/note/blob/master/nginx/nginx.md#tcp负载均衡)
## 服务发现
1. 项目本人已内置基于Thrift的注册中心功能
- 已实现Swoole服务注册中心
- 已实现Go服务注册中心
2. 或者配合[注册中心](https://github.com/limingxinleo/service-registry-swoole-phalcon.git)一起使用
app/tasks/Thrift/ServiceTask.php
~~~
protected function beforeServerStart(swoole_server $server)
{
parent::beforeServerStart($server); // TODO: Change the autogenerated stub
// 增加服务注册心跳进程
$worker = new swoole_process(function (swoole_process $worker) {
$client = new swoole_client(SWOOLE_SOCK_TCP);
if (!$client->connect(env('REGISTRY_IP'), env('REGISTRY_PORT'), -1)) {
exit("connect failed. Error: {$client->errCode}\n");
}
swoole_timer_tick(5000, function () use ($client) {
$service = env('REGISTRY_SERVICE', 'github');
$data = [
'service' => $service,
'ip' => env('SERVICE_IP'),
'port' => env('SERVICE_PORT'),
'nonce' => time(),
'register' => true,
'sign' => 'xxx',
];
$client->send(json_encode($data));
$result = $client->recv();
$result = json_decode($result, true);
if ($result['success']) {
foreach ($result['services'] as $key => $item) {
Redis::hset($service, $key, json_encode($item));
}
}
});
});
$server->addProcess($worker);
}
~~~
## Thrift 数据类型
1. 基本类型（括号内为对应的Java类型）：
~~~
bool（boolean）: 布尔类型(TRUE or FALSE)
byte（byte）: 8位带符号整数
i16（short）: 16位带符号整数
i32（int）: 32位带符号整数
i64（long）: 64位带符号整数
double（double）: 64位浮点数
string（String）: 采用UTF-8编码的字符串
~~~
2. 特殊类型（括号内为对应的Java类型）
~~~
binary（ByteBuffer）：未经过编码的字节流
~~~
3. Structs（结构）：
~~~
struct UserProfile {
1: i32 uid,
2: string name,
3: string blurb
}
struct UserProfile {
1: i32 uid = 1,
2: string name = "User1",
3: string blurb
}
~~~
4. 容器，除了上面提到的基本数据类型，Thrift还支持以下容器类型：
> list(java.util.ArrayList)
> set(java.util.HashSet)
> map（java.util.HashMap）
~~~
struct Node {
1: i32 id,
2: string name,
3: list subNodeList,
4: map subNodeMap,
5: set subNodeSet
}
struct SubNode {
1: i32 uid,
2: string name,
3: i32 pid
}
struct Node {
1: i32 uid,
2: string name,
3: list subNodes
}
~~~
5. 服务
~~~
service UserStorage {
void store(1: UserProfile user),
UserProfile retrieve(1: i32 uid)
}
~~~
近期下载者：
相关文件：
收藏者：