您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

consul服务注册（hyperf）

发布时间：2022-10-21 22:05:37编辑：雪饮阅读（）

启动consul服务

./consul agent -data-dir=./consul_data --server=true --ui=true --bind=0.0.0.0 --client=0.0.0.0 -bootstrap-expect=1

agent必须是第一个参数，后面参数目测应该是没有前后顺序。

--ui的作用是可以通过web管理界面访问

成功启动后访问地址如：

http://192.168.31.80:8500/

--bootstrap-expect ：期望的server节点数目，consul一直等到指定sever数目的时候才会引导整个集群

--bind：该地址用来在集群内部的通讯，集群内的所有节点到地址都必须是可达的，默认是0.0.0.0

--client：提供HTTP、DNS、RPC等服务，默认是127.0.0.1,不对外提供服务，如果需要则改成0.0.0.0

服务实例publishTo指向consul驱动

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

/**
 * Class UserService
 * @package App\JsonRpc
 * @RpcService(name="UserService", protocol="jsonrpc-http", server="jsonrpc-http",publishTo="consul")
 */
class UserService implements UserServiceInterface
{
    /**
     * @param string $name
     * @param string $gender
     * @return string
     */
    public function createUser(string $name, int $gender)
    {
        return "create from 192.168.31.80=> name:".$name.",gender:".$gender;
    }
}

config\autoload\services.php配置服务发现与服务注册及consul驱动配置

服务注册自然要配置，服务发现我的理解是如果本服务器节点也做为消费者时，需要开启服务发现，那么服务发现也就从consul驱动的配置中的uri中去发现服务。

配置示例如：

<?php
 return [
     //发布到服务中心配置开始
     'enable' => [
         'discovery' => true,
         'register' => true,
     ],
     'drivers' => [
         'consul' => [
             'uri' => 'http://127.0.0.1:8500',
             'token' => '',
         ],
     ],
 
     //消费者
     'consumers' => [
         [
             // name 需与服务提供者的 name 属性相同
             'name' => 'UserService',
             // 服务接口名，可选，默认值等于 name 配置的值，如果 name 直接定义为接口类则可忽略此行配置，如 name 为字符串则需要配置 service 对应到接口类
             'service' => \App\JsonRpc\UserServiceInterface::class,
             // 对应容器对象 ID，可选，默认值等于 service 配置的值，用来定义依赖注入的 key
             'id' => \App\JsonRpc\UserServiceInterface::class,
             // 服务提供者的服务协议，可选，默认值为 jsonrpc-http
             // 可选 jsonrpc-http jsonrpc jsonrpc-tcp-length-check
             'protocol' => 'jsonrpc-http',
             // 负载均衡算法，可选，默认值为 random
             'load_balancer' => 'random',
             // 这个消费者要从哪个服务中心获取节点信息，如不配置则不会从服务中心获取节点信息
            'registry' => [
                 'protocol' => 'consul',
                 'address' => 'http://127.0.0.1:8500',
             ],
             // 如果没有指定上面的 registry 配置，即为直接对指定的节点进行消费，通过下面的 nodes 参数来配置服务提供者的节点信息
             /*'nodes' => [
                 ['host' => '192.168.31.173', 'port' => 9600],
             ],*/
             // 配置项，会影响到 Packer 和 Transporter
             'options' => [
                 'connect_timeout' => 5.0,
                 'recv_timeout' => 5.0,
                 'settings' => [
                     // 根据协议不同，区分配置
                     'open_eof_split' => true,
                     'package_eof' => "\r\n",
                     // 'open_length_check' => true,
                     // 'package_length_type' => 'N',
                     // 'package_length_offset' => 0,
                     // 'package_body_offset' => 4,
                 ],
                 // 重试次数，默认值为 2，收包超时不进行重试。暂只支持 JsonRpcPoolTransporter
                 'retry_count' => 2,
                 // 重试间隔，毫秒
                 'retry_interval' => 100,
                 // 使用多路复用 RPC 时的心跳间隔，null 为不触发心跳
                 'heartbeat' => 30,
                 // 当使用 JsonRpcPoolTransporter 时会用到以下配置
                 'pool' => [
                     'min_connections' => 1,
                     'max_connections' => 32,
                     'connect_timeout' => 10.0,
                     'wait_timeout' => 3.0,
                     'heartbeat' => -1,
                     'max_idle_time' => 60.0,
                 ],
             ],
         ]
     ],
 ];