全部产品
弹性计算 会员服务 网络 安全 移动云 数加·大数据分析及展现 数加·大数据应用 管理与监控 云通信 阿里云办公 培训与认证 智能硬件
存储与CDN 数据库 域名与网站(万网) 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 更多
消息队列 MQ

运行 Demo

更新时间:2018-06-21 19:11:47

以 Main 方式启动收发消息

  1. 运行 SimpleMQProducer 类发送消息。

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

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

从 MQ 控制台进入消费者管理>消费者状态,在消费者状态信息页面可以看到启动的消费端已经在线,并且订阅关系一致。

以 Spring 方式启动收发消息

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

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

发送事务消息

运行 SimpleTransactionProducer 类发送消息。

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

收发顺序消息

运行 SimpleOrderConsumer 类接收消息。

运行 SimpleOrderProducer 类发送消息。

说明:此方式下,消息发布和消费都按顺序进行。 详情请参考收发顺序消息

发送定时(延时)消息

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

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

本文导读目录