阅读207 返回首页    go iPhone_iPad_Mac_apple


申请资源__快速入门_消息队列 MQ-阿里云

在 MQ 消息系统中,消息发布者将消息发送到某个指定的消息主题(Topic) ,而消息订阅者则通过订阅该指定的 Topic 来获取和消费消息。因此一个新的应用接入 MQ 需要先申请相关的 MQ 资源,包括消息主题(Topic)的创建,以及为 Topic 建立消息生产关系(Producer ID)和消息消费关系(Consumer ID)。

创建 Topic

消息主题(Topic)是 MQ 里对消息进行的一级归类,比如可以创建“Topic_Trade”这一主题用来识别交易类消息。使用MQ的第一步需要先为您的应用申请 Topic 资源,即创建 Topic。

您可以按照以下步骤创建 Topic:

  1. 登录 MQ 控制台,默认进入发布订阅管理>Topic 管理页面:https://ons.console.aliyun.com/

  2. 在页面左上方选择相应的域(比如公网测试域),然后单击页面右上角的发布 Topic 按钮。

    注意:

    • 如果只是测试,或者需要在本地(非阿里云 ECS 服务器)使用 MQ 服务,请将 Topic 创建在公网环境,并且本地服务器需要能够访问公网。
    • 如果在生产环境使用 MQ 服务,需要将应用部署在阿里云 ECS 上。请在应用程序所在的的域创建 Topic。
    • Topic 不能跨域使用。比如 Topic 创建在“华北1”这个域,那么消息生产端和消费端也必须运行在“华北1”的 ECS 上。
    • 有关域的详细介绍请参见阿里云 ECS 文档地域选择说明
  3. 发布 Topic 对话框输入 Topic 名称及备注,单击确定。您创建的 Topic 将出现在 Topic 列表中。

    注意: Topic 名称必须全局唯一。如果名称已经被其他用户使用,您将无法创建相同名称的 Topic。

    create_topic

创建 Producer ID

创建好 Topic 后,要为这个 Topic 申请消息生产端的资源,即创建 Producer ID。一个 Topic 只能对应一个 Producer ID。

请按照以下步骤为您的 Topic 创建 Producer ID:

  1. 在 MQ 控制台左侧菜单栏依次单击发布订阅管理>Topic 管理

  2. 在 Topic 列表中找到您刚刚创建的 Topic,单击操作选项中的申请发布

    topic_2

  3. 申请发布对话框输入 Producer ID,单击确定

    注意:

    • Producer ID 必须全局唯一。如果名称已存在,您将无法创建相同名称的 Producer ID。
    • Topic对应的生产端必须和这个 Topic 在同一个域,比如您在“公网测试”域创建了“Topic_open”,那么和“Topic_open”对应的 Producer ID 也必须在同一个域。
    • Producer ID 和 Topic 的关系是 1:N,即一个 Topic 只能绑定一个 Producer ID, 但是同一个 Producer ID 可以对应多个 Topic。

创建 Consumer ID

创建好消息生产关系后,您需要为 Topic 申请相应的消息消费资源,即创建 Consumer ID。

请按以下步骤创建 Consumer ID:

  1. 在 MQ 控制台左侧菜单栏依次单击发布订阅管理>Topic 管理

  2. 找到您创建的 Topic,单击右侧操作选项里的申请订阅

  3. 订阅 Topic对话框输入 Consumer ID,单击确定

    topic_3

    注意:

    • Consumer ID 必须全局唯一。如果名称已存在,您将无法创建相同名称的 Consumer ID。
    • Consumer ID 必须和对应的 Topic 在同一个域,比如给“公网测试”域的“Topic_open”绑定 Consumer ID “CID_123”后,“华北1”域内的“Topic_huabei1”将不能绑定同一个 Consumer ID。
    • Consumer ID 和 Topic 的关系是 N:N。同一个 Consumer ID 可以订阅多个 Topic,同一个 Topic 也可以对应多个 Consumer ID。

创建阿里云 AccessKey,SecretKey

在调用 SDK/API 进行消息发送和订阅的时候,除了需要指定创建的 Topic, Producer ID 以及 Consumer ID 以外,还需输入您在阿里云服务器管理控制台创建的身份验证信息,即 AccessKey 和 SecretKey。

请登录阿里云服务器管理控制台创建密钥。如果您已经创建了 AccessKey 和 SecrectKey,也可以返回此页面查看密钥。

aliyun

完成以上准备工作后,您就可以运行示例代码,用 MQ 进行消息发送和订阅了。

最后更新:2016-11-23 18:53:32

  上一篇:go 开通服务__快速入门_消息队列 MQ-阿里云
  下一篇:go 订阅消息__快速入门_消息队列 MQ-阿里云