Размена на пораки во облак на платформата Red Hat OpenShift со помош на Quarkus и AMQ Online

Здраво на сите! Еве го - нашата последна објава во серијата Кваркус! (Патем, гледајте го нашиот вебинар „Ова е Quarkus – Kubernetes родна Java рамка“. Ќе ви покажеме како да започнете од нула или да префрлите готови решенија)

В претходно Во овој пост, ги разгледавме релевантните алатки кои може да се користат за квантифицирање на подобрувањата добиени како резултат на модернизирањето на Java апликациите.

Од верзијата 0.17.0, Кваркус поддржува употреба на напреден протокол за редица пораки (AMQP), кој е отворен стандард за пренос на деловни пораки помеѓу апликации или организации.

Red Hat AMQ Online е услуга изградена врз основа на проект со отворен код EnMasse и имплементирање на механизам за пораки базиран на платформа Red Hat OpenShift. За повеќе детали за тоа како функционира, видете тука (EN). Денес ќе ви покажеме како да ги комбинирате AMQ Online и Quarkus за да изградите модерен систем за пораки базиран на OpenShift користејќи две нови технологии за пораки.

Се претпоставува дека веќе сте го распоредиле AMQ Online на платформата OpenShift (ако не, тогаш видете водич за инсталација).

За почеток, ќе создадеме апликација Quarkus која ќе биде едноставен систем за обработка на нарачки со помош на реактивни пораки. Оваа апликација ќе вклучува генератор на нарачки кој испраќа нарачки до редот за пораки во фиксен интервал, како и процесор за нарачки кој ќе ги обработува пораките од редот и ќе генерира потврди што може да се видат во прелистувачот.

Откако ќе ја создадеме апликацијата, ќе ви покажеме како да ја вградите конфигурацијата на системот за пораки во апликацијата и да го користите AMQ Online за да ги обезбедиме ресурсите што ни се потребни на системот.

Апликација Кваркус

Нашата апликација Quarkus работи на OpenShift и е изменета верзија на програмата amqp-брз почеток. Може да се најде целосен пример за клиентската страна тука.

Генератор на нарачки

Генераторот едноставно монотоно испраќа ID на растечки нарачки на адресата „нарачки“ на секои 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 Online, на нашата апликација ќе и требаат некои податоци за конфигурација, имено: конфигурација на конекторот Quarkus, информации за крајната точка AMQP и акредитиви на клиентот. Се разбира, подобро е да се чуваат сите конфигурациски податоци на едно место, но ние намерно ќе ги одвоиме за да ги прикажеме можните опции за конфигурирање на апликацијата Quarkus.

Конектори

Конфигурацијата на конекторот може да се обезбеди во времето на компајлирање користејќи датотека со својства на апликацијата:

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

За да бидеме едноставни, ќе користиме само редица пораки за адресата „нарачки“. А адресата „потврди“ во нашата апликација ќе користи редица во меморијата.

AMQP крајна точка

Во времето на компајлирање, името на домаќинот и бројот на портата за крајната точка AMQP се непознати, па затоа мора да се инјектираат. Крајната точка може да се постави во конфигурационата мапа што ја креира AMQ Online, така што ќе ги дефинираме преку променливите на околината во манифестот на апликацијата:

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. За да го направите ова, прво мора да креирате сопствен ConfigSource кој ќе го чита токенот за автентикација од датотечниот систем на подлогата:

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

Поставување на системот за пораки

Сега останува само да ги поставиме ресурсите што и се потребни на нашата апликација во системот за пораки. За да го направите ова, треба да креирате: 1) адресен простор за иницијализирање на крајната точка на системот за пораки; 2) адреса за конфигурирање на адресите што ги користиме во апликацијата; 3) Корисник за испраќање пораки за поставување акредитиви на клиентот.

Адресен простор

Објектот AddressSpace во AMQ Online е група на адреси кои споделуваат крајни точки за поврзување и политики за автентикација и авторизација. Кога креирате адресен простор, можете да одредите како ќе бидат изложени крајните точки за пораки:

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, мора да се постават Role и RoleBinding:

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

Сумирање

Така, напишавме апликација Quarkus која користи AMQP за пораки, ја конфигуриравме апликацијата да работи на платформата Red Hat OpenShift и ја имплементиравме нејзината конфигурација врз основа на конфигурацијата AMQ Online. Потоа ги креиравме манифестациите потребни за иницијализирање на системот за пораки за нашата апликација.

Со ова завршува серијата за Quarkus, но има многу нови и интересни работи напред, останете во тек!

Извор: www.habr.com