consul php,go-micro+php+consul实现简单的微服务
首先我们用go-micro构建一个服务。(关于go-micro的使用可以参照官方实例或者文档)//新建一个微服务
micro new --type "srv" user-srv
定义我们的服务,这里定义两个rpc服务,Register和User// 修改proto
syntax = "proto3";
package go.micro.srv.user;
service User {
rpc Register(RegisterRequest) returns (UserInfo) {}
rpc User(UserInfoRequest) returns (UserInfo) {}
rpc Stream(StreamingRequest) returns (stream StreamingResponse) {}
rpc PingPong(stream Ping) returns (stream Pong) {}
}
message UserInfoRequest {
int64 userId = 1;
}
message RegisterRequest {
string username = 1;
string email = 2;
string password = 3;
}
message UserInfo {
int64 id = 1;
string username = 2;
string email = 3;
}
message StreamingRequest {
int64 count = 1;
}
message StreamingResponse {
int64 count = 1;
}
message Ping {
int64 stroke = 1;
}
message Pong {
int64 stroke = 1;
}
然后生成执行下面命令我们就可以发现在proto文件中多出两个文件。这个proto为我们生成的,后面会用到。protoc --proto_path=${GOPATH}/src:. --micro_out=. --go_out=. proto/user/user.proto
写我们的业务逻辑,修改handle/user.go文件type User struct{}
// Call is a single request handler called via client.Call or the generated client code
func (e *User) Register(ctx context.Context, req *user.RegisterRequest, rsp *user.UserInfo) error {
log.Log("Received User.Register request")
rsp.Id = 1
rsp.Email = req.Email
rsp.Username = req.Username
return nil
}
func (e *User) User(ctx context.Context, req *user.UserInfoRequest, rsp *user.UserInfo) error {
log.Log("Received User.Register request")
rsp.Id = 1
rsp.Email = "741001560@qq.com"
rsp.Username = "chensi"
return nil
}
// Stream is a server side stream handler called via client.Stream or the generated client code
func (e *User) Stream(ctx context.Context, req *user.StreamingRequest, stream user.User_StreamStream) error {
log.Logf("Received User.Stream request with count: %d", req.Count)
for i := 0; i < int(req.Count); i++ {
log.Logf("Responding: %d", i)
if err := stream.Send(&user.StreamingResponse{
Count: int64(i),
}); err != nil {
return err
}
}
return nil
}
// PingPong is a bidirectional stream handler called via client.Stream or the generated client code
func (e *User) PingPong(ctx context.Context, stream user.User_PingPongStream) error {
for {
req, err := stream.Recv()
if err != nil {
return err
}
log.Logf("Got ping %v", req.Stroke)
if err := stream.Send(&user.Pong{Stroke: req.Stroke}); err != nil {
return err
}
}
}
最后修改我们的main.go文件,服务发现使用时consul。func main() {
//initCfg()
// New Service
micReg := consul.NewRegistry()
service := micro.NewService(
micro.Server(s.NewServer()),
micro.Name("go.micro.srv.user"),
micro.Version("latest"),
micro.Registry(micReg),
)
// Initialise service
service.Init()
// Run service
if err := service.Run(); err != nil {
log.Fatal(err)
}
}
我们使用consul做微服务发现,当然首先你需要安装consulwget https://releases.hashicorp.com/consul/1.2.0/consul_1.6.1_linux_amd64.zip
unzip consul_1.6.1_linux_amd64.zip
mv consul /usr/local/bin/
启动consul的时候由于在是本地虚拟机上面,所以我们可以简单处理consul agent -dev -client 0.0.0.0 -ui
这时候可以启动consul的ui了,我本地vagrant的虚拟机192.168.10.100,那么我们打开的是http://192.168.10.100:8500/ui/dc1/services
启动user-srv的服务发现consul里面出现 go.micro.srv.user 的服务注册信息了
下面来写hyperf的代码了。按照官方文档安装框架,安装的时候rpc需要选择grpc,需要注意的是你的系统上面需要安装php7.2以上的版本,swoole版本也需要4.3的版本以上,我用的是最新homestead,所以相对而言安装这些依赖比较简单,所以在此强烈推荐。
第一次启动时候官方会要求修改一些php.ini的参数,大家安装要求走就是了。
这部分的流程自己参照官方文档,至于一些扩展的安装可以谷歌或者百度。
安装好框架之后再根目录下面新建一个grpc和proto的目录,把go-micro里面user.proto文件复制到hyperf项目的proto的目录之下。然后在目录下执行命令protoc --php_out=plugins=grpc:../grpc user.proto
执行成功之后会发现在grpc目录下多出两个文件夹。
接下来我们开始编写client的代码,在hyperf项目的app目录下新建一个Grpc的目录并且新建一个UserClient.php的文件namespace App\Grpc;
use Go\Micro\Srv\User\RegisterRequest;
use Go\Micro\Srv\User\UserInfo;
use Hyperf\GrpcClient\BaseClient;
class UserClient extends BaseClient
{
public function Register(RegisterRequest $argument)
{
return $this->simpleRequest(
'/user.User/Register',
$argument,
[UserInfo::class, 'decode']
);
}
关于这一块的代码,其实官方文档写得特别详细,具体可以参照官方文档。
新建一个路由
Router::addRoute(['GET', 'POST', 'HEAD'], '/grpc', 'App\Controller\IndexController@grpc');
编写控制器public function grpc ()
{
$client = new \App\Grpc\UserClient('127.0.0.1:9527', [
'credentials' => null,
]);
$request = new RegisterRequest();
$request->setEmail("741001560@qq.com");
$request->setUsername("chensi");
$request->setPassword("123456");
/**
* @var \Grpc\HiReply $reply
*/
list($reply, $status) = $client->Register($request);
$message = $reply->getId();
return [
'id' => $message
];
}
这时候还需要吧根目录下的grpc目录加载进来。修改composer.json文件```
// psr-4 下面新增两个行
"autoload": {
"psr-4": {
"App\\": "app/",
"GPBMetadata\\": "grpc/GPBMetadata",
"Go\\": "grpc/Go"
},
"files": []
}
然后执行composer dump-autoload命令。然后启动hyperf项目,打开浏览器输入http://192.168.10.100:9501/grpc回车,这时候我们就能看到结果了。
这时候我们会发现一个问题,那就是consul在client端压根没用到,在代码中我们还是需要指明我们的端口号。然后再看看官方文档其实是支持consul的,那么将代码改造下。
在app下新建一个Register的目录创建一个文件ConsulServices.php,然后开始编写服务发现的代码,安装consul包以后,由于官方提供的consul包没有文档所以需要自己去看源代码。官方在consul提供的api上面做了简单的封装,如KV、Health等,在实例化话的时候需要穿一个客户端过去。下面提供一个简单的实例。<?php
declare(strict_types=1);
namespace App\Register;
use Hyperf\Consul\Health;
use Psr\Container\ContainerInterface;
use Hyperf\Guzzle\ClientFactory;
class ConsulServices
{
public $servers;
private $container;
public function __construct(ContainerInterface $container)
{
$this->container = $container;
}
public function getServers()
{
$health = new Health(function () {
return $this->container->get(ClientFactory::class)->create([
'base_uri' => 'http://127.0.0.1:8500',
]);
});
$resp = $health->service("go.micro.srv.user");
$servers = $resp->json();
if (empty($servers)){
$this->servers = [];
}
foreach ($servers as $server) {
$this->servers[] = sprintf("%s:%d",$server['Service']['Address'],$server['Service']['Port']);
}
}
}
这时候发现一个问题如果每次请求过来都去请求一次必然给consul造成很大的负荷。既然用到了swoole框架可以在每次swoole启动的时候去请求一次,然后把服务发现的信息存起来。修改配置文件server。'callbacks' => [
// SwooleEvent::ON_BEFORE_START => [Hyperf\Framework\Bootstrap\ServerStartCallback::class, 'beforeStart'],
SwooleEvent::ON_BEFORE_START => [\App\Bootstrap\ServerStartCallback::class, 'beforeStart'],
SwooleEvent::ON_WORKER_START => [Hyperf\Framework\Bootstrap\WorkerStartCallback::class, 'onWorkerStart'],
SwooleEvent::ON_PIPE_MESSAGE => [Hyperf\Framework\Bootstrap\PipeMessageCallback::class, 'onPipeMessage'],
],
可以在ServerStartCallback类里面请求consul进行服务发现 后面拿到参数就好了。
namespace App\Bootstrap;
use App\Register\ConsulServices;
class ServerStartCallback
{
public function beforeStart()
{
$container = \Hyperf\Utils\ApplicationContext::getContainer();
$container->get(ConsulServices::class)->getServers();
}
}
改造一下原来的控制器public function grpc ()
{
$container = \Hyperf\Utils\ApplicationContext::getContainer();
$servers = $container->get(ConsulServices::class)->servers;
if (empty($servers)) {
return [
'errCode' => 1000,
'msg' => '服务不存在',
];
}
$key = array_rand($servers,1); // 哈哈哈一个简单的负载均衡
$hostname = $servers[$key];
$client = new \App\Grpc\UserClient($hostname, [
'credentials' => null,
]);
$request = new RegisterRequest();
$request->setEmail("741001560@qq.com");
$request->setUsername("chensi");
$request->setPassword("123456");
/**
* @var \Grpc\HiReply $reply
*/
list($reply, $status) = $client->Register($request);
$message = $reply->getId();
return [
'id' => $message
];
}
重启服务,这时候然后刷新浏览器试试。这时候一个简单基于go rpc server和php client的微服务就搭建完成了。当然了这时候还没有心跳机制,hyperf官网提供了一个定时器的功能,我们定时去刷服务发现就好了。
consul php,go-micro+php+consul实现简单的微服务相关推荐
- 构建简单的微服务架构
前言 本篇仅作引导,内容较多,如果阅读不方便,可以使用电脑打开我们的文档官网进行阅读.如下图所示: 文档官网地址:docs.xin-lai.com 目录 总体介绍 微服务架构的好处 微服务架 ...
- SpringCloud(第 002 篇)简单电影微服务类(消费方,而提供方为用户微服务)
2019独角兽企业重金招聘Python工程师标准>>> SpringCloud(第 002 篇)简单电影微服务类(消费方,而提供方为用户微服务) 一.大致介绍 微服务与微服务之间通过 ...
- SpringCloud(第 054 篇)简单 Quartz-Cluster 微服务,采用注解配置 Quartz 分布式集群...
2019独角兽企业重金招聘Python工程师标准>>> SpringCloud(第 054 篇)简单 Quartz-Cluster 微服务,采用注解配置 Quartz 分布式集群 一 ...
- SpringCloud(第 054 篇)简单 Quartz-Cluster 微服务,采用注解配置 Quartz 分布式集群... 1
SpringCloud(第 054 篇)简单 Quartz-Cluster 微服务,采用注解配置 Quartz 分布式集群 - 一.大致介绍 1.因网友提到有没有采用注解式配置的Quartz例子,因此 ...
- 利用SpringCloud搭建一个最简单的微服务框架
利用SpringCloud搭建一个最简单的微服务框架 https://blog.csdn.net/caicongyang/article/details/52974406 1.微服务 微服务主要包含服 ...
- springcloud五大组件?注解_spring cloud实现简单的微服务架构
"读书足以怡情,足以长才.读史使人明智,读诗使人灵秀,数学使人周密,科学使人深刻,伦理学使人庄重,过度学习使人疯魔:凡有所学,皆成性格." --弗朗西斯·培根<论学习> ...
- 一个简单的微服务项目带你上手spring cloud 全家桶
最近一个月,断断续续学习了spring cloud的主流微服务模块,然后实践了一个比较容易上手的微服务项目,现在做一个总结. 这个项目是在github上的一个比较经典的spring cloud易上手的 ...
- 按步搭建简单IoT微服务(2)
整体架构 这章节我们将为系统建立一个简单的前端界面.首先安装一些依赖环境并运行起来,按照下面的步骤开始: 如果还没有准备好,可以先在获取的代码仓库 micro-services-tutorial-io ...
- 按步搭建简单IoT微服务(3)
尝试目标4 现在序列化服务已经运行,可以添加模拟传感器和MQTT代理.模拟传感器的代码位于step4/services/sensor,代理程序代码位于step4/services/broker. 新的 ...
- 简单搭建微服务springCloudNetflix服务(一)
简单搭建微服务springCloudNetflix服务(一) 简单搭建微服务springCloudNetflix服务[添加ribbon中间件](二) 简单搭建微服务springCloudNetflix ...
最新文章
- 使用 GNU Libtool 创建库
- python 实现ping测试延迟的两种方法
- 路径中有中文怎么解决_时序路径分析
- linux脚本格式模板,Linux Shell 常见的命令行格式简明总结
- 如何实现把固定内容自动写入excel_Excel批量查找指定内容并导出
- sql 如何设置行级锁_如何使用SQL Server 2016行级安全性过滤和阻止数据访问
- C++小白课本练习3
- L1-002 打印沙漏 (20 分)—团体程序设计天梯赛
- 对象锁 区别 类锁
- 基于Java JAAS表单的身份验证
- [找规律] 三角形个数(牛客+找规律+思维+代码优化)
- 如何让iPhone桌面简洁又不俗气?
- android 处理闪屏
- programData
- Linux基础学习笔记(持续更新)
- python如何模拟微信扫码登录_python 微信扫码登录故障解决
- python毕业设计 招聘大数据分析可视化
- Ubuntu顶栏显示网速和硬件信息
- Matlab给图片加网格
- win10任务栏自动隐藏失效
热门文章
- 基于 OData 模型和 JSON 模型的 SAP UI5 表格控件行项目的添加和删除实现
- SAP Spartacus B2B 页面信息提示图标的弹出窗口显示实现逻辑
- 将网站SSL Server Certificate导入ABAP系统,证书Subject中文字符被转义引起的问题
- Angular应用启动时创建的injection token一览
- 使用Injection Token将字符串类型的参数注入到类的构造函数里
- Spring 中基于 AOP 的 XML操作方式
- SAP CRM 产品主数据搜索alternative ID type下拉菜单的渲染逻辑
- SAP Commerce Extension的Web应用启动问题
- SAP ERP里如何创建一个新的material类型
- when is backend date format set in Javascript DateFormat