Build Efficient Message Routing with Alibaba Cloud EventBridge – Step‑by‑Step Guide

During digital transformation, enterprises often need message routing, multi‑active deployment, protocol adaptation, and message backup. EventBridge offers a serverless event bus that uses the CloudEvents 1.0 protocol to enable loosely coupled, distributed event‑driven architectures.

Key cloud services involved:

EventBridge – Alibaba Cloud’s serverless event bus.

Message Queue RabbitMQ edition – AMQP‑compatible, fully managed RabbitMQ service.

Message Service (MNS) – Reliable, scalable notification service.

Scenario 1: Message Routing

Use case: forward messages to other topics or cross‑region topics for sharing or data masking. The core capability is a forwarding layer that distributes messages to different topics based on simple filters.

Scenario 2: Multi‑Active Messaging

Each data center runs an independent MQ cluster; services connect locally. EventBridge synchronizes specified topics across clusters, supporting central services (single data‑center) and unit services (deployed in every data‑center).

Scenario 3: Multi‑Protocol Adaptation

Different departments may use different messaging protocols. EventBridge can act as a bridge, allowing a single protocol to be smoothly migrated to multiple protocols.

Architecture

EventBridge’s event‑stream model provides end‑to‑end routing, storage, and synchronization without a traditional bus, suitable for standard streaming (1:1) processing.

Lab Experiment

Goal : Create routing tasks and send test messages via the console.

Resources : EventBridge bus, RabbitMQ instance, MNS instance.

Steps :

Create MNS queue test-mns-q (and test-mns-q2 for the A scenario).

Create RabbitMQ instance, then create Vhost test-amqp-v and queue test-amqp-q.

Create EventBridge event‑stream task test-amqp-mns2mns (A) or test-amqp-mns2rabbitmq (B) with source MNS, target MNS or RabbitMQ, and keep the default rule that matches all events.

Configure the target to forward the $.data field as the message body and $.source as a property.

Download the MNS SDK, edit sample.cfg with your AccessKeyId, AccessKeySecret, and the MNS endpoint (e.g., http://1825725063814405.mns.cn-hangzhou.aliyuncs.com), then run python sendmessage.py test-mns-q to publish 200 messages.

In the EventBridge console, open the created streams (e.g., test-mns-q2, test-amqp-q) and verify that messages are received.

Advantages and Summary

EventBridge delivers low‑cost, low‑maintenance, high‑efficiency end‑to‑end message routing, data filtering, and masking capabilities. It simplifies operations compared with custom solutions and is the most economical choice for routing scenarios.

References

Message Queue MNS console: https://mns.console.aliyun.com/accounttraceid=a42e9ca8e911475087856852d4526c4dsjeq

Message Queue RabbitMQ console: https://amqp.console.aliyun.com/

EventBridge console: https://eventbridge.console.aliyun.com/overview

MNS Python SDK: https://aliware-images.oss-cn-hangzhou.aliyuncs.com/mns/sdk/python/aliyun-mns-python-sdk-1.1.6.zip

Alibaba Cloud RAM console: https://ram.console.aliyun.com/manage/ak

Event stream console: https://eventbridge.console.aliyun.com/cn-hangzhou/event-streamings