Hyperf使用docker-compose集群部署

从运行容器开始

docker run -v /www:/www -p 9601:9601 -p 9602:9602 -p 9603:9603 -it --entrypoint /bin/sh hyperf/hyperf:latest

# 镜像容器运行后，在容器内安装 Composer
wget https://github.com/composer/composer/releases/download/1.8.6/composer.phar
chmod u+x composer.phar
mv composer.phar /usr/local/bin/composer
# 将 Composer 镜像设置为阿里云镜像，加速国内下载速度
composer config -g repo.packagist composer https://mirrors.aliyun.com/composer

$ cd /www

# 通过 Composer 安装 hyperf/hyperf-skeleton 项目
composer create-project hyperf/hyperf-skeleton  api
composer create-project hyperf/hyperf-skeleton  org
composer create-project hyperf/hyperf-skeleton  mms

在每个项目根目录里面都安装watch，这是热加载组件

wget -O watch https://gitee.com/hanicc/hyperf-watch/raw/master/watch

使用docker-compose启动

1、在宿主机的www目录下创建一个docker-compose目录，该目录用于存放相关的docker-compose和dockerfile文件

ps：这里不一定要在www目录下，但是换了其他目录的时候执行docker—compose -f 后面要带路径

2、在docker-compose目录下分别创建三个文件夹api、org、mms，这三个文件夹存储对应项目的dockerfile，内容如下：

FROM hyperf/hyperf

WORKDIR /www
#CMD ["php","bin/hyperf.php","start"]
CMD php watch -c

因为使用的都是同个镜像，所以内容都一样

3、边写docker-compose.yml

version: '2'
networks:
  dev_yes:
services:
  api:
    build:
      context: ./api
      dockerfile: dockerfile
    ports:
      - "9601:9601"
    volumes:
      - /www/api:/www
    networks:
      - dev_yes
  mms:
    build:
      context: ./mms
      dockerfile: dockerfile
    ports:
      - "9602:9602"
    volumes:
      - /www/mms:/www
    networks:
      - dev_yes
  org:
    build:
      context: ./org
      dockerfile: dockerfile
    ports:
      - "9603:9603"
    volumes:
      - /www/org:/www
    networks:
      - dev_yes

在宿主机执行一下命令，启动服务

docker-compose -f /www/docker-compose/docker-compose.yml up

至此服务开启成功！

但是不知道为什么这里的watch热加载组件没有成功~~~

配置服务之间的通讯

api作为消费端

org和mms作为服务端

配置如下：

org服务端

先配置

config/autoload/server.php

'servers' => [
        [
            'name' => 'jsonrpc',
            'type' => Server::SERVER_BASE,
            'host' => '0.0.0.0',
            'port' => 9603,
            'sock_type' => SWOOLE_SOCK_TCP,
            'callbacks' => [
                SwooleEvent::ON_RECEIVE => [Hyperf\JsonRpc\TcpServer::class, 'onReceive'],
            ],
        ],
]

修改.env

APP_NAME=org

定义服务提供者和定义接口文件

JsonRpc/TestService.php

<?php

declare(strict_types=1);
namespace App\JsonRpc;
use Hyperf\RpcServer\Annotation\RpcService;

/**
 * Class TestService
 * @package App\JsonRpc
 * @RpcService(name="TestService",protocol="jsonrpc",server="jsonrpc")
 */
class TestService implements TestServiceInterface
{
    public function test(int $a , int $b) :array
    {
        return ['code'=>0,'data'=>'这是org服务提供者','params1'=>$a,'params2'=>$b];
    }
}

JsonRpc/TestServiceInterface.php

<?php
declare(strict_types=1);
namespace App\JsonRpc;


interface TestServiceInterface
{
    public function test(int $a , int $b):array ;
}

mms服务端

config/autoload/server.php

'servers' => [
        [
            'name' => 'jsonrpc',
            'type' => Server::SERVER_BASE,
            'host' => '0.0.0.0',
            'port' => 9602,
            'sock_type' => SWOOLE_SOCK_TCP,
            'callbacks' => [
                SwooleEvent::ON_RECEIVE => [Hyperf\JsonRpc\TcpServer::class, 'onReceive'],
            ],
        ],
]

修改.env

APP_NAME=mms

定义服务提供者和定义接口文件

JsonRpc/MmsService.php

<?php
declare(strict_types=1);
namespace App\JsonRpc;
use Hyperf\RpcServer\Annotation\RpcService;

/**
 * Class MmsServeice
 * @package App\JsonRpc
 * @RpcService(name="MmsService",protocol="jsonrpc",server="jsonrpc")
 */
class MmsService implements MmsServiceInterface
{
    public function mmsTest(string $cellPhone,int $code) :array
    {
        return ['code'=>0,'data'=>'这是mms服务端','message'=>'电话号码是'.$cellPhone.',验证码是'.$code];
    }
}

JsonRpc/MmsServiceInterface.php

<?php
declare(strict_types=1);
namespace App\JsonRpc;

interface MmsServiceInterface
{
    public function mmsTest(string $cellPhone, int $code) :array ;
}

api 消费端配置

config/autoload/services.php

<?php

declare(strict_types=1);
/**
 * This file is part of Hyperf.
 *
 * @link     https://www.hyperf.io
 * @document https://doc.hyperf.io
 * @contact  group@hyperf.io
 * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
 */
return [
    'consumers' => value(function (){
        $services = [
            'TestService'=>['service'=>\App\JsonRpc\TestServiceInterface::class,'host'=>'org','port'=>9603],
            'MmsService'=>['service'=>\App\JsonRpc\MmsServiceInterface::class,'host'=>'mms','port'=>9602],
        ];
        $consumers =[];
        foreach ($services as $name => $value){
            $consumers[] = [
                'name' => $name,
                'service' => $value['service'],
                'protocol' => 'jsonrpc',
                'load_balancer' => 'random',
                'nodes' => [
                    ['host' => $value['host'], 'port' => $value['port']],
                ],
            ];
        }
        return $consumers;
    })
];

定义org和mms接口文件