ApsaraMQ for RocketMQ:Integración con Spring

ApsaraMQ for RocketMQ proporciona proyectos de demostración que integran el SDK ons-client en beans administrados por Spring, lo que ofrece componentes de productor y consumidor listos para la inyección de dependencias. Esta guía explica el ejemplo de Spring Boot. El ejemplo de Spring estándar sigue el mismo patrón.

Tipos de mensaje compatibles

La integración con Spring admite productores y consumidores para los siguientes tipos de mensaje:

• Mensajes normales

• Mensajes ordenados

• Mensajes transaccionales

Requisitos previos

Antes de empezar, asegúrese de contar con lo siguiente:

• JDK 1.8 o posterior

• Maven 2.5 o posterior

• IntelliJ IDEA u otro IDE de Java

• Una instancia de ApsaraMQ for RocketMQ con un endpoint TCP

• Un AccessKey pair (AccessKey ID y AccessKey secret)

Paso 1: Descargar el proyecto de demostración

Clone o descargue uno de los proyectos de demostración desde GitHub:

Paso 2: Crear recursos

Cree los siguientes recursos en ApsaraMQ for RocketMQ console:

1. Create an instance.

2. Create a topic. Configure el tipo de mensaje para que coincida con los mensajes que planea enviar. Por ejemplo, seleccione Normal para mensajes normales o Ordered para mensajes ordenados.

3. Create a group. Seleccione TCP como tipo de protocolo, ya que el SDK ons-client se comunica mediante TCP.

4. Get the TCP endpoint para su instancia.

Paso 3: Configurar el proyecto de demostración

Abra el proyecto de demostración en IntelliJ IDEA y actualice la dependencia de Maven y las propiedades de la aplicación.

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>com.aliyun.openservices</groupId>
        <artifactId>ons-client</artifactId>
        <!-- Replace with the latest version -->
        <version>1.8.8.8.Final</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

Paso 4: Ejecutar la demostración

Asegúrese de que las clases ubicadas en java-springboot-demo/src/main/java/com/aliyun/openservices/springboot/example estén importadas en su proyecto y ejecute el método main().

Pasos siguientes

• Message filtering -- Filtre mensajes por etiqueta o expresión SQL.

• Release notes -- Compruebe la versión más reciente del SDK ons-client.