आसान REST-आधारित ऑर्केस्ट्रेशन और वर्कफ़्लो इंजन के लिए कैमुंडा का उपयोग करना (कोई जावा नहीं)

नमस्ते, हबर! मैं आपके ध्यान में लेख का अनुवाद प्रस्तुत करता हूँ "कैमुंडा को उपयोग में आसान REST-आधारित ऑर्केस्ट्रेशन और वर्कफ़्लो इंजन के रूप में उपयोग करें (जावा को छुए बिना)" बर्नड रूकर द्वारा।

07.07.2020/XNUMX/XNUMX, अनुवाद लेख बर्नड रूकर

मैं अक्सर गैर-जावा लोगों के साथ माइक्रोसर्विस आर्किटेक्चर पर चर्चा करता हूं: C#, Node.JS/JavaScript डेवलपर्स, या गोलांग उत्साही। उन सभी को इस तथ्य का सामना करना पड़ता है कि उन्हें माइक्रोसर्विस आर्किटेक्चर में एक ऑर्केस्ट्रेशन इंजन या वर्कफ़्लो को अनुकूलित करने और ऑर्डर करने, टाइमआउट, सागा को संभालने और लेनदेन की भरपाई करने की क्षमता हासिल करने के लिए एक उपकरण की आवश्यकता होती है।

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

नहीं! वास्तव में, आप बिना किसी जावा ज्ञान के कैमुंडा को आसानी से चला सकते हैं और अपनी पसंद की किसी भी भाषा में कोड के लिए आर्किटेक्चर को कॉन्फ़िगर कर सकते हैं। इस लेख में हम देखेंगे:

• बुनियादी वास्तुकला;
• बाकी एपीआई;
• जावा के अलावा अन्य भाषाओं के लिए मौजूदा क्लाइंट लाइब्रेरी पर सलाह;
• C# और Node.JS का उपयोग करने का उदाहरण;
• कैमुंडा सर्वर (डॉकर या टॉमकैट) चलाने के तरीके।

आर्किटेक्चर

कैमुंडा जावा में लिखा गया है और इसे चलाने के लिए जावा वर्चुअल मशीन (JVM) की आवश्यकता होती है। कैमुंडा एक REST API प्रदान करता है जो आपको अपनी पसंद की किसी भी भाषा में लिखने और कैमुंडा के साथ REST का उपयोग करने की अनुमति देता है:

कैमुंडा में वर्कफ़्लो को BPMN में परिभाषित किया गया है, जो मूल रूप से एक XML फ़ाइल है। इसका उपयोग करके मॉडलिंग की जा सकती है कैमुंडा मॉडलर.

पूर्व-निर्मित डॉकर छवि के माध्यम से कैमुंडा चलाना

कैमुंडा को चलाने का सबसे आसान तरीका डॉकर का उपयोग करना है। कैमुंडा को चलाने के वैकल्पिक तरीकों का वर्णन इस आलेख में बाद में किया गया है।

इस मामले में, बस चलाएँ:

  docker run -d -p 8080:8080 camunda/camunda-bpm-platform:latest

आपको Linux, Java वर्चुअल मशीन या Tomcats के बारे में चिंता करने की ज़रूरत नहीं है। Dockerfiles और बुनियादी दस्तावेज (उदाहरण के लिए, आवश्यक डेटाबेस से जुड़ने के निर्देश) यहां उपलब्ध हैं Github.

यदि आप कैमुंडा एंटरप्राइज संस्करण चलाना चाहते हैं, तो आप आसानी से बदल सकते हैं Dockerfile.

हालाँकि, डॉकर का उपयोग करके कैमुंडा को चलाने का एक नकारात्मक पक्ष है: आपको टॉमकैट का एक संस्करण मिलेगा जिसमें हमेशा नवीनतम सुधार शामिल नहीं होते हैं। किसी तरह इससे निजात पाने के लिए, आप वांछित टॉमकैट वितरण के आधार पर स्वयं एक डॉकर छवि बना सकते हैं, जैसा कि इस उदाहरण में दिखाया गया है, या नीचे वर्णित समाधानों में से किसी एक का उपयोग कर सकते हैं।

एक प्रक्रिया मॉडल तैनात करना

आइए एक क्लासिक यात्रा बुकिंग के लिए सागा टेम्पलेट का उपयोग करके एक उदाहरण देखें जहां आप एक पंक्ति में तीन कार्रवाइयों को ट्रिगर करना चाहते हैं और बाद में विफलता के मामले में सफल कार्रवाइयों की क्षतिपूर्ति करना चाहते हैं। बीपीएमएन फॉर्म में प्रस्तुत, यह इस तरह दिखता है:

अब आप उपयोग कर सकते हैं प्रक्रिया मॉडल परिनियोजन के लिए REST API. मान लें कि आपने इसे Trip.bpmn के रूप में सहेजा है और कैमुंडा को डॉकर के माध्यम से चलाया है, इसलिए यह लोकलहोस्ट:8080 पर उपलब्ध था:

  curl -w "n" 
