本文介绍通过HTTP请求将HTTP端点内容发布到ActiveMQ指定队列。完成访问HTTP端点URL,发送GET请求将获取的内容发布到ActiveMQ的指定队列。

前提条件

背景信息

通过集成流配置可以调用HTTPS端口URL,实现将信息发布到ActiveMQ服务器的指定主题或者队列。 调用HTTPS端口URL的方式支持GET、PUT、POST、DELETE、HEAD、OPTIONS、TRACE和PATCH。

通过创建的集成,将完成以下动作:
  1. 访问HTTPS端口URL。
  2. 将信息发布到ActiveMQ的指定队列Queue1中。

创建连接

本示例中会用到ActiveMQ和HTTPS,所以需要借助连接器创建对应的连接。

创建空白集成

  1. 登录应用集成控制台
  2. 在左侧导航栏选择集成 > 集成列表
  3. 集成列表页面单击新建集成
  4. 新建集成面板中创建方式选择为空白流,选择目标环境,输入名称,然后单击创建
  5. 集成创建后,返回集成设计页面,选择接下来的操作。
    • 在页面左上角选择工作空间,然后在右上角单击保存,创建一个空集成。
    • 在页面左上角单击 ,在列表中单击Flow,创建集成流。详情请参见创建集成流

创建集成流

  1. 集成设计页面设置集成名,选择目标工作空间环境
  2. 集成设计页面左上角单击 ,在列表中单击Flow,创建集成流。
    也可以在页面中单击点击创建,在列表中单击Flow,创建集成流。
  3. 选择触发器,实现访问HTTPS端口URL。
    1. 创建新集成流对话框输入名称,并选择之前创建的HTTPS连接作为触发器,然后单击创建创建https触发器
    2. 选择操作对话框的Periodic invoke URL右侧,单击选择选择operation
    3. 步骤配置对话框中设置参数,然后单击确定步骤配置
      步骤配置参数说明:
      参数 描述
      URL路径 调用HTTPS端点URL的path路径,可根据实际情况设置。
      Http方法 调用方式,默认为GET

      包含的调用方式有GET、PUT、POST、DELETE、HEAD、OPTIONS、TRACE和PATCH,请根据实际需要选择。

      周期 调用周期,默认为1800000,单位ms,可根据实际需要设置为其他周期。
    4. 设置outputDataShape对话框选择scheme列表中选择任意类型,然后单击创建
    创建完成后,集成流中即包括定期访问HTTPS端点URL的触发器。触发器-https端点定期访问
  4. 在集成流中添加ActiveMQ,实现将消息发布到ActiveMQ指定主题或者队列。
    1. 在集成流中Periodic invoke URL后单击
    2. 选择组件类型对话框单击连接,然后单击之前新建的ActiveMQ连接。
    3. 选择操作对话框中的发布消息右侧,单击选择选择operation
    4. 步骤配置对话框设置参数,然后单击确定步骤配置-将消息发送到指定主题或队列
      步骤配置参数说明:
      参数 描述
      是否持久化 是否持久化保证消息投递,默认不勾选。
      目标名 设置将消息发布到指定主题或队列的目标名,如Queue1。设置的主题或者队列需要在ActiveMQ服务器上配置。
      目标类型 选择将消息发布到的目标类型,根据实际需要选择主题或者队列
      • 主题:是一对多的广播消息消费模型,采用服务端主动推送(Push)模式。
      • 队列:是一对一的共享消息消费模型,采用客户端主动拉取(Pull)模式。
    5. 设置inputDataShape对话框选择scheme列表中选择任意类型,然后单击创建
  5. 集成设计页面右上角单击保存,保存集成流。
    HTTPS协议处理集成流创建完成。https协议处理集成流
    注意 返回集成设计页面时,请及时在页面右上角单击保存,以免添加的步骤丢失。

部署集成

集成创建并保存后,需要对集成进行部署。详情请参见部署集成示例

结果验证

  • 验证ActiveMQ的消息代理。

    登录ActiveMQ服务器,查看队列Queue1是否有从HTTPS端点发布的消息。

  • 验证集成部署是否正常运行。

    查看目标集成的执行记录,其执行日志状态是否为SUCCESS