66      人物

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

以 Main 方式启动收发消息

1. 运行 SimpleMQProducer 类发送消息。

2. 登录 MQ 控制台，在左侧菜单栏选择消息查询>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

  上一篇： Demo 工程配置__MQ Demo 工程_消息队列 MQ-阿里云

  下一篇： 消息过滤__特色功能_消息队列 MQ-阿里云