1.免开发打造智能热水器，随心用水，舒适生活

本方案主要介绍有关热水器产品方案，适用于热水器产品开发者快速入门，了解并快速接入涂鸦平台。

MCU对接方案是目前家电类产品对接涂鸦平台最常用的方案之一。主要用于带有MCU主控的热水器产品实现智能化，直接对接涂鸦模组串口协议即可实现联网。客户只需要关注产品本身的功能研发，联网智能化部分使用公版方案或者面板工作台，具体MCU方案通信原理图如下：

系统介绍

1、涂鸦联网模块：实现产品配网，采用串口通信方式连接App和云端，实现产品指令上传下发。

• IoT模组，提供多种模组选择，支持贴片式、直插式等不同需求；已实现跨芯片平台与跨通讯平台能力；
• IoT转接板模组，提供多种转接板模块选择，支持3.3V、5V、12V等不同电压等级需求；已实现Plug and Play即插即用式的 USB串口转接板对接方式；

2、涂鸦云：全球部署的IoT平台，对所有设备和App进行连接，进行数据沉淀，实现智能设备互通，安全、稳定、快速。

3、App单元：提供多种形式的APP，实现对设备的远程控制。

• 公版App：免费公版App，即刻使用，场景丰富，全球通用，适用于产品快速对接；
• OEM App：基于官方模板，通过简单的UI及个性化配置一键生成自有品牌的独立App，满足轻度个性化定制需求；
• 定制App：基于公版架构，充分满足品牌个性化需求进行深度开发的App版本；
• App SDK，适用于用户自研App；

4、语音单元：支持国内外主流语音平台接入。 - 国外支持Amazon Alexa、Google Assistant、Yandex Alice；

• 国内支持百度小度等各大主流音箱平台；
• 涂鸦提供的面向国内IoT控制的Wi-Fi在线语音模组，内置“小智管家”唤醒词和消噪算法，实现“小智管家 Built-in” 的语音入口能力，和Powered by Tuya的IoT控制能力；

5、数据及运维管理平台：涂鸦为所有开发者提供非常丰富的数据统计平台，助力厂家提供更好的设备体验优化。借助涂鸦运营平台，当消费者产品出现问题时，产品主动上报故障码。平台分析后自动生成报警工单，客服人员能第一时间处理，让售后服务更简单。 - 数据中心功能及使用说明 - 运营中心使用指南

方案详情

通用功能

• 快速配网：支持EZ和AP两种配网方式，及蓝牙快速连接；
• 常见功能：一键开关、模式切换、温度调节、童锁、定时预约、温标切换等；
• 实时状态：工作状态、当前温度、耗电量、耗水量、耗气量、剩余水量、水流量等；
• 设备配置：配网信息、快捷开关、告警设置等；
• 故障告警：支持机器故障、告警、通知等消息推送；
• 设备分享：支持家庭管理、成员间设备分享；
• 群组控制：支持同一类型设备组成群组，进行群控；
• 智能场景自动化：支持智能场景触发条件、执行任务，在App智能场景进行对应功能的设置；
• OTA升级：支持提示/静默等方式的设备及模组升级；
• 多语言管理：支持多种语言的配置管理和切换；
• 语音包管理：支持多种语音包的配置管理和切换；

扩展功能

• 云定时：涂鸦云提供云端定时能力，无需本地计时；支持周循环设定；
• 能耗统计：支持用电量、用气量、用水量等按年、月、日维度进行统计及展示；
• 整机维护提醒：对设备激活后使用时间进行累积计时，达到整机维护时间后进行消息推送；
• 安全报警：多渠道的消息推送，轻微异常，故障上报；高级危险预警，可以以消息推送或电话等形式告知用户，确保使用安全；

公版面板

热水器目前有6种控制面板可选择，详细UI如下：

客户选中主题风格符合的面板后，可以点击编辑进行二次编辑，具体编辑方式可参照：面板DIY操作指南

模组选配

针对热水器MCU对接方案，推荐使用WBR3联网模组。

概述： WBR3 是由涂鸦智能开发的一款低功耗嵌入式 Wi-Fi+BT 模块。它由一个高集成度的无线射频芯片 RTL8720CF 构成，内置了 Wi-Fi 网络协议栈和丰富的库函数。WBR3 还包含低功耗的 KM4 MCU，WLAN MAC，1T1R WLAN，最高主频 100MHz，内置 256K SRAM ，芯片内置 2Mbyte flash 和丰富的外设资源。 WBR3 是一个 RTOS 平台，集成了所有 Wi-Fi MAC 以及 TCP/IP 协议的函数库。用户可以基于这些开发满足自己需求的嵌入式 Wi-Fi 产品。

