阅读66 返回首页    go iPhone_iPad_Mac_手机_平板_苹果apple


运行 Demo__MQ Demo 工程_消息队列 MQ-阿里云

以 Main 方式启动收发消息

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

    Topic查询

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

    打印消费端日志

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

    消费者状态

以 Spring 方式启动收发消息

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

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

发送事务消息

运行 SimpleTransactionProducer 类发送消息。

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

发送定时(延时)消息

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

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

HTTP、MQTT 物联接入

  1. HTTP 接入请参考 MQ HTTP 接入
  2. MQTT 接入请参考 MQTT 接入

最后更新:2016-11-23 16:04:19

  上一篇:go Demo 工程配置__MQ Demo 工程_消息队列 MQ-阿里云
  下一篇:go 消息过滤__特色功能_消息队列 MQ-阿里云