在windows使用docker环境搭建hyperf微服务

创建hyperf项目环境

docker run -d --name hyperfrpc -v d/dataproject/hyperfrpc:/hyperf-skeleton -p 9501:9501 -it --entrypoint /bin/sh hyperf/hyperf:7.4-alpine-v3.11-swoole

参数解释：

-d 表示在后台运行

--name 表示给容器取个名字

-v 表示挂载到本机的目录

-p 表示映射到主机的端口，冒号前的是本机，后面是docker容器端口

-it 终端

--entrypoint 通过这个来覆盖dockerfile里定义的entrypoint

镜像容器运行后，然后进入容器中，在容器内安装 Composer

#下载composer.phar文件
wget https://github.com/composer/composer/releases/download/1.8.6/composer.phar
#给composer.phar文件加可执行权限
chmod u+x composer.phar
#移动该文件到/usr/local/bin/composer
mv composer.phar /usr/local/bin/composer

将 Composer 镜像设置为阿里云镜像，加速国内下载速度

composer config -g repo.packagist composer https://mirrors.aliyun.com/composer

通过 Composer 安装 hyperf/hyperf-skeleton 项目

composer create-project hyperf/hyperf-skeleton

进入安装好的 Hyperf 项目目录，linux目录

cd hyperf-skeleton

测试 Hyperf环境是否成功

php bin/hyperf.php start

在powshell打开一个cli

docker exec -it hyperfrpc /bin/bash

进行测试

curl 127.0.0.1:9501

看到输出

{"method":"GET","message":"Hello Hyperf."}

环境成功

在hyperf-skeleton目录下创建消费者和提供者

删除刚刚创建的hyperf项目

rm -rf hyperf-skeleton

创建provider

composer create-project hyperf/hyperf-skeleton hyperf-skeleton/provider

创建时，选项只选择一个JSON-PRC with Service Governance，其他都选n

创建consumer

cd hyperf-skeleton

cp -r provider consumer

随意使用一个编辑器然后打开项目，目录是你创建docker容器时挂载的地方，我们上面挂载了d/dataproject/hyperfrpc

我们可以在目录看到存在provider、consumer

编写provider

我们在app目录下创建一个文件夹，叫Rpc，在Rpc下创建CalculatorService和CalculatorServiceInterface

服务端口

CalculatorServiceInterface是服务接口

服务实现类

CalculatorService就是我们服务提供者的服务实现类,我们只需要服务实现类上添加注解@RpcService就可以将服务发布

name，给服务起个名字

protocol，使用的协议，这里一般使用jsonrpc-http

server，绑定的server

添加对应server

接下来，我们去config/autoload/server.php下，添加刚刚在注解@RpcService上写的server=“jsonrpc-http”的这个server

我们找到servers

然后发现已经存在一个name是http的server了，我们复制一个name是http的server，之后添加在http这个server的下面，然后修改一下

我们把name修改成jsonrpc-http

我们把port修改成9502

我们把callbacks修改一下，把HyperfHttpServerServer::class修改成HyperfJsonRpcHttpServer::class,如下面

'servers' => [
 [
 'name' => 'http',
 'type' => Server::SERVER_HTTP,
 'host' => '0.0.0.0',
 'port' => 9501,
 'sock_type' => SWOOLE_SOCK_TCP,
 'callbacks' => [
 Event::ON_REQUEST => [HyperfHttpServerServer::class, 'onRequest'],
 ],
 ],
 [
 'name' => 'jsonrpc-http',
 'type' => Server::SERVER_HTTP,
 'host' => '0.0.0.0',
 'port' => 9502,
 'sock_type' => SWOOLE_SOCK_TCP,
 'callbacks' => [
 Event::ON_REQUEST => [HyperfJsonRpcHttpServer::class, 'onRequest'],
 ],
 ],

编写consumer

我们就在consumer项目的controller调用一下刚刚写的CalculatorService把。

对应接口

在调用之前我们需要把服务接口从provider哪里复制一份过来

我们在consumer的app目录下创建Rpc目录，在Rpc目录下创建刚刚复制的CalculatorServiceInterface

使用controller调用

我们就在IndexController里面的index方法调用服务,但是现在还无法消费成功，我们还需要一些配置。

calculatorService->add(1,2);
 }
}
​

创建services的配置文件

我们需要去到/config/autoload目录下创建services.php文件，文件配置如下

[
 [
 'name'=>'CalculatorService',
 'service'=>CalculatorServiceInterface::class,
 'nodes'=>[
 ['host'=>'127.0.0.1','port'=>9502],
 ],
 ],
 ],
];

这个服务的name和我们编写注解的name是一致的

服务的service对应consumer的CalculatorServiceInterface，

由于我们没有使用注册中心，所以我们直接使用节点地址，对应上面代码中的nodes

修改consumer的启用端口

因为consumer复制过来的，所以我们需要修改一下端口

在/config/autoload下的server.php文件下

我们找到server，定位到name是http的server，将端口修改成9503

'servers' => [
 [
 'name' => 'http',
 'type' => Server::SERVER_HTTP,
 'host' => '0.0.0.0',
 'port' => 9503,
 'sock_type' => SWOOLE_SOCK_TCP,
 'callbacks' => [
 Event::ON_REQUEST => [HyperfHttpServerServer::class, 'onRequest'],
 ],
 ],
 ],

consumer编写完成

启动provider

进入终端

cd hyperf-skeleton/
cd provider/
php bin/hyperf.php start

启动consumer

cd hyperf-skeleton/
cd consumer/
php bin/hyperf.php start

发起请求

在打开一个终端

curl 127.0.0.1:9503

我们应该可以看到输出了

3

return [
 'uri' => 'http://127.0.0.1:8500',
 'token' => '',
];

#下载并解压consul
cd /opt/
​
mkdir consul
​
chmod 777 consul
​
cd consul
​
wget https://releases.hashicorp.com/consul/1.3.0/consul_1.3.0_linux_amd64.zip
​
unzip consul_1.3.0_linux_amd64.zip
​
cp consul /usr/local/bin/
​
#检查是否安装成功
consul
​
consul version
​
#启动consul服务
consul agent -dev -ui -node=consul-dev -client=127.0.0.1
​
​
#3.再开一个终端，输入查看8500端口
curl 127.0.0.1:8500
#看见Moved Permanently.就成功了

[
 [
 'name'=>'CalculatorService',
 'service'=>CalculatorServiceInterface::class,
 'registry'=>[
 'protocol'=>'consul',
 'address'=>'http://127.0.0.1:8500',
 ],
//            'nodes'=>[
//                ['host'=>'127.0.0.1','port'=>9502],
//            ],
 ],
 ],
];

CTRL+C
php bin/hyperf.php start

CTRL+C
php bin/hyperf.php start

curl 127.0.0.1:9503
#可以看到还是输出，我们已经把nodes注释了
3

"正常",
 ];
}
 public static function searchFallback()
 {
 return [
 'message'=>"流量过大，熔断",
 ];
 }
}

UserService->search();
 }
}

curl curl 127.0.0.1:9501/user/search
curl curl 127.0.0.1:9501/user/search
curl curl 127.0.0.1:9501/user/search

process()` 继续执行或者自行处理
 echo "限流中";
 return $proceedingJoinPoint->process();
 }
}