特性： - 内置低功耗 KM4 MCU，可以兼作应用处理器 主频 100MHz - 工作电压：3V-3.6V - 外设：9×GPIOs, 1×UART, 1×Log_Tx - Wi-Fi/BT 连通性 - 802.11 B/G/N20 - 通道 1-14@2.4GHz(CH1-11 for US/CA, CH1-13 for EU/CN) - 支持 WPA/WPA2 安全模式 - 支持Bluetooth 4.2 Low Energy - 802.11b 模式下+20dBm 的输出功率 - 支持 SmartConfig 功能（包括 Android 和 iOS 设备） - 板载 PCB Onboard 天线 - 通过 CE,FCC 认证 - 工作温度：-20℃ to 85℃

尺寸封装： WBR3 共有 2 排引脚（2×8），引脚间距为 2mm。 WBR3 尺寸大小：16±0.35 mm (W)×24±0.35 mm (L) ×2.9±0.15 mm (H)。WBR3尺寸图如下图所示：

更多模组需求可联系平台运营、相应BD或项目经理确认。

适用单品

电热水器、燃气热水器、太阳能热水器、空气能热水器等。

登录平台

在涂鸦IoT平台，注册开发者账号，开启产品智能化。

为了使用日志查询、权限分享等相关功能，请开通企业版权限。

IoT平台链接：Tuya IoT。

流程概述

Step1 - 产品创建：在IoT平台选择相应产品类，定义产品名称、型号，创建产品；

Step2 - 产品定义：在平台定义产品的具体功能，核心是数据传输内容及格式；

Step3 - 面板配置：根据产品特点，选择和配置个性化的UI，核心是风格、颜色、图标等；

Step4 - 硬件开发：根据产品主控的要求，选择适配的Wi-Fi通讯模组，开发MCU程序；

Step5 - App构建：构建具有厂商特点的App，核心是LOGO、欢迎页、设备页等；

Step6 - 云端配置：配置App界面多国语言、申请开通智能音箱、设备OTA升级等核心操作；

点击了解IoT开发平台，助您快速完成产品智能化：

auth.tuya.com/register?from=http%3A%2F%2Fiot.tuya.com%2F&_source=e74d60a1928993e1892f7e5efbaa5467

以下是产品创建的详细流程：

创建步骤

产品创建

在涂鸦IoT平台创建产品，选择【大家电】-【热水器】，点击“创建产品”即可开始创建产品。

相关说明：

1. 产品名称：实际设备的默认名，将显示在App中设备页；
2. 通讯类型：硬件连接涂鸦云的方式，目前支持Wi-Fi、Wi-Fi&蓝牙双模、NB方式；

产品定义

如何定义DP

涂鸦平台将设备与云端传输的数据，抽象成不同类型的DP，在定义DP时，可根据机器功能，分类成不同的DP点，用于控制和显示。

为满足不同开发需求，涂鸦平台提供标准化功能和自定义功能：

• 标准功能：是指该类别下提供的常用功能，涂鸦已针对热水器产品常用功能进行了标准化，客户可以按需直接选用；
• 自定义功能：自定义热水器的附加功能项，用于扩展设备功能，如果你的产品功能不在标准功能中，可以添加自定义功能；

面板配置

产品定义后，可以选择不同风格的面板（设备控制页），作为热水器产品的交互页面。在IoT平台，涂鸦提供了推荐面板、自由配置面板、以及开发调试面板，供客户选择。

推荐面板：带有完整UI设计的面板，客户可以根据自己的主题偏好选择相应的样式，同时该类面板涂鸦提供丰富的可视化组件，用户可以基于选择的主体面板进行二次编辑，修改布局、颜色及产品逻辑规则等；

自由配置面板：支持自由设置页面控件及样式，用于自定义产品；

调试面板：以开关选项方式显示机器端数据，用于开发阶段调试；

硬件开发

模组选择

热水器电控，主板通过云模组，与涂鸦云和App进行通讯连接。在产品新建后，选择适用的云模组，并根据主板、云模组的接口电路及产品要求，完成硬件电路的开发。

步骤：模组选择—固件选择—固件信息配置

目前，智能热水器产品常用的是WBR3模组，模组详细说明，请参考：WBR3规格说明书

MCU程序开发

云模组通过串口通讯方式与MCU对接，MCU端根据【产品定义】步骤中定义的功能DP，实现设备数据与云端的交互。MCU开发过程主要涉及协议的解析、数据的上报与接收等。

MCU开发有两种方式可选择：

1）串口协议方式

MCU根据串口协议，自行组包和解包，实现数据的上报和执行；

2）SDK方式

移植IoT平台封装好的SDK接口文件，MCU直接调用相关函数，实现数据的上报和执行；

