Quarkus र AMQ अनलाइन प्रयोग गरेर Red Hat OpenShift प्लेटफर्ममा क्लाउड-नेटिभ सन्देश

नमस्ते सबै! यो यहाँ छ - क्वार्कस श्रृंखला मा हाम्रो अन्तिम पोस्ट! (वैसे, हाम्रो वेबिनार हेर्नुहोस् "यो क्वार्कस हो - कुबर्नेट्स नेटिभ जाभा फ्रेमवर्क"। हामी तपाईंलाई कसरी स्क्र्याचबाट सुरु गर्ने वा तयार समाधानहरू स्थानान्तरण गर्ने भनेर देखाउनेछौं)

В अघिल्लो यस पोष्टमा, हामीले सान्दर्भिक उपकरणहरू हेर्यौं जुन जाभा अनुप्रयोगहरूको आधुनिकीकरणको परिणामको रूपमा प्राप्त सुधारहरूको परिमाण गर्न प्रयोग गर्न सकिन्छ।

संस्करण ०.१७.० देखि, क्वार्कस Advanced Message Quueing Protocol को प्रयोगलाई समर्थन गर्दछ (AMQP), जुन एप्लिकेसन वा संस्थाहरू बीच व्यापार सन्देशहरू स्थानान्तरण गर्नको लागि खुला मानक हो।

Red Hat AMQ अनलाइन खुला स्रोत परियोजनाको आधारमा निर्मित सेवा हो EnMasse र प्लेटफर्म-आधारित सन्देश संयन्त्र लागू गर्दै रेड ह्याट ओपनशिफ्ट। यसले कसरी काम गर्छ भन्ने बारे थप विवरणहरूको लागि, हेर्नुहोस् यहाँ (EN)। आज हामी तपाईंलाई दुई नयाँ सन्देश प्रविधिहरू प्रयोग गरेर आधुनिक OpenShift-आधारित सन्देश प्रणाली निर्माण गर्न AMQ अनलाइन र क्वार्कसलाई कसरी संयोजन गर्ने भनेर देखाउनेछौं।

यो मानिन्छ कि तपाईंले ओपनशिफ्ट प्लेटफर्ममा AMQ अनलाइन डिप्लोइ गरिसक्नुभएको छ (यदि होइन भने, त्यसपछि हेर्नुहोस्। स्थापना गाइड).

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

एकपटक हामीले एप्लिकेसन सिर्जना गरिसकेपछि, हामी तपाईंलाई मेसेजिङ सिस्टम कन्फिगरेसनलाई कसरी एप्लिकेसनमा इम्बेड गर्ने र प्रणालीमा आवश्यक पर्ने स्रोतहरू उपलब्ध गराउन AMQ अनलाइन प्रयोग गर्ने भनेर देखाउनेछौं।

क्वार्कस एप

हाम्रो क्वार्कस एप 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++);
    }
}

अर्डर प्रोसेसर

अर्डर ह्यान्डलर अझ सरल छ, यसले केवल "पुष्टिहरू" ठेगानामा पुष्टिकरण ID फर्काउँछ।

@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 अनलाइनमा जडान गर्नको लागि, हाम्रो अनुप्रयोगलाई केही कन्फिगरेसन डेटा चाहिन्छ, जस्तै: क्वार्कस कनेक्टर कन्फिगरेसन, 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 Online मा 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 अनलाइन कन्फिगरेसनमा आधारित यसको कन्फिगरेसन लागू गर्‍यौं। हामीले त्यसपछि हाम्रो अनुप्रयोगको लागि सन्देश प्रणाली सुरु गर्न आवश्यक manifests सिर्जना गर्यौं।

यसले क्वार्कसको बारेमा श्रृंखला समाप्त गर्दछ, तर त्यहाँ धेरै नयाँ र चाखलाग्दो चीजहरू छन्, साथ रहनुहोस्!

स्रोत: www.habr.com