PHP माइक्रोसर्विस फ्रेमवर्क - Swoft 2.0.3 प्रकाशित

Swoft क्या है?

स्विफ्ट स्वोले एक्सटेंशन के आधार पर एक PHP माइक्रोसर्विस कोरटाइन फ्रेमवर्क है। गो की तरह, Swoft में एक अंतर्निहित coroutine वेब सर्वर और एक सामान्य coroutine क्लाइंट है और यह पारंपरिक PHP-FPM से स्वतंत्र मेमोरी में निवासी है। स्प्रिंग क्लाउड फ्रेमवर्क लचीले एनोटेशन, शक्तिशाली वैश्विक निर्भरता इंजेक्शन कंटेनर, व्यापक सेवा शासन, लचीला और शक्तिशाली एओपी, मानक पीएसआर विनिर्देश कार्यान्वयन और इसी तरह के समान गो भाषा संचालन हैं।

तीन वर्षों के संचय और दिशा अन्वेषण के माध्यम से, Swoft ने PHP दुनिया में स्प्रिंग क्लाउड को स्विफ्ट बनाया है, जो PHP के उच्च-प्रदर्शन ढांचे और माइक्रोसिस्टम्स प्रबंधन के लिए सबसे अच्छा विकल्प है।

सुरुचिपूर्ण सेवा शासन

Swoft आधिकारिक तौर पर अनुशंसा करता है कि व्यवसाय और सेवा शासन को अलग करने के लिए डेवलपर्स सर्विस मेश पैटर्न का उपयोग करते हैं, जैसे कि Istio / Envoy फ्रेमवर्क, लेकिन Swoft भी छोटे और मध्यम आकार के व्यवसायों के लिए माइक्रोसेर्वर घटकों का एक सेट प्रदान करता है ताकि वे जल्दी से माइक्रोसॉर्फ़िस का निर्माण कर सकें।

• सेवा पंजीकरण और खोज
• सेवा तोड़ने वाला
• सेवा सीमक
• कॉन्फ़िगरेशन केंद्र

सेवा पंजीकरण और खोज

सेवा पंजीकरण और खोज के लिए, यदि अन्य तृतीय पक्ष समान होते हैं, तो Swoft द्वारा प्रदान की गई Swoft -consul घटक की आवश्यकता होती है।

पंजीकरण और रद्दीकरण सेवाएं

SwooleEvent::START घटना के लिए सुनो, सेवा को पंजीकृत करें

 /** * Class RegisterServiceListener * * @since 2.0 * * @Listener(event=SwooleEvent::START) */ class RegisterServiceListener implements EventHandlerInterface { /** * @Inject() * * @var Agent */ private $agent; /** * @param EventInterface $event */ public function handle(EventInterface $event): void { /* @var HttpServer $httpServer */ $httpServer = $event->getTarget(); $service = [ // .... ]; $scheduler = Swoole\Coroutine\Scheduler(); $scheduler->add(function () use ($service) { // Register $this->agent->registerService($service); CLog::info('Swoft http register service success by consul!'); }); $scheduler->start(); } } 

SwooleEvent::SHUTDOWN ईवेंट के लिए सुनो, सेवा रद्द करें

 /** * Class DeregisterServiceListener * * @since 2.0 * * @Listener(SwooleEvent::SHUTDOWN) */ class DeregisterServiceListener implements EventHandlerInterface { /** * @Inject() * * @var Agent */ private $agent; /** * @param EventInterface $event */ public function handle(EventInterface $event): void { /* @var HttpServer $httpServer */ $httpServer = $event->getTarget(); $scheduler = Swoole\Coroutine\Scheduler(); $scheduler->add(function () use ($httpServer) { $this->agent->deregisterService('swoft'); }); $scheduler->start(); } } 

 /** * Class RpcProvider * * @since 2.0 * * @Bean() */ class RpcProvider implements ProviderInterface { /** * @Inject() * * @var Agent */ private $agent; /** * @param Client $client * * @return array * @example * [ * 'host:port' * ] */ public function getList(Client $client): array { // Get health service from consul $services = $this->agent->services(); $services = [ ]; return $services; } } 

 return [ 'user' => [ 'class' => ServiceClient::class, 'provider' => bean(RpcProvider::class) // ... ] ]; 

 /** * Class BreakerLogic * * @since 2.0 * * @Bean() */ class BreakerLogic { /** * @Breaker(fallback="funcFallback") * * @return string * @throws Exception */ public function func(): string { // Do something throw new Exception('Breaker exception'); } /** * @return string */ public function funcFallback(): string { return 'funcFallback'; } } 

 /** * Class LimiterController * * @since 2.0 * * @Controller(prefix="limiter") */ class LimiterController { /** * @RequestMapping() * @RateLimiter(key="request.getUriPath()", fallback="limiterFallback") * * @param Request $request * * @return array */ public function requestLimiter(Request $request): array { $uri = $request->getUriPath(); return ['requestLimiter', $uri]; } /** * @param Request $request * * @return array */ public function limiterFallback(Request $request): array { $uri = $request->getUriPath(); return ['limiterFallback', $uri]; } } 

 /** * Class AgentCommand * * @since 2.0 * * @Command("agent") */ class AgentCommand { /** * @Inject() * * @var Config */ private $config; /** * @CommandMapping(name="index") */ public function index(): void { $namespaces = [ 'application' ]; while (true) { try { $this->config->listen($namespaces, [$this, 'updateConfigFile']); } catch (Throwable $e) { CLog::error('Config agent fail(%s %s %d)!', $e->getMessage(), $e->getFile(), $e->getLine()); } } } /** * @param array $data * * @throws ContainerException * @throws ReflectionException */ public function updateConfigFile(array $data): void { foreach ($data as $namespace => $namespaceData) { $configFile = sprintf('@config/%s.php', $namespace); $configKVs = $namespaceData['configurations'] ?? ''; $content = '<?php return ' . var_export($configKVs, true) . ';'; Co::writeFile(alias($configFile), $content, FILE_NO_DEFAULT_CONTEXT); CLog::info('Apollo update success！'); /** @var HttpServer $server */ $server = bean('httpServer'); $server->restart(); } } } 

 php bin/swoft agent:index