开发详情，请参考：涂鸦通用Wi-Fi SDK说明

机器功能调试

在产品开发的验证和调试阶段，为了验证技术方案、或App面板的功能，可采用IoT平台提供的调试助手及调试面板，实现App端和机器端的数据通讯，辅助开发过程的开发调试。

1、仿真助手 涂鸦云仿真助手，PC机与云模组通过串口连接，模拟MCU收发机器功能DP数据，可在App端实时体验交互效果。

适用于在MCU程序开发前，对所定义的产品功能进行验证，以及调试过中数据有效性的验证。

仿真助手使用详情，请参考：模组调试使用助手说明

2、面板调试

在设备配网功能调试完成后，可以通过App对热水器进行配网，在App上对热水器进行相关操作，验证指令收发，App显示、机器执行等是否正确。

同时，MCU在开发前期，可以借助调试面板功能，单独调试某个DP的逻辑是否正确。

调试面板只保留数据收发操作，不含交互逻辑，可以在【界面配置】环节选择，适用于开发过程的调试。

3、日志查询

开通调试过程中，会遇到DP数据收发过程查询的需求。IoT平台提供日志查询功能，可以查看热水器MCU与App间的数据通讯情况，适用于异常情况下，排查各端的操作情况。

【说明】日志查询功能，需要开通“企业版”账户权限，并在运营平台操作。

App构建

当机器功能开发完成后，将涉及自有品牌App的构建。涂鸦平台提供在线OEM App的功能。

在IoT的【App工作台】，可配置App名称、LOG、配网文案、产品图标等信息，生成具备厂商标识信息和个性化的OEM App。

详细操作请参考：App构建引导

云端配置

多语言配置

当产品目标市场是海外区域时，需要将App界面的语言调整成相应区域的语种。

在IoT平台“拓展功能”的“多语言配置”，可对设置功能点进行多语言编辑，完成编辑后。当手机调整系统语言后，App界面语言也随之调整。

OTA升级

为了满足机器功能升级，平台支持MCU OTA功能。

在IoT平台“拓展功能”的“固件升级”，可以自定义上传MCU固件，固件版本、升级信息等都支持自定义管理。

告警设置

涂鸦提供不同等级的告警提示功能，客户可以自定义产品告警条件，触发后通知用户或企业，实时监控产品状态，保障产品健康运行。

更多云配置功能，如果有问题可联系平台运营、相应BD及项目经理。

2.2017年度·消费电子行业产品奖榜单发布

过去一年，我们见证了许多卓越产品的诞生与进化，它们改变了人们的生活习惯，将科技带进新领域，衍生新方向。

新年伊始，《消费电子》杂志社资深评测编辑团队和业内权威人士共同组成的专家评审团本着公平、公正、公开的原则，对消费电子类产品就市场认可度、技术创新、性价比、用户体验等方面进行综合考量，评选出“2017年度消费电子行业最值得购买、创新、优秀手机/电脑类产品/智能设备/家电产品/数码产品奖”，并在此发布。

最值得购买产品奖

荣耀 畅玩X系列手机

荣耀 Waterplay平板

施耐德 电气插电式PM2.5空气质量监测仪

TCL JSQ25-13EZ燃气热水器

希捷 Backup Plus Ultra Slim移动硬盘

创新产品奖

锤子 坚果Pro 2手机

CHERRY MX BOARD 1.0 TKL 机械键盘

金洛克 星脉K2指静脉智能锁

视贝 扫地机器人抹抹4.0

BOOX Max2电纸书

优秀产品奖

华为 Mate 10 Pro手机

华硕 飞行堡垒 NX580游戏本

佳明 vivosmart3 智能运动健康手环

施耐德 电气天朗系列终端配电箱

西部数据 My Cloud Home 智能个人云

荣耀畅玩X系列手机

目前已突破4000万用户

一直以来，荣耀都在不断创新和提升品质，力求满足广大消费者在消费升级时代的需求。

事实也证明了荣耀的成功，2017年，荣耀X系列机型（包括畅玩4X、5X、6X、7X）累计销量突破4000万台，成为荣耀乃至国产机型中最畅销系列之一。

超高销量的背后，离不开畅玩4X的全网通技术、畅玩5X千元指纹机的普及以及畅玩6X千元双摄机的带动。

而荣耀X系列的最新机型畅玩7X更是一举将全面屏旗舰机拉到千元档位，无论是全面屏、颜值、配置，还是工艺，荣耀畅玩7X为千元机树立了新标准，重新定义了千元旗舰机，开启了全面屏手机的千元时代。

锤子坚果Pro 2

见全面屏 漂亮得不像话

