首先我们用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做微服务发现,当然首先你需要安装consul
wget 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官网提供了一个定时器的功能,我们定时去刷服务发现就好了。
以上是go-micro+php+consul实现简单的微服务的详细内容。更多信息请关注PHP中文网其他相关文章!

使用数据库存储会话的主要优势包括持久性、可扩展性和安全性。1.持久性:即使服务器重启,会话数据也能保持不变。2.可扩展性:适用于分布式系统,确保会话数据在多服务器间同步。3.安全性:数据库提供加密存储,保护敏感信息。

在PHP中实现自定义会话处理可以通过实现SessionHandlerInterface接口来完成。具体步骤包括:1)创建实现SessionHandlerInterface的类,如CustomSessionHandler;2)重写接口中的方法(如open,close,read,write,destroy,gc)来定义会话数据的生命周期和存储方式;3)在PHP脚本中注册自定义会话处理器并启动会话。这样可以将数据存储在MySQL、Redis等介质中,提升性能、安全性和可扩展性。

SessionID是网络应用程序中用来跟踪用户会话状态的机制。1.它是一个随机生成的字符串,用于在用户与服务器之间的多次交互中保持用户的身份信息。2.服务器生成并通过cookie或URL参数发送给客户端,帮助在用户的多次请求中识别和关联这些请求。3.生成通常使用随机算法保证唯一性和不可预测性。4.在实际开发中,可以使用内存数据库如Redis来存储session数据,提升性能和安全性。

在无状态环境如API中管理会话可以通过使用JWT或cookies来实现。1.JWT适合无状态和可扩展性,但大数据时体积大。2.Cookies更传统且易实现,但需谨慎配置以确保安全性。

要保护应用免受与会话相关的XSS攻击,需采取以下措施:1.设置HttpOnly和Secure标志保护会话cookie。2.对所有用户输入进行输出编码。3.实施内容安全策略(CSP)限制脚本来源。通过这些策略,可以有效防护会话相关的XSS攻击,确保用户数据安全。

优化PHP会话性能的方法包括:1.延迟会话启动,2.使用数据库存储会话,3.压缩会话数据,4.管理会话生命周期,5.实现会话共享。这些策略能显着提升应用在高并发环境下的效率。

thesession.gc_maxlifetimesettinginphpdeterminesthelifespanofsessiondata,setInSeconds.1)它'sconfiguredinphp.iniorviaini_set().2)abalanceIsiseededeedeedeedeedeedeedto to to avoidperformance andununununununexpectedLogOgouts.3)

在PHP中,可以使用session_name()函数配置会话名称。具体步骤如下:1.使用session_name()函数设置会话名称,例如session_name("my_session")。2.在设置会话名称后,调用session_start()启动会话。配置会话名称可以避免多应用间的会话数据冲突,并增强安全性,但需注意会话名称的唯一性、安全性、长度和设置时机。


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热门文章

热工具

MinGW - 适用于 Windows 的极简 GNU
这个项目正在迁移到osdn.net/projects/mingw的过程中,你可以继续在那里关注我们。MinGW:GNU编译器集合(GCC)的本地Windows移植版本,可自由分发的导入库和用于构建本地Windows应用程序的头文件;包括对MSVC运行时的扩展,以支持C99功能。MinGW的所有软件都可以在64位Windows平台上运行。

mPDF
mPDF是一个PHP库,可以从UTF-8编码的HTML生成PDF文件。原作者Ian Back编写mPDF以从他的网站上“即时”输出PDF文件,并处理不同的语言。与原始脚本如HTML2FPDF相比,它的速度较慢,并且在使用Unicode字体时生成的文件较大,但支持CSS样式等,并进行了大量增强。支持几乎所有语言,包括RTL(阿拉伯语和希伯来语)和CJK(中日韩)。支持嵌套的块级元素(如P、DIV),

Dreamweaver Mac版
视觉化网页开发工具

PhpStorm Mac 版本
最新(2018.2.1 )专业的PHP集成开发工具

螳螂BT
Mantis是一个易于部署的基于Web的缺陷跟踪工具,用于帮助产品缺陷跟踪。它需要PHP、MySQL和一个Web服务器。请查看我们的演示和托管服务。