Quarkus आणि AMQ ऑनलाइन वापरून Red Hat OpenShift प्लॅटफॉर्मवर क्लाउड-नेटिव्ह मेसेजिंग

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

В मागील या पोस्टमध्ये, आम्ही जावा ऍप्लिकेशन्सच्या आधुनिकीकरणाच्या परिणामी प्राप्त झालेल्या सुधारणांचे प्रमाण मोजण्यासाठी वापरल्या जाणार्‍या संबंधित साधनांकडे पाहिले.

आवृत्ती 0.17.0 पासून, क्वार्कस प्रगत संदेश क्यूइंग प्रोटोकॉल (एमक्यूपी), जे ऍप्लिकेशन्स किंवा संस्थांमधील व्यवसाय संदेश हस्तांतरित करण्यासाठी खुले मानक आहे.

Red Hat AMQ ऑनलाइन ओपन सोर्स प्रोजेक्टच्या आधारे तयार केलेली सेवा आहे EnMasse आणि प्लॅटफॉर्म-आधारित मेसेजिंग यंत्रणा कार्यान्वित करणे रेड हॅट ओपनशिफ्ट. ते कसे कार्य करते याबद्दल अधिक तपशीलांसाठी, पहा येथे (EN). आज आम्‍ही तुम्‍हाला दोन नवीन मेसेजिंग तंत्रज्ञान वापरून आधुनिक OpenShift-आधारित मेसेजिंग सिस्‍टम तयार करण्‍यासाठी AMQ ऑनलाइन आणि Quarkus कसे एकत्र करायचे ते दाखवू.

असे गृहीत धरले जाते की तुम्ही आधीच ओपनशिफ्ट प्लॅटफॉर्मवर AMQ ऑनलाइन तैनात केले आहे (जर नसेल, तर पहा स्थापना मार्गदर्शक).

प्रारंभ करण्यासाठी, आम्ही एक क्वार्कस ऍप्लिकेशन तयार करू जो रिऍक्टिव्ह मेसेजिंग वापरून एक सोपी ऑर्डर प्रोसेसिंग सिस्टम असेल. या ऍप्लिकेशनमध्ये ऑर्डर जनरेटरचा समावेश असेल जो एका ठराविक अंतराने संदेश रांगेत ऑर्डर पाठवतो, तसेच ऑर्डर प्रोसेसर जो रांगेतील संदेशांवर प्रक्रिया करेल आणि ब्राउझरमध्ये पाहण्यायोग्य पुष्टीकरणे जनरेट करेल.

एकदा आम्‍ही अॅप्लिकेशन तयार केल्‍यावर, अॅप्लिकेशनमध्‍ये मेसेजिंग सिस्‍टम कॉन्फिगरेशन कसे एम्‍बेड करायचे आणि आम्‍हाला सिस्‍टीमवर आवश्‍यक संसाधनांची तरतूद करण्‍यासाठी AMQ ऑनलाइन कसे वापरायचे ते आम्‍ही दाखवू.

क्वार्कस अॅप

आमचा Quarkus ऍप्लिकेशन OpenShift वर चालतो आणि प्रोग्रामची सुधारित आवृत्ती आहे amqp-क्विकस्टार्ट. क्लायंटच्या बाजूचे संपूर्ण उदाहरण आढळू शकते येथे.

ऑर्डर जनरेटर

जनरेटर दर 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;
    }
}

समायोजन

AMQ ऑनलाइनशी कनेक्ट होण्यासाठी, आमच्या ऍप्लिकेशनला काही कॉन्फिगरेशन डेटाची आवश्यकता असेल, म्हणजे: Quarkus कनेक्टर कॉन्फिगरेशन, AMQP एंडपॉइंट माहिती आणि क्लायंट क्रेडेन्शियल. अर्थातच, सर्व कॉन्फिगरेशन डेटा एकाच ठिकाणी ठेवणे चांगले आहे, परंतु क्वार्कस ऍप्लिकेशन कॉन्फिगर करण्यासाठी संभाव्य पर्याय दर्शविण्यासाठी आम्ही ते मुद्दाम वेगळे करू.

कनेक्टर्स

अनुप्रयोग गुणधर्म फाइल वापरून संकलित वेळी कनेक्टर कॉन्फिगरेशन प्रदान केले जाऊ शकते:

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

