दूरस्थ प्रेक्षक

यदि परियोजना स्थानीय मशीन के दायरे से परे चली गई, तो सबसे अधिक संभावना है कि आपको कुछ तृतीय-पक्ष प्रणालियों के साथ एकीकृत करना होगा।

मैं उस मामले पर विचार करना चाहता हूं जब उल्लिखित बाहरी सिस्टम हमारे सिस्टम में किसी भी बदलाव की सूचना प्राप्त करना चाहता है। उदाहरण के लिए, उत्पाद कैटलॉग को अपडेट करना।

कार्य

एक ट्रेडिंग प्लेटफॉर्म है जो WEB सेवाओं के माध्यम से अपने उत्पाद आधार तक पहुंच प्रदान करता है। साइट के पार्टनर डेटाबेस में बदलाव के बारे में जल्द से जल्द जानना चाहते हैं।

समाधान का विकल्प

हम अपने सभी भागीदारों को जानते हैं, हम उनके सॉफ़्टवेयर के लिए दस्तावेज़ का अनुरोध कर सकते हैं।

आप हमारे भागीदारों के एपीआई के साथ काम को लागू कर सकते हैं, और उत्पाद सूची को बदलते समय, उन्हें सीधे सूचित कर सकते हैं।

इस दृष्टिकोण के साथ, प्रत्येक नए ग्राहक को व्यक्तिगत रूप से जुड़ना होगा। यदि भागीदार ने सॉफ़्टवेयर में कुछ बदल दिया है, तो कार्यक्षमता को पुनर्स्थापित करने के लिए संसाधनों की आवश्यकता होगी। सामान्य तौर पर, अतिरिक्त खर्च और जिम्मेदारी का एक अतिरिक्त क्षेत्र।

मैं वास्तव में ऐसे तंग संबंध स्थापित नहीं करना चाहता। इसलिए, हम निम्नलिखित करेंगे।

आइए आधार के रूप में "पर्यवेक्षक" पैटर्न लें। हमारे सहयोगी घटनाओं की सदस्यता लें और उन्हें आवश्यक सूचनाएं प्राप्त करें।

कार्यान्वयन

सदस्यता के रिकॉर्ड को कहीं रखा जाना चाहिए। डेवलपर के विवेक पर भंडारण का प्रकार बना रहेगा। विचार करें कि क्या संग्रहीत करने की आवश्यकता है।

• प्रतिस्पर्धा। कई प्रकार की घटनाएं हो सकती हैं और सभी को अलर्ट न भेजने के लिए, आपको यह जानना होगा कि किसने क्या सदस्यता ली है।
• URL. . HTTP- URL. , .
• . , ( , , ). , . - . .

, PHP.

, POST- URL. , b2b.api.my-soft.ru/event-subscription. URL event( ).

( Laravel):

public function subscribe()
{
    $request = $this->getRequest();
    $eventName = $request->input('event');
    $url = $request->input('callback');

    $validator = \Validator::make([
        'url' => $url,
        'event' => $eventName
    ], [
        'url' => 'url|required',
        'event' => 'required'
    ]);

    if ($validator->fails()) {
        throw new BadRequestHttpException($validator->errors()->first());
    }

    $repository = $this->getRepository();
    if (!$repository->eventAvailable($eventName)) {
        throw new BadRequestHttpException(trans('api.error.eventSubscription.wrongEvent'));
    }

    if (!$repository->canAddEvent($eventName)) {
        throw new BadRequestHttpException(trans('api.error.eventSubscription.maxCallbacks'));
    }

    $model = $repository->createModel([
        'client_id' => $request->attributes->get('client')->id,
        'event' => $eventName,
        'url' => $url
    ]);
    if ($repository->save($model)) {
        return $this->response($model);
    }
    throw new \Exception();
}

:

• ,
• ,
• ( canAddEvent)
• ,

.

. , . , .. . .

, , .

.

, , . , , .

, . .

$subscribersRepository->with(['event' => $event->getEventName()])->getActive()->each(function ($model) use ($event) {
    $this->dispatch(new \Commands\RemoteCallback(
        $model->id,
        $model->url,
        $event->getData()->toArray()
    ));
});

.

RemoteCallback :

public function handle(EventSubscriptionRepository $subscriptionRepository)
{
    $client = new \Guzzle\Http\Client();
    $res = $client->post($this->url, [], $this->data, ['connect_timeout' => 3, 'timeout' => 3]);
    try {
        if ($res->send()->getStatusCode() !== 200) {
            throw new \Exception();
        }
        $subscriptionRepository->dropErrors($this->subscriptionId);
    } catch (\Exception $e) {
        $subscriptionRepository->incrementError($this->subscriptionId);
    }
}

. POST- URL. , , .

. . HTTP != 200, . , 3 3 . , .

सदस्यता अनुरोध के प्रसंस्करण के दौरान, इस की संभावना की जाँच की जाती है (canAddEvent विधि)। यह कुछ भी हो सकता है, लेकिन मेरे मामले में श्रोताओं की संख्या की सीमा की जाँच की जाती है। प्रत्येक प्रकार के आयोजन के लिए 3 से अधिक नहीं।

इसके अलावा, निश्चित रूप से, ऐसे एपीआई तरीकों के साथ काम करने के लिए प्राधिकरण की आवश्यकता होती है।

वह मूल रूप से यह है। सबसे सरल विकल्प का वर्णन किया गया है। यदि आवश्यक हो, तो आप SOAP या सॉकेट कनेक्शन के लिए समर्थन जोड़ सकते हैं या ऐसा कुछ कर सकते हैं। और आपको संदेश को फिर से भेजने की आवश्यकता है यदि प्रतिक्रिया सफल नहीं थी।