步驟一：快速創建自定義事件總線

1. 登錄事件總線EventBridge控制臺。
2. 在左側導航欄，單擊事件總線。
3. 在頂部菜單欄，選擇地域。

4. 在事件總線頁面的自定義事件總線區域，單擊快速創建。

5. 在創建自定義事件總線配置向導面板，完成以下操作。

   1. 在總線（必填）面板，在自定義事件總線名稱文本框輸入marketing，在描述文本框輸入路由CRM系統的營銷相關事件，然后單擊下一步。

   2. 在事件源面板，在事件源名稱文本框輸入MyCustomSource，在描述文本框輸入生產CRM系統的營銷相關事件，事件提供方選擇自定義應用，然后單擊下一步。

   3. 在規則面板，在規則名稱文本框輸入MyCustomRule，在描述文本框輸入將CRM系統的營銷相關事件路由到輕量消息隊列（原 MNS）。，在模式內容代碼框輸入事件模式，然后單擊下一步。

      過濾出用戶注冊或登錄事件的事件模式內容示例如下所示。

      {
          "source": [
              "crmabc.newsletter"
          ],
          "type": [
              "UserSignUp", "UserLogin"
          ]
      }

   4. 在目標面板，配置事件目標，然后單擊創建。

      • 服務類型：單擊輕量消息隊列（原 MNS）。

      • 隊列：選擇MyQueue。

      • 消息內容：單擊完整事件。

步驟二：使用SDK發布事件

使用SDK將CRM系統的營銷相關事件發布到事件總線EventBridge。

1. 添加Maven依賴。

   Maven依賴的示例代碼如下：

   <dependency>
         <groupId>com.aliyun</groupId>
         <artifactId>eventbridge-client</artifactId>
         <version>1.2.6</version>
   </dependency>

2. 發布事件。

   發布事件的示例代碼如下：

   import java.net.URI;
   import java.util.ArrayList;
   import java.util.Date;
   import java.util.List;
   
   import com.aliyun.eventbridge.EventBridge;
   import com.aliyun.eventbridge.EventBridgeClient;
   import com.aliyun.eventbridge.models.CloudEvent;
   import com.aliyun.eventbridge.models.Config;
   import com.aliyun.eventbridge.models.PutEventsResponse;
   import com.aliyun.eventbridge.util.EventBuilder;
   import com.google.gson.Gson;
   
   public class PutEventsSample {
   
       private final EventBridge eventBridgeClient;
   
       public PutEventsSample() {
           Config authConfig = new Config();
           authConfig.accessKeyId = System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID");
           authConfig.accessKeySecret =System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET");
           authConfig.endpoint = "{endpoint}";
           eventBridgeClient = new EventBridgeClient(authConfig);
       }
   
       public void putEventsSample() {
           List<CloudEvent> cloudEventList = new ArrayList<CloudEvent>();
           cloudEventList.add(EventBuilder.builder()
                   .withId("9e9b433c-a89b-4918-896b-7e1b7221****")
                   .withSource(URI.create("crmabc.newsletter"))
                   .withType("UserSignUp")
                   .withSubject("crmabc/users/1234345")
                   .withTime(new Date())
                   .withJsonStringData("{ \"E-Mail\": \"${email}\" }")
                   .withAliyunEventBus("marketing")
                   .build());
           PutEventsResponse putEventsResponse = eventBridgeClient.putEvents(cloudEventList);
           System.out.println(new Gson().toJson(putEventsResponse));
       }
   
       public static void main(String[] args){
           PutEventsSample sample = new PutEventsSample();
           try {
               sample.putEventsSample();
           }
           catch (Throwable e) {
               e.printStackTrace();
           }
       }
   }

   參數	描述
   accessKeyId	阿里云賬號的AccessKey ID。
   accessKeySecret	阿里云賬號的AccessKey Secret。
   endpoint	事件總線EventBridge服務接入點。登錄事件總線EventBridge控制臺，在左側導航欄單擊事件總線，找到目標自定義事件總線，在最右側操作列單擊詳情，在總線概覽頁面的接入點區域獲取。

結果驗證

您可以在輕量消息隊列（原 MNS）控制臺確認是否接收到關注的營銷相關事件。

1. 登錄輕量消息隊列（原 MNS）控制臺。

2. 在左側導航欄，單擊隊列列表。

3. 在頂部菜單欄，選擇地域。

4. 在隊列列表頁面，找到目標隊列，在其右側操作列選擇更多 > 收發消息。

5. 在隊列收發消息快速體驗頁面的接收消息區域，單擊接收消息。

   接收到的示例消息內容如下所示。

   {
       "eventId":"9e9b433c-a89b-4918-896b-7e1b7221****",
       "publishTime":1591272433527,
       "Message":{
           "data":"{ \"E-Mail\": \"${email}\" }",
           "id":"9e9b433c-a89b-4918-896b-7e1b7221****",
           "source":"crmabc.newsletter",
           "specversion":"1.0",
           "type":"UserSignUp",
           "subject":"crmabc/users/1234345",
           "time":"2020-06-04T12:07:11.851Z"
       },
       "eventBusName":"marketing",
       "eventBusOwner":"<yourAccountId>",
       "ruleName":"MyCustomRule",
       "eventBusInvoker":"<yourAccountId>",
       "MessageMD5":"D0256972C35F85409E38D176B7E7****"
   }