गोष्टी सोप्या ठेवण्यासाठी, आम्ही फक्त "ऑर्डर" पत्त्यासाठी संदेश रांग वापरू. आणि आमच्या अनुप्रयोगातील "पुष्टीकरण" पत्ता मेमरीमध्ये रांग वापरेल.

AMQP एंडपॉइंट

संकलित करताना, AMQP एंडपॉइंटसाठी होस्टनाव आणि पोर्ट क्रमांक अज्ञात आहे, म्हणून ते इंजेक्ट केले जाणे आवश्यक आहे. AMQ ऑनलाइन द्वारे तयार केलेल्या कॉन्फिगमॅपमध्ये एंडपॉइंट सेट केला जाऊ शकतो, म्हणून आम्ही त्यांना ऍप्लिकेशन मॅनिफेस्टमधील पर्यावरणीय चलांद्वारे परिभाषित करू:

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

श्रेय

सेवा खाते टोकनचा उपयोग OpenShift वर आमचा अर्ज प्रमाणित करण्यासाठी केला जाऊ शकतो. हे करण्यासाठी, तुम्ही प्रथम एक सानुकूल कॉन्फिगसोर्स तयार करणे आवश्यक आहे जे पॉडच्या फाइल सिस्टममधून प्रमाणीकरण टोकन वाचेल:

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

या आदेशांनंतर, अनुप्रयोग उपयोजित केला जाईल, परंतु जोपर्यंत आम्ही AMQ ऑनलाइन मध्ये आवश्यक संदेश संसाधने कॉन्फिगर करत नाही तोपर्यंत ते सुरू होणार नाही.

मेसेजिंग सिस्टम सेट करत आहे

आता फक्त आमच्या ऍप्लिकेशनला मेसेजिंग सिस्टममध्ये आवश्यक असलेली संसाधने सेट करणे बाकी आहे. हे करण्यासाठी, तुम्हाला तयार करणे आवश्यक आहे: 1) मेसेजिंग सिस्टम एंडपॉइंट सुरू करण्यासाठी अॅड्रेस स्पेस; 2) आम्ही ऍप्लिकेशनमध्ये वापरत असलेले पत्ते कॉन्फिगर करण्यासाठी पत्ता; 3) मेसेजिंग वापरकर्ता क्लायंट क्रेडेन्शियल सेट करण्यासाठी.

पत्त्याची जागा

AMQ ऑनलाइन मधील AddressSpace ऑब्जेक्ट हा पत्त्यांचा एक समूह आहे जो कनेक्शन एंडपॉइंट आणि प्रमाणीकरण आणि अधिकृतता धोरणे सामायिक करतो. तुम्ही अॅड्रेस स्पेस तयार करता तेव्हा, मेसेजिंग एंडपॉइंट्स कसे उघड केले जातील ते तुम्ही निर्दिष्ट करू शकता:

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"]

अनुप्रयोग कॉन्फिगर करण्यासाठी परवानग्या

AMQ Online साठी आम्ही AMQP एंडपॉइंट माहिती एम्बेड करण्यासाठी वापरलेला कॉन्फिगमॅप तयार करण्यासाठी, रोल आणि रोलबाइंडिंग सेट करणे आवश्यक आहे:

---
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

चला मग ऍप्लिकेशन रूट URL तपासू (फक्त हा पत्ता ब्राउझरमध्ये उघडा):

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

ब्राउझरने दर्शविले पाहिजे की AMQ ऑनलाइनद्वारे संदेश पाठवले आणि प्राप्त होत असल्याने तिकिटे वेळोवेळी अपडेट केली जातात.

गोळा करीत आहे

म्हणून आम्ही मेसेजिंगसाठी AMQP वापरणारा क्वार्कस ऍप्लिकेशन लिहिले, ऍप्लिकेशनला Red Hat OpenShift प्लॅटफॉर्मवर चालवण्यासाठी कॉन्फिगर केले आणि AMQ ऑनलाइन कॉन्फिगरेशनवर आधारित त्याचे कॉन्फिगरेशन लागू केले. त्यानंतर आम्ही आमच्या ऍप्लिकेशनसाठी मेसेजिंग सिस्टम सुरू करण्यासाठी आवश्यक मॅनिफेस्ट तयार केले.

यामुळे क्वार्कस बद्दलची मालिका संपते, पण पुढे खूप नवीन आणि मनोरंजक गोष्टी आहेत, ट्यून राहा!

स्त्रोत: www.habr.com