锤子坚果Pro 2简洁的全面屏采用了微曲边框设计，屏幕采用双面玻璃材质打造，其后背还加入了“星空油墨”的涂装工艺，显得机身背部流光溢彩。

机身侧面的细红色腰线设计采用了CNC钻石切割技术，与隔离出来的“闪电胶囊”键相辅相成。

锤子坚果 Pro 2的人像双摄支持背景虚化拍法和更懂你的陌陌AI美颜算法，搭载1200万像素索IMX386广角+500万像素三星S5K4E8专业景深双摄像头，支持1600万像素外加f/2.2大光圈，且具有多样化功能，给予用户强大的拍摄体验。

华为Mate 10 Pro

以水玩转 影像实力派

华为Mate 10 Pro的机身沿用了曲面双玻璃设计，华丽风范尽显无遗。6英寸屏幕采用OLED材质，机身采用金属材质，表面在多层镀膜工艺的包裹下，使得握持手感细腻又柔和。

华为Mate 10 Pro采用新一代徕卡双摄，具有1200万彩色+2000万像素的后置摄像头。

双摄相机两个摄像头的光圈为f/1.6，自带OIS光学防抖功能，抓拍和夜拍效果更完美，以大师级别的拍摄实力呈现出唯美而艺术气息浓郁的景色。

华为Mate 10 Pro的配置可谓是最亮眼的地方，其搭载的麒麟970是世界上首款集成NPU的芯片，功耗较以往降低20%，图像识别速度快，搭配6GB运行内存+256GB机身储存，运行效率高且可以帮助手机更为精准、快速地识别拍摄场景，并将拍摄光线和场景自动调整到最佳状态。

值得一提的是，EMUI8.0版本中还加入了AI翻译功能，可以实现即拍即译。

荣耀Waterplay平板电脑

水下畅玩！影音平板也有好音色？

荣耀Waterplay以香槟金为主配色，简约、素雅，配以CNC工艺一体化轻薄机身，465g的重量和8mm的机身厚度，拿起来虽略重，但手感细腻润滑，转角圆润不割手，兼具趣玩性与便携性。

荣耀Waterplay采用了哈曼卡顿调校的4个高品质立体扬声器，给予用户最纯臻的观感、听感。而对于热衷观影追剧的用户而言，10.1英寸且屏幕分辨率为1920×1200的IPS屏幕绝对够用，大屏之下的护眼功能可以有效地缓解用户的眼部疲劳。

荣耀Waterplay的防水级别达到IP67，不仅可以防止灰尘的吸入、渗透，还避免了短暂受水浸泡后的损伤。

CHERRY MX BOARD 1.0 TKL 机械键盘

追求极致手感

CHERRY MX BOARD 1.0 TKL外观上继续引用了“樱桃”家族式外观风格，棱角分明的边框，精工打磨软润的倒角，简洁明亮的CHERRY 金属LOGO放在正前方，让键盘整体看起来格外精致。

键盘上下边框采用斜坡式设计搭配原厂高度人体工学阶梯键帽，且上盖利用磨砂进行打造，一上手就无比细腻，搭配上茶轴开关段落行程短和触发压力小的优点，让用户弹指之间不失线性手感。

CHERRY MX BOARD 1.0 TKL内部采用镀金十字触点技术，避免接通和断开电源时，瞬间电流过大产生的电弧击伤。键盘还具有全键同击无冲功能，用户就算一次性按下所有的按键也不会出现按键冲突，非常符合电竞玩家的需求。

华硕 飞行堡垒 NX580

入门型轻薄游戏本

华硕飞行堡垒 NX580游戏本外观高贵优雅，整体机身都采用了精密制造程序铣削的高强度铝合金打造，且在外表加入了金属拉丝工艺，搭配薄度只有19.2mm的机身，摸起来手感舒适，优雅之间又夹带着时尚。

华硕飞行堡垒 NX580游戏本具备全尺寸LED背光键盘，采用无缝一体式设计，有着1.4mm的键程，三级亮度调整，给用户带来舒适的输入体验。此外，其触控面板原本带有指纹传感器，支持“一点登录”。

华硕飞行堡垒 NX580游戏本配有i7-7700HQ处理器，GTX1050 2G显卡，8G内存，128G SSD与1TB硬盘，可以畅通无阻地运行中小型游戏。

施耐德电气插电式PM2.5空气质量监测仪

空气质量监测新玩法

施耐德电气插电式PM2.5空气质量监测仪覆盖常规插座，采用一体化墙面美学、纯白无边，简约时尚。其白色的LED数值显示看上去一目了然。

施耐德电气插电式PM2.5空气质量监测仪采用PC防弹胶材质，能够高温阻燃、双重绝缘，安全使用。该监测仪具有专业红外检测技术，120秒快速检测，用户随时随地都可以准确地检查空气质量。

