全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
消息队列 MQ

运行 Demo

更新时间:2017-12-01 17:03:50

以 Main 方式启动收发消息

  1. 运行 SimpleMQProducer 类发送消息。

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

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

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

以 Spring 方式启动收发消息

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

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

发送事务消息

运行 SimpleTransactionProducer 类发送消息。

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

收发顺序消息

运行 SimpleOrderConsumer 类接收消息。

运行 SimpleOrderProducer 类发送消息。

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

发送定时(延时)消息

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

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

HTTP、MQTT 物联接入

HTTP 接入请参考 MQ HTTP 接入
MQTT 接入请参考 MQTT 接入

本文导读目录