全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 阿里云办公 培训与认证 物联网
消息队列 MQ

运行 Demo

更新时间:2017-08-24 11:42:17   分享:   

以 Main 方式启动收发消息

  1. 运行 SimpleMQProducer 类发送消息。
  2. 登录 MQ 控制台,在左侧菜单栏选择消息查询>Topic 查询,选择 Topic 名称进行查询。可以看见消息已经发送至 Topic。

    Topic查询

  3. 运行 SimpleMQConsumer 类接收消息。可以看到消息被接收打印的日志。因为有初始化,所以需等待几秒,在生产环境中不会经常初始化。

    打印消费端日志

    订阅管理>消费者状态中可以看到,启动的消费端已经在线,并且订阅关系一致。

    消费者状态

以 Spring 方式启动收发消息

  1. 运行 MQProducer4Spring 类发送消息。
  2. 运行 MQConsumer4Spring 类接收消息。

查看结果跟上面过程类似。

发送事务消息

运行 SimpleTransactionProducer 类发送消息。

说明:LocalTransactionCheckerImpl 类为本地事务 check 接口类。用于校验事务。详情请参考发送分布式事务消息

收发顺序消息

运行 SimpleOrderConsumer 类接收消息。

运行 SimpleOrderProducer 类发送消息。

说明:一种按照顺序进行发布和消费的方式。详情请参考收发顺序消息

发送定时(延时)消息

运行 MQTimerProducer 类发送消息。延时3秒后投递。

说明:MQ 也可以指定一个精确的投递时间,最长定时时间为40天。具体请参考发送定时消息

HTTP、MQTT 物联接入

  1. HTTP 接入请参考 MQ HTTP 接入
  2. MQTT 接入请参考 MQTT 接入
本文导读目录
本文导读目录
以上内容是否对您有帮助?