金洛克星脉K2指静脉智能锁

气得小偷直跺脚

金洛克星脉K2指静脉智能锁极具贵族气质，其表面由优雅高贵的香槟色金属拉丝材质打造，金属机身将黑色的触摸屏包裹其中，可谓琴心剑胆。

与普通的指纹智能锁不同，金洛克星脉K2指静脉智能锁采用独一无二的指静脉解锁技术，通过手指中流动血液内血红蛋白的成像来识别身份，无论老人还是孩子都不会出现无法识别开门的情况。

此外，金洛克星脉K2指静脉智能锁还可以通过微信小程序生成动态密码来帮助用户应付各种解锁环境。

佳明 vivosmart3 智能运动健康手环

运动首选 无感佩戴

佳明 vivosmart3 智能运动健康手环小巧智能，时尚、低调的外形设计，据说可搭配多种风格。

其采用了全新的柔软一体式表带，屏幕采用了隐藏式OLFD触屏设计，在不显示内容的情况下屏幕完全与腕带融为一体。

vivosmart3手环除了内置Elevte腕式光学心率监测技术外，还针对力量训练的运动模式新增训练功能。手机下载Garmin Connect，用户便可查看自己的活动信息，时刻掌握运动数据。

作为一款拥有蓝牙连接功能的健康手环，其配对后就可以查看天气、音乐控制、查找手机等。同时，它的常用功能还有计步、心率、爬楼数、中高强度活动时间等。

vivosmart3支持走路/跑步/其他/力量训练/有氧运动5种运动模式，运动时可以长按屏幕进入菜单手动创建运动，也可以开启Move IQ自动识别运动，操作十分简易。

TCL JSQ25-13EZ燃气快速热水器

温暖整个冬季

TCL JSQ25-13EZ热水器外观以白色为主配色，简洁、别致风范表露无遗，装饰于洗浴室的融合度极高。其黑色显示屏（操作面板）安于机身正面，触摸手感舒适。

TCL JSQ25-13EZ热水器自带的“涡轮增压”可以宽幅启动水压且自适应水压调节，即使水压不稳也可以确保热水器的正常使用，令用户畅享恒温热水。

为了提升用户体验，热水器还特意加入了精密比例气阀控技术，使得热水器的恒温效果达到最优越，避免遇到水温忽冷忽热的状况。

该热水器非常省电，能效等级达到了国家二级。除此之外，热水器还搭载了自动分段燃烧器，再配以极具科学性的智能芯片，让用户洗浴时感觉更加舒适与节能。

视贝扫地机器人抹抹4.0

最“纯粹”的扫地机

视贝扫地机器人抹抹4.0的外壳采用磨砂材质，利用无接缝滑盖设计，按住外壳就可以轻轻地向外推开。其支持红外线遥控控制，按键功能有自动清扫、局部清扫、沿墙清扫、Z字形、左螺旋和有螺旋路线六种模式可选择。

视贝扫地机器人抹抹4.0装载3组地检、8组墙检感应器，可应付各种危险障碍，同时拥有2200mAh大容量电池，据官方介绍可以续航2小时。此外，其还在底部设有魔术贴，可以将搭配的高迁抹布稳稳粘住，配合驱动轮实现边扫边拖。

施耐德电气天朗系列终端配电箱

内外兼修 实力“箱”伴

施耐德电气天朗系列终端配电箱设计时尚简约，气质大方，可以无痕融入风格迥异的住宅空间。

电箱采用高标准的ABS材料外壳，有着环保、耐腐蚀、物理性能强的特点。其金属面盖内折卷边安全结实，可强力抗变形。独特的腰孔设计能够轻松地辅助支架找平，使装修更灵活。

希捷Backup Plus Ultra Slim移动硬盘

史上最薄的1TB移动硬盘

希捷Backup Plus Ultra Slim移动硬盘正面采用了蜂窝圆点图案设计，光滑的铝合金表层与蜂窝图案融为一体，瞬间将硬盘提高了一个档次，华丽又时尚。其机身厚度为9.6毫米，在存储行业内的同容量产品中是最薄的一款。

希捷Backup Plus Ultra Slim移动硬盘虽然薄，但是有着1TB、2TB的容量，且内置自动识别系统驱动，只要插在电脑上即可使用，无需格式化便可以在PC和Mac两种设备间共享文件。

BOOX Max2电纸书

可以做显示器的电纸书

BOOX Max2沿用了往常长方形杂志轮廓，薄度为7.5mm。手感上面，其材质偏向于磨砂塑料材质，但是细滑程度绝对不亚于任何一种金属质感，完全不割手。

