🥇क्वार्कस और एएमक्यू ऑनलाइन का उपयोग करके रेड हैट ओपनशिफ्ट प्लेटफॉर्म पर क्लाउड-नेटिव मैसेजिंग

नमस्ते! यह यहाँ है - क्वार्कस श्रृंखला में हमारी अंतिम पोस्ट! (वैसे, हमारा वेबिनार देखें "यह क्वार्कस - कुबेरनेट्स मूल जावा फ्रेमवर्क है". हम आपको दिखाएंगे कि शुरुआत से कैसे शुरुआत करें या तैयार समाधान कैसे स्थानांतरित करें)

В पहले का इस पोस्ट में, हमने उन प्रासंगिक उपकरणों को देखा जिनका उपयोग जावा अनुप्रयोगों के आधुनिकीकरण के परिणामस्वरूप प्राप्त सुधारों को मापने के लिए किया जा सकता है।

संस्करण 0.17.0 के बाद से, क्वार्कस उन्नत संदेश कतारबद्ध प्रोटोकॉल के उपयोग का समर्थन करता है (एएमक्यूपी), जो एप्लिकेशन या संगठनों के बीच व्यावसायिक संदेशों को स्थानांतरित करने के लिए एक खुला मानक है।

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

यह माना जाता है कि आपने पहले ही ओपनशिफ्ट प्लेटफॉर्म पर एएमक्यू ऑनलाइन तैनात कर दिया है (यदि नहीं, तो देखें)। इंस्टालेशन गाइड).

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

एक बार एप्लिकेशन बनाने के बाद, हम आपको दिखाएंगे कि एप्लिकेशन में मैसेजिंग सिस्टम कॉन्फ़िगरेशन को कैसे एम्बेड किया जाए और सिस्टम पर हमारे लिए आवश्यक संसाधनों का प्रावधान करने के लिए एएमक्यू ऑनलाइन का उपयोग कैसे किया जाए।

क्वार्कस ऐप

हमारा क्वार्कस एप्लिकेशन ओपनशिफ्ट पर चलता है और प्रोग्राम का एक संशोधित संस्करण है एएमक्यूपी-क्विकस्टार्ट. ग्राहक पक्ष का एक पूरा उदाहरण पाया जा सकता है यहां.

जेनरेटर ऑर्डर करें

जनरेटर बस हर 5 सेकंड में बढ़ते ऑर्डर आईडी को "ऑर्डर" पते पर भेजता है।

@ApplicationScoped
public class OrderGenerator {
 
    private int orderId = 1;
 
    @Outgoing("orders")
    public Flowable<Integer> generate() {
        return Flowable.interval(5, TimeUnit.SECONDS)
        .map(tick -> orderId++);
    }
}

ऑर्डर प्रोसेसर

ऑर्डर हैंडलर और भी सरल है, यह केवल "पुष्टि" पते पर एक पुष्टिकरण आईडी लौटाता है।

@ApplicationScoped
public class OrderProcessor {
    @Incoming("orders")
    @Outgoing("confirmations")
    public Integer process(Integer order) {
        // Идентификатор подтверждения равен удвоенному идентификатору заказа <img draggable="false" class="emoji" alt=":-)" src="https://s.w.org/images/core/emoji/11.2.0/svg/1f642.svg">
        return order * 2;
    }
}

पुष्टिकरण संसाधन

पुष्टिकरण संसाधन हमारे एप्लिकेशन द्वारा उत्पन्न पुष्टिकरणों को सूचीबद्ध करने के लिए एक HTTP समापन बिंदु है।

@Path("/confirmations")
public class ConfirmationResource {
 
    @Inject
    @Stream("confirmations") Publisher<Integer> orders;
 
    @GET
    @Produces(MediaType.TEXT_PLAIN)
    public String hello() {
        return "hello";
    }
 
 
    @GET
    @Path("/stream")
    @Produces(MediaType.SERVER_SENT_EVENTS)
    public Publisher<Integer> stream() {
        return orders;
    }
}

समायोजन

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

कनेक्टर्स

एप्लिकेशन गुण फ़ाइल का उपयोग करके संकलन समय पर कनेक्टर कॉन्फ़िगरेशन प्रदान किया जा सकता है:

