云视频会议事件 - 事件总线EventBridge

本教程以云视频会议开始或结束事件为例，说明事件总线EventBridge如何根据事件规则将云视频会议事件路由到指定的HTTP网关，从而实现事件驱动架构。

前提条件

您已完成以下操作：

背景信息

事件驱动架构：以事件驱动架构设计和管理您的服务可以很好的实现服务模块之间解耦，提高服务整体的稳定性和灵活性。所有的业务数据都可以映射到事件上来，所有的业务事件按照业务领域划分为多个事件类型。更多信息，请参见事件驱动架构。

云视频会议：云视频会议是阿里云提供的开放、可靠、智能的会议PaaS服务，基于阿里集团数年视频会议技术及应用积累、全球部署的网络节点覆盖及领先的AI技术，您可快速构建多端互通与简单易用的会议协作应用。

云视频会议定义的事件类型如下表所示。


事件类型	事件类型描述	事件触发场景
aliyuncvc:MeetingEvent:MeetingStateEvent	会议开始或结束事件	会议开始，即从第一个人进入会议，推送“时间、MeetingUUID、MeetingName、action”。会议结束，即从最后一个人离开会议（不论是主动还是被动），推送“时间、MeetingUUID、MeetingName、action”。
aliyuncvc:MeetingEvent:MemberStateEvent	会议成员状态事件	成员入会，推送“时间、MeetingUUID、MeetingName、userID、groupId、action”。成员离会，推送“时间、MeetingUUID、MeetingName、userID、groupId、action”。
aliyuncvc:MeetingEvent:MemberOperate	会议成员会中操作事件	静音或取消静音，推送“时间、MeetingUUID、MeetingName、userID、groupId、action”。打开或关闭扬声器，推送“时间、MeetingUUID、MeetingName、userID、groupId、action”。打开或关闭摄像头，推送“时间、MeetingUUID、MeetingName、userID、groupId、action”。打开或关闭共享屏幕，推送“时间、MeetingUUID、MeetingName、userID、groupId、action”。
aliyuncvc:MeetingEvent:MeetingStatistic	会议统计数据发布事件	每天推送一次最高并发。

注意事项

云视频会议作为阿里云官方事件源，目前只对中国香港和华东1（杭州）两个地域开放。

云视频会议事件通知事件流

本文以云视频会议为例，为您介绍阿里云服务接入事件总线EventBridge的流程。

步骤一：创建事件规则

云视频会议事件会发布到云服务专用总线。事件总线EventBridge为您内置了云服务专用总线，您无需再创建。为云服务专用总线创建事件规则的步骤如下：

登录事件总线EventBridge控制台。
在左侧导航栏，选择事件驱动 > 事件规则。
在顶部菜单栏，选择地域。
在事件规则页面，从事件总线列表中选择云服务专用总线，然后单击创建规则。
在创建规则页面，完成以下操作。
1. 在配置基本信息配置向导页面，在名称文本框输入MyRule，在描述文本框输入将云视频会议开始或结束事件路由到指定HTTP网关。，然后单击下一步。
2. 在配置事件模式配置向导页面，事件源类型选择阿里云官方事件源，事件源选择acs.aliyuncvc云视频会议，事件类型选择会议状态，然后单击下一步。
3. 在配置事件目标配置向导页面，配置事件目标，然后单击创建。
  - 服务类型：单击HTTP。
  - URL：输入地址http://api.xtingke.com/eventBridge/processEvent。
  - Body：单击完整事件。
  注意目标服务和事件规则必须处于同一地域。

步骤二：使用HTTP网关接收事件

使用HTTP网关接收事件。

示例代码如下所示。

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@SpringBootApplication
@Slf4j
public class EventProcessingApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

    @PostMapping("/eventBridge/processEvent")
    @ResponseBody
    public String revieveMessage(@RequestBody String data) {
        log.info("revieveEvent");
        log.info(data);
        return "recieved";
    }
}