最为诧异的是其有着13.3英寸高清柔性Carta屏，搭配2200×1650超高清像素，观感舒适且护眼效果极佳。此外，BOOX MAX 2 新增了一个 MicroHDMI 接口，在连接上电脑之后，只需要打开 MAX 2 内置的显示器功能即可开始当做电脑显示器使用，显示时内容比较精细，还能减轻眼睛疲劳。

BOOX Max2搭载了四核CPU以及2G运行内存+32GB超大储存、安卓6.0操作系统。续航方面，BOOX Max2继续沿用了4100mAh大容量电池，可待机超过12小时。

西部数据My Cloud Hom e智能个人云

创意工作者必备

My Cloud Home外观具有家居范，上半身洁白且晶莹剔透，下半身则犹如钻石网格，摸上去手感不错，摆在家里不失为一件艺术品。

My Cloud Home能够帮助用户更好地管理存储内容的新型智能个人云存储解决方案。

用户可以通过My Cloud Home将手机、电脑、USB、云端和社交媒体的照片、视频及文件轻松集中在一个系统上进行管理，随时随地通过手机、平板电脑或计算机轻松连接云端，与家人、好友一起体验和分享精彩内容。

此外，西部数据还提供了My Cloud Home Duo双硬盘智能个人云，包含了My Cloud Home的全部功能，另外其还提供了一套设置为镜像模式（RAID 1）的双硬盘配置，自动复制其数据内容到第二个硬盘上，使用户倍加放心。

3.阿里P7架构师教你如何实现RabbitMQ 延时消息

RabbitMQ 延时消息的实现（上）

我们在实际业务中有一些需要延时发送消息的场景，例如：

1、 家里有一台智能热水器，需要在30分钟后启动

2、 未付款的订单，15分钟后关闭

注意这里的场景是延时，不是定时。当然，解决了延时，定时就很简单了（定时=当前时刻+间隔时间）。

由于RabbitMQ本身不支持延时队列（延时消息），所以要通过其他方式来实现。总的来说有三种：

1、 先存储到数据库，用定时任务扫描，登记时刻+延时时间，就是需要投递的时刻

2、 利用RabbitMQ的死信队列（Dead Letter Queue）实现

3、 利用rabbitmq-delayed-message-exchange插件

定时任务实现比较简单，此处略过。我们来看一下后两种方案分别怎么实现。

前提知识：我们可以在发送消息时指定单条消息的存活时间（Time To Live，TTL）。也可以设置一个队列的消息过期时间。

这两种方式，当队列中的消息到达过期时间（比如30分钟）仍未被消费，就会被发送到队列的死信交换机（Dead Letter Exchange，DLX），被再次路由，此时再次路由到的队列就被称为死信队列（Dead Letter Queue）。需要注意，死信交换机和死信交换机都是基于其用途来描述的，它们实际上也是普通的交换机和普通的队列。如果队列没有指定DLX或者无法被路由到一个DLQ，则队列中过期的消息会被直接丢弃。

因此，我们可以利用消息TTL的特性，实现消息的延时投递。

1、设置单条消息的过期时间的方法：

AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()

.deliveryMode(2) // 持久化消息

.contentEncoding("UTF-8")

.expiration("10000") // TTL，10秒后没有被消费则被发送到DLX

.build();

channel.basicPublish("", "TEST_TTL_QUEUE", properties, msg.getBytes()); //此处发送到 AMQP Default 这个默认的Direct类型的交换机，并路由到TEST_TTL_QUEUE队列

2、设置队列的消息过期时间的方法：

Map<String, Object> argss = new HashMap<String, Object>();

argss.put("x-message-ttl",6000); // TTL，6秒后没有被消费则被发送到DLX

channel.queueDeclare("TEST_TTL_QUEUE", false, false, false, argss);

注意：如果同时设置了消息的过期时间和队列的消息过期时间，则会取其中一个较小的值。比如消息设置5秒过期，队列设置消息10秒过期，则实际过期时间是5秒。

基于消息TTL，我们来看一下如何利用死信队列（DLQ）实现延时队列：

总体步骤：

1）创建一个交换机

2）创建一个队列，与上述交换机绑定，并且通过属性指定队列的死信交换机。

3）创建一个死信交换机

4）创建一个死信队列

4）将死信交换机绑定到死信队列

5）消费者监听死信队列

代码如下：

消费者：

因为此处使用默认的AMQP Default的Exchange，所以省略了第1）步，没有创建交换机。

这里用指定消息的TTL实现，所以设置队列TTL属性的代码注释了。

// 指定队列的死信交换机

Map<String,Object> arguments = new HashMap<String,Object>();

arguments.put("x-dead-letter-exchange","DLX_EXCHANGE");

// arguments.put("x-expires","9000"); // 设置队列的TTL