-H "Accept: application/json" 
-F "deployment-name=trip" 
-F "enable-duplicate-filtering=true" 
-F "deploy-changed-only=true" 
-F "[email protected]" 
http://localhost:8080/engine-rest/deployment/creat

अब आप दौड़ सकते हैं नए वर्कफ़्लो उदाहरण REST API का उपयोग करना और उस डेटा को पास करना जिसे आप वर्कफ़्लो इंस्टेंस वेरिएबल के रूप में देखना चाहते हैं:

  curl 
-H "Content-Type: application/json" 
-X POST 
-d '{"variables":{"someData" : {"value" : "someValue", "type": "String"}},"businessKey" : "12345"}}' 
http://localhost:8080/engine-rest/<!-- -->process-definition/key/<!-- -->FlowingTripBookingSaga<!-- -->/start

अगला दिलचस्प सवाल यह है कि कैमुंडा कार बुक करने जैसी प्रक्रियाओं को कैसे ट्रिगर करता है? कैमुंडा कुछ अंतर्निहित का उपयोग करके न केवल तुरंत सेवाओं (पुश-सिद्धांत) को कॉल कर सकता है कनेक्टर्स, लेकिन कार्य वस्तुओं को एक प्रकार की अंतर्निहित कतार में भी रखें। फिर कार्यकर्ता REST के माध्यम से कार्य आइटम प्राप्त कर सकता है, कार्य कर सकता है, और कैमुंडा (पुल-प्रिंसिपल) को पूरा होने की रिपोर्ट कर सकता है।

तो सबसे पहले आपको ये करना होगा फ़ेचएंडलॉक (चूंकि अन्य कर्मचारी सिस्टम को स्केल करने के लिए एक ही समय में कार्य प्राप्त कर सकते हैं):

  curl 
-H "Content-Type: application/json" 
-X POST 
-d <!-- -->'{"workerId":"worker123","maxTasks":1,"usePriority":true,"topics":[{"topicName": "reserve-car"}, "lockDuration": 10000, "variables": ["someData"]}]}'<!-- --> 
http://localhost:8080/engine-rest/external-task/fetchAndLock

फिर कैमुंडा को यह बताओ कार्यकर्ता ने अपना काम पूरा कर लिया है (ध्यान दें कि आपको पहले अनुरोध में प्राप्त बाहरी कार्य आईडी दर्ज करनी होगी):

  curl 
-H "Content-Type: application/json" 
-X POST 
-d <!-- -->'{"workerId":"worker123", "variables": {}}'<!-- --> 
http://localhost:8080/engine-rest/<!-- -->external-task/EXTERNAL_TASK_ID/complete

बस इतना ही - आपको अब तक किसी जावा की आवश्यकता नहीं पड़ी है, है ना? और यह आरंभ करने के लिए पर्याप्त है!

ग्राहक पुस्तकालय

किसी भी प्रोग्रामिंग भाषा में REST API को कॉल करना आसान है। जावास्क्रिप्ट में JQuery का उपयोग करके ऐसा करना सुविधाजनक है, और C# में आप System.Net.Http और Newtonsoft.Json का उपयोग कर सकते हैं। लेकिन इसमें समय लगेगा. तो आप बस कुछ क्लाइंट लाइब्रेरी का उपयोग कर सकते हैं।

वर्तमान में कई तैयार क्लाइंट लाइब्रेरी उपलब्ध हैं:

• जावास्क्रिप्ट: लिंक. कैमुंडा द्वारा समर्थित;
• जावा: लिंक. कैमुंडा द्वारा समर्थित;
• सी #:लिंक и लिंक. ये दोनों परियोजनाएं मध्यवर्ती स्थिति में हैं और वस्तुतः कोई गतिविधि नहीं है, लेकिन एक अच्छे शुरुआती बिंदु के रूप में काम कर सकती हैं;
• PHP: लिंक यह बहुत संपूर्ण लाइब्रेरी नहीं है और इसमें नवीनतम एपीआई परिवर्तन शामिल नहीं हैं, लेकिन मैं उन परियोजनाओं के बारे में जानता हूं जो इसका उपयोग करती हैं।

जावास्क्रिप्ट और जावा के अपवाद के साथ, क्लाइंट लाइब्रेरीज़ कैमुंडा उत्पाद का हिस्सा नहीं हैं। उनसे कैमुंडा की सभी REST API सुविधाओं का समर्थन करने की अपेक्षा न करें। सिर्फ इसलिए कि कोई लाइब्रेरी एक निश्चित सुविधा प्रदान नहीं करती है इसका मतलब यह नहीं है कि यह वहां नहीं है, हमेशा कैमुंडा रेस्ट एपीआई की जांच करें। विशिष्ट परियोजनाएं पुस्तकालयों को शुरुआती बिंदु और टेम्पलेट के रूप में उपयोग करती हैं।

