云视频会议事件_最佳实践_事件总线EventBridge-阿里云

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

前提条件

您已完成以下操作：

开通EventBridge服务。详情请参见开通服务。
开通云视频会议。详情请参见开通云视频会议。

背景信息

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

云视频会议：云视频会议是阿里云提供的开放、可靠、智能的会议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	会议统计数据发布事件	每天推送一次最高并发。

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

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

步骤一：创建事件规则

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

登录事件总线EventBridge控制台。
在顶部菜单栏，选择地域。
在左侧导航栏，单击规则。
在规则页面选择事件总线区域，从事件总线列表，选择default。
在规则页面的规则列表区域，单击创建规则。
在创建事件规则面板，完成以下操作。
1. 在名称和描述区域的名称文本框，输入MyRule，在描述文本框，输入将云视频会议开始或结束事件路由到指定HTTP网关。。
2. 在定义事件模式区域，单击服务提供的预定义模式，从服务提供方列表，选择阿里云服务，从阿里云服务列表，选择Aliyun Meeting Service，从事件类型列表，选择aliyuncvc:MeetingEvent:MeetingStateEvent。
  上图中的事件模式代码如下：
```
{
    "source": [
        "acs.aliyuncvc"
    ],
    "type": [
        "aliyuncvc:MeetingEvent:MeetingStateEvent"
    ]
}
```
3. 在选择事件总线区域，单击默认事件总线。
4. 在选择目标服务区域，从目标服务类型列表，选择HTTP，在URL文本框输入http://api.xtingke.com/eventBridge/processEvent，在Body下方单击完整事件。
5. 单击确定。

步骤二：使用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";
    }
}

接收到的事件如下图所示。 cvc_5