// 声明队列（默认交换机AMQP default，Direct）

channel.queueDeclare("TEST_DLX_QUEUE", false, false, false, arguments);

// 声明死信交换机

channel.exchangeDeclare("DLX_EXCHANGE","topic", false, false, false, null);

// 声明死信队列

channel.queueDeclare("DLX_QUEUE", false, false, false, null);

// 绑定，此处 Dead letter routing key 设置为 #，代表路由所有消息

channel.queueBind("DLX_QUEUE","DLX_EXCHANGE","#");

生产者：

String msg = "Hello world, Rabbit MQ, DLX MSG";

// 设置属性，消息10秒钟过期

AMQP.BasicProperties properties = new AMQP.BasicProperties.Builder()

.deliveryMode(2) // 持久化消息

.contentEncoding("UTF-8")

.expiration("10000") // TTL

.build();

// 发送消息

channel.basicPublish("", "TEST_DLX_QUEUE", properties, msg.getBytes());

消息的流转流程

生产者——原交换机——原队列——（超过TTL之后）——死信交换机——死信队列——最终消费者

如图：

使用死信队列实现延时消息的缺点：

1） 如果统一用队列来设置消息的TTL，当梯度非常多的情况下，比如1分钟，2分钟，5分钟，10分钟，20分钟，30分钟……需要创建很多交换机和队列来路由消息。

2） 如果单独设置消息的TTL，则可能会造成队列中的消息阻塞——前一条消息没有出队（没有被消费），后面的消息无法投递。

3） 可能存在一定的时间误差。

下一篇文章，我们来讲一下如何使用rabbitmq的延时消息插件来实现延时消息。

RabbitMQ 延时消息的实现（下）

在RabbitMQ 3.5.7及以后的版本提供了一个插件（rabbitmq-delayed-message-exchange）来实现延时队列功能。同时插件依赖Erlang/OPT 18.0及以上。

插件源码地址：

https://github.com/rabbitmq/rabbitmq-delayed-message-exchange

插件下载地址：

https://bintray.com/rabbitmq/community-plugins/rabbitmq_delayed_message_exchange

1、进入插件目录

whereis rabbitmq

cd /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.12/plugins

2、下载插件

wget https://bintray.com/rabbitmq/community-plugins/download_file?file_path=rabbitmq_delayed_message_exchange-0.0.1.ez

如果下载的文件名带问号则需要改名，例如：

mv download_file?file_path=rabbitmq_delayed_message_exchange-0.0.1.ez rabbitmq_delayed_message_exchange-0.0.1.ez

3、启用插件

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

4、停用插件

rabbitmq-plugins disable rabbitmq_delayed_message_exchange

5、插件使用

通过声明一个x-delayed-message类型的exchange来使用delayed-messaging特性。x-delayed-message是插件提供的类型，并不是rabbitmq本身的（区别于direct、topic、fanout、headers）。

代码：

消费者（先启动）：

// 声明x-delayed-message类型的exchange

Map<String, Object> argss = new HashMap<String, Object>();

argss.put("x-delayed-type", "direct");

channel.exchangeDeclare("DELAY_EXCHANGE", "x-delayed-message", false,

false, argss);

// 声明队列

channel.queueDeclare("DELAY_QUEUE", false,false,false,null);

// 绑定交换机与队列

channel.queueBind("DELAY_QUEUE", "DELAY_EXCHANGE", "DELAY_KEY");

// 创建消费者

Consumer consumer = new DefaultConsumer(channel) {

@Override

public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,

byte[] body) throws IOException {

String msg = new String(body, "UTF-8");

SimpleDateFormat sf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");

System.out.println("收到消息：[" + msg + "]\n接收时间：" +sf.format(new Date()));

}

};

// 开始获取消息

channel.basicConsume("DELAY_QUEUE", true, consumer);

生产者（后启动）：

// 延时投递，比如延时1分钟

Date now = new Date();

Calendar calendar = Calendar.getInstance();

calendar.add(Calendar.MINUTE, +1);// 1分钟后投递

Date delayTime = calendar.getTime();

SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");

String msg = "发送时间：" + sf.format(now) + "，投递时间：" + sf.format(delayTime);

// 延迟的间隔时间，目标时刻减去当前时刻

Map<String, Object> headers = new HashMap<String, Object>();

headers.put("x-delay", delayTime.getTime() - now.getTime());

AMQP.BasicProperties.Builder props = new AMQP.BasicProperties.Builder()

.headers(headers);

channel.basicPublish("DELAY_EXCHANGE", "DELAY_KEY", props.build(),

msg.getBytes());

channel.close();

conn.close();

控制台输出：

收到消息：[发送时间：2019-01-15 20:44:41.000，投递时间：2019-01-15 20:45:41.003]

