从运行容器开始

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

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

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

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

declare(strict_types=1);

namespace App\JsonRpc;

interface MmsServiceInterface

{

public function mmsTest(string $cellPhone, int $code) :array ;

}

api 消费端配置

config/autoload/services.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接口文件

JsonRpc/TestServiceInterface.php

declare(strict_types=1);

namespace App\JsonRpc;

interface TestServiceInterface

{

public function test(int $a , int $b):array ;

}

JsonRpc/MmsServiceInterface.php

declare(strict_types=1);

namespace App\JsonRpc;

interface MmsServiceInterface

{

public function mmsTest(string $cellPhone, int $code) :array ;

}

控制其中调用

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

*/

namespace App\Controller;

use App\JsonRpc\MmsServiceInterface;

use App\JsonRpc\TestServiceInterface;

use Hyperf\HttpServer\Annotation\Controller;

use Hyperf\HttpServer\Annotation\GetMapping;

use Hyperf\Utils\ApplicationContext;

/**

* Class IndexController

* @package App\Controller

* @Controller(prefix="index")

*/

class IndexController extends AbstractController

{

/**

* @Author xue

* @DateTime 2020-08-25

* @GetMapping(path="testRpc")

*/

public function testRpc()

{

$orgClient = ApplicationContext::getContainer()->get(TestServiceInterface::class);

$data1 = $orgClient->test(1,2);

$mmsClient = ApplicationContext::getContainer()->get(MmsServiceInterface::class);

$data2 = $mmsClient->mmsTest('13681242210',1234);

$data[]=$data1;

$data[]=$data2;

return $data;

}

}

浏览器访问index/testRpc

输出:

[{"code":0,"data":"这是org服务提供者","params1":1,"params2":2},{"code":0,"data":"这是mms服务端","message":"电话号码是13681242210,验证码是1234"}]