mp.messaging.outgoing.orders.connector=smallrye-amqp
mp.messaging.incoming.orders.connector=smallrye-amqp

चीजों को सरल रखने के लिए, हम केवल "ऑर्डर" पते के लिए एक संदेश कतार का उपयोग करेंगे। और हमारे एप्लिकेशन में "पुष्टिकरण" पता मेमोरी में एक कतार का उपयोग करेगा।

एएमक्यूपी समापन बिंदु

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

spec:
  template:
    spec:
      containers:
      - env:
        - name: AMQP_HOST
          valueFrom:
            configMapKeyRef:
              name: quarkus-config
              key: service.host
        - name: AMQP_PORT
          valueFrom:
            configMapKeyRef:
              name: quarkus-config
              key: service.port.amqp

साख

सेवा खाता टोकन का उपयोग ओपनशिफ्ट पर हमारे एप्लिकेशन को प्रमाणित करने के लिए किया जा सकता है। ऐसा करने के लिए, आपको पहले एक कस्टम कॉन्फ़िगसोर्स बनाना होगा जो पॉड के फ़ाइल सिस्टम से प्रमाणीकरण टोकन को पढ़ेगा:

public class MessagingCredentialsConfigSource implements ConfigSource {
    private static final Set<String> propertyNames;
 
    static {
        propertyNames = new HashSet<>();
        propertyNames.add("amqp-username");
        propertyNames.add("amqp-password");
    }
 
    @Override
    public Set<String> getPropertyNames() {
        return propertyNames;
    }
 
    @Override
    public Map<String, String> getProperties() {
        try {
            Map<String, String> properties = new HashMap<>();
            properties.put("amqp-username", "@@serviceaccount@@");
            properties.put("amqp-password", readTokenFromFile());
            return properties;
        } catch (IOException e) {
            throw new UncheckedIOException(e);
        }
    }
 
    @Override
    public String getValue(String key) {
        if ("amqp-username".equals(key)) {
            return "@@serviceaccount@@";
        }
        if ("amqp-password".equals(key)) {
            try {
                return readTokenFromFile();
            } catch (IOException e) {
                throw new UncheckedIOException(e);
            }
        }
        return null;
    }
 
    @Override
    public String getName() {
        return "messaging-credentials-config";
    }
 
    private static String readTokenFromFile() throws IOException {
        return new String(Files.readAllBytes(Paths.get("/var/run/secrets/kubernetes.io/serviceaccount/token")), StandardCharsets.UTF_8);
    }
}

एप्लिकेशन बनाएं और तैनात करें

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

फिर, वहां दिए गए निर्देशों का पालन करते हुए, आपको स्रोत डाउनलोड करना होगा, हमारा एप्लिकेशन बनाना और तैनात करना होगा:

git clone https://github.com/EnMasseProject/enmasse-example-clients
cd enmasse-example-clients/quarkus-example-client
oc new-project myapp
mvn -Pnative -Dfabric8.mode=openshift -Dfabric8.build.strategy=docker package fabric8:build fabric8:resource fabric8:apply

इन आदेशों के बाद, एप्लिकेशन तैनात किया जाएगा, लेकिन तब तक शुरू नहीं होगा जब तक हम एएमक्यू ऑनलाइन में आवश्यक मैसेजिंग संसाधनों को कॉन्फ़िगर नहीं कर लेते।

संदेश प्रणाली की स्थापना

अब जो कुछ बचा है वह उन संसाधनों को सेट करना है जिनकी हमारे एप्लिकेशन को मैसेजिंग सिस्टम में आवश्यकता है। ऐसा करने के लिए, आपको बनाने की आवश्यकता है: 1) मैसेजिंग सिस्टम एंडपॉइंट को आरंभ करने के लिए एक पता स्थान; 2) एप्लिकेशन में हमारे द्वारा उपयोग किए जाने वाले पतों को कॉन्फ़िगर करने के लिए पता; 3) क्लाइंट क्रेडेंशियल सेट करने के लिए उपयोगकर्ता को संदेश भेजना।

पता स्थान

एएमक्यू ऑनलाइन में एड्रेसस्पेस ऑब्जेक्ट पतों का एक समूह है जो कनेक्शन एंडपॉइंट और प्रमाणीकरण और प्राधिकरण नीतियों को साझा करता है। जब आप एक पता स्थान बनाते हैं, तो आप निर्दिष्ट कर सकते हैं कि मैसेजिंग एंडपॉइंट कैसे प्रदर्शित होंगे:

apiVersion: enmasse.io/v1beta1
kind: AddressSpace
metadata:
  name: quarkus-example
spec:
  type: brokered
  plan: brokered-single-broker
  endpoints:
  - name: messaging
    service: messaging
    exports:
    - name: quarkus-config
      kind: configmap

पता

पते का उपयोग संदेश भेजने और प्राप्त करने के लिए किया जाता है। प्रत्येक पते का एक प्रकार होता है, जो उसके शब्दार्थ को निर्धारित करता है, साथ ही एक योजना भी होती है, जो आरक्षित किए जाने वाले संसाधनों की संख्या निर्दिष्ट करती है। उदाहरण के लिए, पता इस प्रकार निर्धारित किया जा सकता है:

apiVersion: enmasse.io/v1beta1
kind: Address
metadata:
  name: quarkus-example.orders
spec:
  address: orders
  type: queue
  plan: brokered-queue

संदेश भेजने वाला उपयोगकर्ता

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

apiVersion: user.enmasse.io/v1beta1
kind: MessagingUser
metadata:
  name: quarkus-example.app
spec:
  username: system:serviceaccount:myapp:default
  authentication:
    type: serviceaccount
  authorization:
  - operations: ["send", "recv"]
    addresses: ["orders"]

एप्लिकेशन को कॉन्फ़िगर करने की अनुमतियां

एएमक्यू ऑनलाइन के लिए कॉन्फिगमैप बनाने के लिए जिसका उपयोग हमने एएमक्यूपी एंडपॉइंट जानकारी को एम्बेड करने के लिए किया था, भूमिका और रोलबाइंडिंग सेट की जानी चाहिए:

---
apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:
  name: quarkus-config
spec:
  rules:
  - apiGroups: [ "" ]
    resources: [ "configmaps" ]
    verbs: [ "create" ]
  - apiGroups: [ "" ]
    resources: [ "configmaps" ]
    resourceNames: [ "quarkus-config" ]
    verbs: [ "get", "update", "patch" ]
---
apiVersion: rbac.authorization.k8s.io/v1
kind: RoleBinding
metadata:
  name: quarkus-config
roleRef:
  apiGroup: rbac.authorization.k8s.io
  kind: Role
  name: quarkus-config
subjects:
- kind: ServiceAccount
  name: address-space-controller
  namespace: amq-online-infra

कॉन्फ़िगरेशन कैसे लागू करें

आप मैसेजिंग सिस्टम कॉन्फ़िगरेशन को इस तरह लागू कर सकते हैं:

cd enmasse-example-clients/quarkus-example-client
oc project myapp
oc apply -f src/main/resources/k8s/addressspace
oc apply -f src/main/resources/k8s/address

आवेदन सत्यापन

यह सुनिश्चित करने के लिए कि एप्लिकेशन शुरू हो गया है, सबसे पहले, आइए जांचें कि क्या संबंधित पते बनाए गए हैं और सक्रिय हैं:

until [[ `oc get address quarkus-example.prices -o jsonpath='{.status.phase}'` == "Active" ]]; do echo "Not yet ready"; sleep 5; done

तो फिर आइए एप्लिकेशन रूट यूआरएल की जांच करें (बस इस पते को ब्राउज़र में खोलें):

echo "http://$(oc get route quarkus-example-client -o jsonpath='{.spec.host}')/prices.html"

ब्राउज़र को यह दिखाना चाहिए कि टिकट समय-समय पर अपडेट किए जाते हैं क्योंकि संदेश एएमक्यू ऑनलाइन द्वारा भेजे और प्राप्त किए जाते हैं।

उपसंहार

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

यह क्वार्कस के बारे में श्रृंखला का समापन करता है, लेकिन आगे बहुत सी नई और दिलचस्प चीजें हैं, बने रहें!

स्रोत: www.habr.com

क्वार्कस और एएमक्यू ऑनलाइन का उपयोग करके रेड हैट ओपनशिफ्ट प्लेटफॉर्म पर क्लाउड-नेटिव मैसेजिंग