接收时间：2019-01-15 20:45:41.064

2018已经过去过去，2019还想一成不变吗？拥抱变化，突破瓶颈，想要学习Java架构技术的朋友可以加我的群：725219329，群内每晚都会有阿里技术大牛讲解的最新Java架构技术。并会录制录播视频分享在群公告中，作为给广大朋友的加群的福利——分布式(Dubbo、Redis、RabbitMQ、Netty、RPC、Zookeeper、高并发、高可用架构)/微服务（Spring Boot、Spring Cloud）/源码（Spring、Mybatis）/性能优化（JVM、TomCat、MySQL）

4.热水神器：替你暖住整个冬日—TCL JSQ25-13EZ燃气快速热水器体验评测

冬日寒气来袭，疲惫的人们除了需要被窝暖身子，也终需热水驱寒，而往往一款好的燃气热水器不仅以即开即用的便利、避免漏电危险等优点深受人们喜爱，还因智能化操作被人所优选选择。

此番《消费电子》评测室选择了一款TCL JSQ25-13EZ燃气快速热水器进行评测，据悉，其具有能耗低、自适应水压调节等特性，性价比颇高。下面，就让我们一同体验一下吧！

别致简雅 黑白相配

外观方面，TCL JSQ25-13EZ热水器以白色为主配色，简洁、别致风范表露无遗，装饰于洗浴室的融合度极高。长方体轮廓浑圆一体，外观设计几乎看不到任何多余的元素，秉承着最简洁白净的理念，反而更能让人好感满满。

黑色显示屏（操作面板）安于机身正面，设定温度与室内温度按照常规数字形式呈现于显示屏正中间，升温、降温、功能以及开关功能键按一字排开，操作极其简易。热水进口、冷水进口、燃气进口和排水阀分别设置于机身底部，用户安装时也可以更便利，而且TCL JSQ25-13EZ热水器特意在底部刻上了文字提示，相当贴心。

安置于顶部的不锈钢材质的强排型排烟口可以有效地排离烟气，增强安全性的同时起到了延长使用寿命的作用。令人最为青睐的是，其侧面无缝一体型的造型，圆润的转角摸上去全然不割手，利于用户搬动安装。

水压自调节 恒温效果佳

对于读者而言，购入一款好的热水器会以恒温效果、水压效果以及安全性等方面作为购置标准，做工反而是第二要素。水压不稳定，出水量稳定性不佳都是冬日里最令人困扰的事情，而TCL JSQ25-13EZ热水器自带的“涡轮增压”性能恰恰解决了这一问题，宽幅启动水压且自适应水压调节，即使水压不稳也可以确保热水器的正常使用，令用户畅享恒温热水。

平时热水澡，一打开家里的热水器就会因水温问题而遇到被烫的风险，调低或调高温度所花费的时间并不少，所以TCL JSQ25-13EZ热水器特意加入了精密比例气阀控技术，使得恒温效果达到最优越，避免遇到水温忽冷忽热的状况，同时数字显示界面清晰的显示出了温度、运行状况，让用户时刻知悉运行情况。

搭载自动分段燃烧器 环保节能

节能方面，TCL JSQ25-13EZ的能效等级达到了国家二级，对于目前只有冷凝机为一级能效的热水器市场而言，强排机达到国家二级能效的确难能可贵，且其节能性绝对满足用户省电的需求。

TCL JSQ25-13EZ额定热负荷为25KW，往往通俗点理解额定热负荷越大，则燃气热水器的升数也会越大，所以25KW绝对满足一般家庭洗浴时出水量的舒适度。其中额定热负荷热水热效率为89%，50%额定热负荷热水热效率为85%，均符合二级节能评价值的88%和84%以上的最低标准。

此外，TCL JSQ25-13EZ还搭载了自动分段燃烧器，让用户的洗浴更加舒适、节能，再配以智能芯片控制，极具科学性。需要注意的是，TCL JSQ25-13EZ热水器应安装在与显示器平齐的高度，即据地1.6m左右，当热水器使用时，切记保持室内空气流畅。

产品参数表：

总结： 家用必备 性价比高

TCL JSQ25-13EZ热水器以简洁雅致的外观令人倾心，再配以贴心的性能设置，整体表现足以称为“家用必备品”。虽然用户对热水器的类别各有偏爱，但在节能表现上依旧强悍的TCL JSQ25-13EZ热水器，安全而恒温的特性绝对满足用户的使用需求。有兴趣的用户，可以考虑入手。

《消费电子》杂志是中华人民共和国工业和信息化部主管中国电子商会主办的一本集人物访谈、产品评测、行业风向、消费导购为一体的大型消费电子全产业链资讯刊物。