yaangvu / php-eureka
Spring Cloud Eureka发现服务器的PHP客户端。
Requires
- php: ^8.0
- guzzlehttp/guzzle: ^7
Requires (Dev)
- phpunit/phpunit: ^7|^8
This package is auto-updated.
Last update: 2024-09-07 16:00:14 UTC
README
PHP客户端,用于(Spring Cloud) Netflix Eureka服务注册和发现。
安装
您可以使用Composer安装此包。
composer require "yaangvu/php-eureka"
文档
创建Eureka客户端
您需要做的第一件事是使用您自己的配置创建一个 EurekaClient
实例。
$client = new EurekaClient([ 'eurekaDefaultUrl' => 'https://:8761/eureka', 'hostName' => 'service.hamid.work', 'appName' => 'service', 'ip' => '127.0.0.1', 'port' => ['8080', true], 'homePageUrl' => 'https://:8080', 'statusPageUrl' => 'https://:8080/info', 'healthCheckUrl' => 'https://:8080/health' ]);
所有可用的配置如下:
eurekaDefaultUrl
(默认:https://:8761
);主机名
应用程序名称
IP地址
status
(默认:UP
)overriddenStatus
(默认:UNKNOWN
)端口号
securePort
(默认:['443', false]
)countryId
(默认:1
)dataCenterInfo
(默认:['com.netflix.appinfo.InstanceInfo$DefaultDataCenterInfo', 'MyOwn']
)主页URL
状态页URL
健康检查URL
vip地址
安全vip地址
heartbeatInterval
(默认:30
)discoveryStrategy
(默认:RandomStrategy
)实例提供者
您还可以在创建 EurekaClient
实例后更改配置,使用setter方法。
$client->getConfig()->setAppName("my-service");
操作
在创建 EurekaClient 实例后,将执行多个操作。
- 注册:将服务实例注册到 Eureka
$client->register();
- 注销:从 Eureka 注销服务实例
$client->deRegister();
- 心跳:向 Eureka 发送心跳,表示客户端正在运行(一次性心跳)
$client->heartbeat();
您可以使用 start()
方法注册实例并定期发送心跳。
$client->start();
使用此方法,首先您的服务将使用您提供的配置注册到 Eureka。然后,将根据 heartbeatInterval
配置值定期向 Eureka 发送心跳。此间隔时间可以像任何其他配置项一样更改。
$client->getConfig()->setHeartbeatInterval(60); // 60 seconds
显然,此方法应在 CLI 中使用。
- 服务发现:从 Eureka 获取服务的实例
$instance = $client->fetchInstance("the-service"); $homePageUrl = $instance->homePageUrl;
发现策略
当从 Eureka 获取服务的实例时,您可能会得到一个可用实例列表。您可以根据所需的负载均衡策略选择其中一个。例如,轮询或随机策略可能是您选择的对象。
目前,此库仅支持 RandomStrategy
,但是您可以通过实现 DiscoveryStrategy
接口的 getInstance()
方法来创建自定义策略。
class RoundRobinStrategy implements DiscoveryStrategy { public function getInstance($instances) { // return an instance } }
然后,您只需将您的自定义策略引入到 EurekaClient
实例中即可。
$client->getConfig()->setDiscoveryStrategy(new RoundRobinStrategy());
本地注册和缓存
失败是不可避免的,特别是在云原生应用程序中。因此,有时 Eureka 可能会因为故障而不可用。在这些情况下,我们应该有一个本地服务注册表来避免级联故障。
默认情况下,如果 Eureka 停止运行,则 fetchInstance()
方法失败,因此会抛出异常,并且应用程序无法继续工作。为了解决这个问题,您应该创建一个本地服务注册表。
有一个名为 InstanceProvider
的接口,您可以通过实现该接口的 getInstances()
方法并返回基于您理想逻辑的服务实例来使用它。
class MyProvider implements InstanceProvider { public function getInstances($appName) { // return cached instances of the service from the Redis } }
在此示例中,我们已将服务的实例缓存在 Redis 中,并在 Eureka 停止运行时加载它们。
创建您的自定义提供者后,只需将其添加到配置中即可使其工作
$client->getConfig()->setInstanceProvider(new MyProvider());
您的自定义提供者仅在Eureka服务不可用或响应不正常时被调用。
这就需要您做的全部。通过添加此功能,即使Eureka服务不可用,您的应用程序仍能继续工作。
为了缓存特定服务的所有可用实例,您可以调用fetchInstances()
方法,该方法从Eureka获取服务的所有实例。
$instances = $client->fetchInstances("the-service");
#从 https://github.com/piwvh/php-eureka
分支创建