सी# के साथ उदाहरण

उपरोक्त क्लाइंट लाइब्रेरी का उपयोग करके, हम बस लिख सकते हैं:

  var camunda = new CamundaEngineClient("http://localhost:8080/engine-rest/engine/default/", null, null);
  // Deploy the BPMN XML file from the resources
  camunda.RepositoryService.Deploy("trip-booking", new List<object> {
        FileParameter.FromManifestResource(Assembly.GetExecutingAssembly(), "FlowingTripBookingSaga.Models.FlowingTripBookingSaga.bpmn")
     });
  
  // Register workers
  registerWorker("reserve-car", externalTask => {
    // here you can do the real thing! Like a sysout :-)
    Console.WriteLine("Reserving car now...");
    camunda.ExternalTaskService.Complete(workerId, externalTask.Id);
  });
  registerWorker("cancel-car", externalTask => {
    Console.WriteLine("Cancelling car now...");
    camunda.ExternalTaskService.Complete(workerId, externalTask.Id);
  });
  registerWorker("book-hotel", externalTask => {
    Console.WriteLine("Reserving hotel now...");
    camunda.ExternalTaskService.Complete(workerId, externalTask.Id);
  });
  // Register more workers...
  
  StartPolling();
  
  string processInstanceId = camunda.BpmnWorkflowService.StartProcessInstance("FlowingTripBookingSaga", new Dictionary<string, object>()
    {
      {"someBookingData", "..." }
    });

पूर्ण कार्यशील स्रोत कोड ऑनलाइन पाया जा सकता है: लिंक. एक अन्य उदाहरण यहां उपलब्ध है लिंक.

Node.js के साथ उदाहरण

  var Workers = require('camunda-worker-node');
  var workers = Workers('http://localhost:8080/engine-rest', {
    workerId: 'some-worker-id'
  });
  
  workers.registerWorker('reserve-car', [ 'someData' ], function(context, callback) {
    var someNewData = context.variables.someData + " - added something";
    callback(null, {
      variables: {
        someNewData: someNewData
      }
    });
  });
  
  workers.shutdown();

अधिक जानकारी वेबसाइट पर पाई जा सकती है github.com

कैमुंडा शुरू करने के वैकल्पिक तरीके

"कैमुंडा स्टैंडअलोन वॉर" के साथ कस्टम डॉकर छवि

कैमुंडा से पूर्व-निर्मित डॉकर छवि के विकल्प के रूप में, आप स्वयं टॉमकैट तैयार कर सकते हैं (उदाहरण के लिए, आधिकारिक डॉकर टॉमकैट छवियों के आधार पर) और फिर कैमुंडा को तथाकथित WAR फ़ाइलों में से एक के रूप में कॉपी कर सकते हैं।

यदि आपके पास कई अतिरिक्त आवश्यकताएं हैं और आप जावा बिल्ड वातावरण को अनुकूलित कर सकते हैं, तो आप कैमुंडा स्टैंडअलोन युद्ध को भी कॉन्फ़िगर कर सकते हैं। इन उदाहरणों के अनुसार एक मेवेन बिल्ड सेट करें: बिल्ड युद्ध विन्यास के साथ मेवेन या असेंबली ओवरले के साथ मेवेन.

कैमुंडा टॉमकैट वितरण का शुभारंभ

दूसरा विकल्प केवल कैमुंडा टॉमकैट वितरण को डाउनलोड करना, उसे अनज़िप करना और चलाना है। ऐसा करने के लिए, आपको केवल अपने कंप्यूटर पर जावा रनटाइम एनवायरनमेंट (JRE) स्थापित करना होगा। यह आसानी से हो सकता है यहां से डाउनलोड करें.

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

टॉमकैट का उपयोग करके कैमुंडा चलाना

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

कैमुंडा को उत्पादन में लॉन्च करना

आमतौर पर, कैमुंडा को चलाने के लिए आपको कुछ अंतिम सेटअप करने की आवश्यकता होगी। कैमुंडा के पास दिशानिर्देश हैं जो इसका विस्तार से वर्णन करते हैं, लेकिन मैं इस लेख में उन पर ध्यान नहीं दूंगा - मैं सिर्फ एक उदाहरण दूंगा: वितरण का REST API डिफ़ॉल्ट रूप से प्रमाणीकरण के लिए कॉन्फ़िगर नहीं किया गया है। हो सकता है आप इसे बदलना चाहें.

संक्षेप

जैसा कि आपने देखा होगा, कैमुंडा के साथ शुरुआत करना बहुत आसान है, चाहे आप किसी भी भाषा का उपयोग करें। मुख्य बात यह है कि सभी संचार REST API के माध्यम से किया जाता है। इंस्टालेशन भी काफी सरल है, खासकर डॉकर का उपयोग करते समय।

स्रोत: www.habr.com