所有文章皆为原创，若转载请标明出处，谢谢~
新浪微博，欢迎关注：
2627282930311234568111213141617181920212223242526272812345678
随笔 - 148
评论 - 310
留言簿(53)
随笔分类(125)
随笔档案(147)
个人一直在使用中，在线观看www.youtube.com上高清视频一点都不卡。
每个月才18块钱，一个季度48，再超值提供一个9折优惠码：freevpnssh。
我平常在Linux下安装/更新软件，压根不用担心GFW阻挠了，
更不用提windows 7了。
阅读排行榜
评论排行榜如何应用MQTT协议到物联网中(IOT)
传统的web应用可能不需要可靠的消息服务，但当前以物联网为代表的多样终端非常需要一个消息协议来提供服务。
建筑模式来来往往，如果说有一个永恒不变的事情，那就是需要一个可靠的消息传输。
消息队列也许在客户端/服务端世界有过它的盛世高峰，它处理大型机之间的信息交流并与我们的财务网络连接，但是它从来没有离开我们---尽管事实上直接访问api是大多数当前开发的主要特点。
直接访问api在大多数我们的web系统中工作良好，在有限的服务器资源及进程通信的后端。然而当我们转移到微型服务架构以及云---特别是我们面对物联网的时候，那么事情改变了。
突然，由于物联网的因素，我们将处理由不同规则部署的数不清的组件系统，还要处理终端发来的成千，可能不是上万条的业务消息。在这种情况下，著名的mvc设计模式将不能使用，所以我们需要转换到微服务-安全模式，回去计算机场景概念就像是参与者，使用参与者/消息模式去处理我们的服务如何与任意数量的终端进行通信。
发布订阅的救援
这是消息队列工具要发挥的作用，使用发布/订阅模式为将数据传输到服务器端提供可靠的方法。微服务参与者可订阅到已发布的连接并对接收到信息触发相应的动作。这种模式很适合将设备和服务连接起来，当有新的设备不断增加时仍能确保服务稳定。
由IBM开发的MQTT(消息队列传输协议）是一个轻量级的发布/订阅消息协议，目前已经被OASIS标准化。最初它被设计为大规模的WebSphere MQ系统与SCADA设备链接,后来MQTT演变成为通用的目的消息队列系统，它能允许一台服务器管理成千上万个终端，这是一个很简单的消息协议它并不限制于TCP/IP，能被很有限处理能力的设备所使用。
发布/订阅协议并不陌生。不过它也许在大多数开发者工具箱的底层里，它们是一个为服务架构创建消息大巴简单方法。MQTT是发布/订阅模相关的简单执行，通过消息发布到主题，而主题将会被客户端应用订阅。主题是按等级划分的，所以你可以订阅一个资源中的不同等级的信息元素。
等级划分的主题
例如，货车中的冷冻装置中的一系列传感器可以这么组成一个等级划分的主题格式：冷冻装置传感器/卡车/温度/区域，这里卡车和区域可用于标识过滤信息：一个车辆或一个区域下的多个车辆信息。
应用程序可订阅MQTT服务器上可用的主题，使用明确的订阅获取指定的消息种子，或使用通配符获取不同等级主题聚集的消息。你可以使用通配符替换一个等级架构中的一层或所有其余的元素。
在我们事例中，仪表货车+冷冻装置传感器+温度能让我们看到所有区域里所有卡车上的温度，同时，冷冻装置传感器/卡车1#将获得名字为卡车1上的所有冷冻传感器上的数据。这个方法意味着你可能使用多个微服务处理不同的主题--一个每天处理特定传感器或数据的监控，另一个处理观察错误情况等等。
MQTT提供保持最后一条消息发送的选项，因此当前的客户端连接到服务端时，就有可能在订阅的同时下载初始消息而不用等待从源发送新的消息。源还有一个选项"Will"--一个预先存储在服务器上的消息用于在断开连接时递送。客户端在will模式下可以断开连接，当然如果他们没有清空sesssion标记，可以重新连接并查看存在的订阅。联合使用session flags和wills令你可以处理源于不稳定的网络及自动化服务规模的问题。
设置服务质量
MQTT中一个非常有用的特色就为你的消息设置QoS规则的能力。这里有三个Qos级别可以使用：
Level 0：是最佳劳动选项，即出错后无条件重试。这种方法很适合用于持续的监测像趋势事务而不是实际的消息。作为控制系统的一部分，你可能使用level 0连接到流处理器或者一个机器学习系统来处理大量的消息。
Level 1：是”至少一次（at least once)“选项，用于消息可以保证被递送，尽管多次递送可能产生。如果你在处理消息量较少，通过编程处理重复项，这将是你的最佳选项。非常快，且低影响，并能与各种不同应用程序模块工作。
只有一次：是最为计算强调的层次，但它保证每个消息有且只有一次被接收到。
在内部，MQTT是一个非常简单的协议，它为构建物联网应用程序或超大规模云中的处理能力提供思想。当新的设备被添加到网络中，他们可以快速成为新的主题资源，同时新的客户端可以它们创建同时订阅主题。URI 方案令连接服务器接收消息非常简单。有大量的工具提供帮助测试MQTT连接，包括桌面和移动应用---即使是使用websockets的app应用。
使用MQTT为物联网创建消息驱动的服务非常简单，有各种服务包括知名的Mosquitto以及用于Arduino的事例代码及其它制造商。在客户端,MQTT同时被知名的工具支持，包括 Node.js-基于Secene microservices framework及visual Node-Red programming environment,伴随着成长的社区论坛帮你开始创建你的应用。
担心MQTT协议如何在现实世界中执行？这里有一个很好证明：它为互联网中最大也是最忙的应用提供支持，这就是:Facebook's Messenger
本文来自：
没有更多推荐了，MQTT--NodeMCU及MQTT接发消息体验 - 简书
MQTT--NodeMCU及MQTT接发消息体验
使用MQTT先要有一个MQTT服务器，具体如何搭建可以看上一篇文章
这一篇主要讲下NodeMCU的使用，以及MQTT介绍和如何接发消息
1. ESP8266介绍
介绍NodeMCU前需要先了解ESP8266，它是一个完整自称体系的WiFi网络解决方案，能独立运行也可为从部件连接单片机运行
具有以下特点：
内置TCP/IP协议
2. NodeMCU介绍
NodeMCU是一款基于ESP8266模块的开源硬件，符合Arduino框架。同时可使用Node.js编程
3. WiFi测试
先要安装Arduino IDE For ESP8266
Arduino IDE For ESP8266是根据Arduino修改的专门烧写ESP8266开发板的IDE。在装好Arduino IDE后：
打开Arduino 文件-&首选项，在 附加开发管理网站 中填入，然后点击确定保存
重启IDE后，打开 工具-&开发板-&开发板管理器；搜索ESP8266，选择esp 8266 by ESP8266 Community安装
下载完成后可以在开发板选项中看到ESP8266 Module,以及NodeMCU等可选开发板
将NodeMCU通过usb连接到电脑，在工具下选择相应配置
波特率越大烧录程序速度越快但有可能出错
端口选择NodeMCU对应端口，如果没看到端口，那是驱动没有装，装驱动可以看这里
打开示例选择ESP8266WiFi中的WiFiScan
烧到板子上打开窗口监视器可以看到扫描出来的附近热点
1. MQTT介绍
消息队列遥测传输(MQTT)是IBM开发的即时通讯协议，为计算能力有限且工作在低带宽、不可靠网络的传感器或控制设备而设计。比如对于移动开发，它可以用于消息推送，即时通讯等等
发布/订阅的消息模式，提供一对多的消息发布
使用TCP/IP提供网络连接
有三种消息发布服务质量，至多一次，至少一次，只有一次
传输小、开销小
LastWill通知中断机制
2. MQTT原理介绍
客户端：发布者(Publish)、订阅者(SubScribe)，客户端有ID,ID冲突会挤掉先连接客户端。
服务器端：代理(Broker)
消息：主题(Topic)+负载(payload)
举个场景为例：
QQ用户2(账号QQ1000)向QQ用户1(QQ9999)发送消息“Hello World”.
发送者：QQ用户2
订阅者：QQ用户1
消息：QQ9999+”Hello World”.
消息发送至服务器，服务器查找QQ9999对应的用户后，发送信息给QQ用户2.
3. MQTT ESP8266库
菜单“项目”-“加载库”-“管理库”，搜索安装“PubSubClient”
PubSubClient有一些示例可以打开mqtt_esp8266看下
4. MQTT接发消息体验
这里做两个示例
1. NodeMCU发布消息：光照强度传感器测得环境光照强度发布到服务器，手机订阅该Topic接收光强信息
#include &ESP8266WiFi.h&
#include &PubSubClient.h&
int pinLED = D2;
const char* ssid = "********";//连接的路由器的名字
const char* password = "********";//连接的路由器的密码
const char* mqtt_server = "********";//服务器的地址
const int port=****;//服务器端口号
WiFiClient espC
PubSubClient client(espClient);
int light=255;
void setup_wifi() {//自动连WIFI接入网络
delay(10);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print("...");
void callback(char* topic, byte* payload, unsigned int length) {//用于接收数据
for (int i = length-1; i &=0; i--) {
l+=(int)((char)payload[i]-'0')*p;
Serial.println(l);//换行
void reconnect() {//等待，直到连接上服务器
while (!client.connected()) {//如果没有连接上
if (client.connect("biloba")+random()) {//接入时的用户名，尽量取一个很不常用的用户名
client.subscribe("LED");//接收外来的数据时的intopic
Serial.print("failed, rc=");//连接失败
Serial.print(client.state());//重新连接
Serial.println(" try again in 5 seconds");//延时5秒后重新连接
delay(5000);
void setup() {//初始化程序，只运行一遍
Serial.begin(9600);//设置串口波特率（与烧写用波特率不是一个概念）
setup_wifi();//自动连WIFI接入网络
client.setServer(mqtt_server, port);//端口号
client.setCallback(callback); //用于接收服务器接收的数据
void loop() {//主循环
reconnect();//确保连上服务器，否则一直等待。
client.loop();//MUC接收数据的主循环函数。
analogWrite(pinLED,light);
先使用ESP8266WiFi库的方法连接一个wifi，连接成功后loop中获取光强并转换为json格式，发布到light的Topic主题下，可以打开服务器web管理页面，可以在Topic找到它
接着试着用手机app订阅接收传感器发的消息（具体Android端如何实现下篇文章会讲到），在google play中下载一个myMqtt的APP，不方便的可以在这里下
打开APP，在setting中设置你服务器ip，端口等保存，如果顶部显示绿色表明连接成功，在Subscribe中订阅light主题，返回到Dashboard就能实时收到消息
1. NodeMCU接收消息：连接一个led灯，用手机APP控制灯的亮度
#include &ESP8266WiFi.h&
#include &PubSubClient.h&
#include &math.h&
int pinLED = D2;
const char* ssid = "********";//连接的路由器的名字
const char* password = "********";//连接的路由器的密码
const char* mqtt_server = "********";//服务器的地址
const int port=****;//服务器端口号
WiFiClient espC
PubSubClient client(espClient);
int light=1024;//led的亮度值
void setup_wifi() {//自动连WIFI接入网络
delay(10);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print("...");
void callback(char* topic, byte* payload, unsigned int length) {//用于接收数据
//将char* 转换为int
for (int i = length-1; i &=0; i--) {
l+=(int)((char)payload[i]-'0')*p;
light=l;//赋值给light
Serial.println(l);
void reconnect() {//等待，直到连接上服务器
while (!client.connected()) {//如果没有连接上
if (client.connect("biloba")+random()) {//接入时的用户名，尽量取一个很不常用的用户名
client.subscribe("LED");//接收外来的数据时的intopic
Serial.print("failed, rc=");//连接失败
Serial.print(client.state());//重新连接
Serial.println(" try again in 5 seconds");//延时5秒后重新连接
delay(5000);
void setup() {//初始化程序，只运行一遍
Serial.begin(9600);//设置串口波特率（与烧写用波特率不是一个概念）
setup_wifi();//自动连WIFI接入网络
client.setServer(mqtt_server, port);//端口号
client.setCallback(callback); //用于接收服务器接收的数据
void loop() {//主循环
reconnect();//确保连上服务器，否则一直等待。
client.loop();//MUC接收数据的主循环函数。
analogWrite(pinLED,light);//设置led亮度
代码跟上面没太大区别，只不过这里不发信息了，而接收LED Topic的信息，接收到转换为int设置为灯的亮度，这样就实现远程app控灯。打开myMqtt的publish，输入Topic为LED，Message为灯的亮度（0-1024），可以实时控制灯
当能力达不到自己的野心时，静下心来学习。
前言 MQTT是IBM开发的一个即时通讯协议，面向M2M和物联网的连接，采用轻量级发布和订阅消息传输机制，并且有可能成为物联网的重要组成部分。 ESP8266是一款物美价廉的Wi-Fi芯片，集成Tensilica L106
钻石系列的32 位处理器和片上SRAM，多达17...
Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智能路由，微代理，控制总线）。分布式系统的协调导致了样板模式, 使用Spring Cloud开发人员可以快速地支持实现这些模式的服务和应用程序。他们将在任何分布式...
入门 nodeJS net模块 demo01 概述： TCP/IP 传输层协议，主要解决数据如何在网络中传输 Socket 对Tcp/Ip协议的封装和应用 Http 应用层协议，主要解决如何包装数据 网络五层模型 物理层，数据链路层，网络层，传输层，应用层 单向通信： 使用...
背景 近来公司需要做一个即时通讯工具，选型用MQTT协议来做。于是仔细搜集MQTT相关的了一些资料，并分享出来供大家参考。 MQTT简介 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，它是...
1、概述 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是IBM开发的一个即时通讯协议，有可能成为物联网的重要组成部分。该协议支持所有平台，几乎可以把所有联网物品和外部连接起来，被用来当做传感器和致动器（比如通过Twit...
你已经高三了，为什么还沉迷于手机，别人都在弯道超车，你呢，你在玩手机，你的梦想不是玩玩手机就能实现的，何况还是那么难实现的一个梦，亲爱的，看看你的前桌，你要有她的毅力和坚持，还会是现在这个模样吗？整天幻想有什么用，就算生病难受也要坚持啊！最后一次警告自己，明天手机要关机！再见！
早晨在海鸥的鸣叫声中醒来，布莱顿是著名沿海城市，环境优美景色秀丽，随时都可以看到翩翩飞翔的海鸥，如果你碰巧拿着食物海鸥就会俯冲下来抢吃抢喝，有时也挺吓人的。 今天终于晴天了，没有雾霾的天空真美啊！ 布莱顿的公交系统太发达了，每个社区的每条街都有公交车，而且准点的可怕，一分钟...
今天八点多醒的，起来学了一会习，大概一个小时左右吧，哎……宿舍是堕落的祸源，去教室学习，也许会好一点吧。。。
下午睡了好长时间，多长时间不知道，起来感到有点头疼，也不知道睡多了还是睡少了/小纠结。起来后一个舍友说:&你是从火星来的吗&我:&为什么这么说……&舍友...
民警来了，他们决定先采用保守方案，了解女子跳楼原因，有针对性地对她进行劝说。 这名女子叫楚谢（化名），是这间屋子的租客。房东匆忙间也及时赶来，面带焦虑，声音有点失控，“她说我这里不好，那里不好，我说要不你就别住了，重新找房子吧。”房东不免有些自责，似乎楚谢此次轻生的举动自己...
爱情都是需要物质维持的吗
感觉自己的爱情就好像人们所说的无事不登三宝殿一样，还是自己不够信任对方吗？> MQTT-BOX102 多比物联MQTT物联网关介绍
多比物联MQTT-BOX102采集各种工控设备（PLC、采集器、仪器仪表和传感器）的数据，并通过MQTT物联网协议或者其它应用协议（如HTTP/MySQL/SQL Server/Oracle等）经由4G/3G/有线网传送到百度天工、阿里云、微软Azure、多比物联网云组态等工业物联网云平台。MQTT-BOX102系列产品，是一款一个网口，支持4G/3G/PPPOE/ethernet等各种网络接入方式、支持各种工控协议解析，支持MQTT上行协议，支持网关信息采集管理，支持设备和变量的定义和远程部署、支持自定义方式的数据采集和数据控制和支持防火墙等功能为一体的嵌入式工业级智能MQTT网关。多比物联MQTT-BOX102适合作为大规模的分布式设备的接入节点，内嵌Modbus RT/Modbus TCP， OPC，Bacnet等1000+种工业协议解析器，可以通过协议分析把现场设备的数据先收集到网关节点计算分析，然后再通过MQTT协议或者其它应用协议（支持自定义MQTT协议）上传到云端或Web 服务器端。方便客户的应用系统通过MQTT服务器（如）和消息队列实现数据的采集和远程控制；同时各种网关管理、部署、应用等高级功能。 广泛应用于能源、风电、配电、电梯、空压机、包装机械、注塑机、石油钻井机械、机加工设备、供水设备、热力锅炉、光伏电厂、医疗器械、化工设备、物业管理等泛工业领域。多种网络接入、易于部署和完善的管理及应用功能协助客户构建工业物联网系统。一、产品特性1.&丰富接口、易于部署4G、3G、PPPOE网络、232/485串口终端通信，为不同的应用场合提供不同的接入方案。2.&万物互联、高效接入内嵌协议分析器，支持Modbus RT/Modbus TCP， OPC，Bacnet等1000+种工业协议转化为MQTT协议；通过场景Agent技术将策略规则计算和应用部署分发实现本地计算，提高设备的智能控制能力和实时性能。内嵌工业协议栈（包括但不局限于西门子PLC、欧姆龙PLC、ABB/GE等PLC协议， Bacnet， 能耗规约，水利规约，环保规约等国标或国际标准），实现现场复杂机器类型的标准化接入，不仅可以实现数汇聚到数据中心进行计算存储，同时可以实现远程控制和远程发布。·&内置协议栈:TCP，UDP，IPv4，SNMPv1/v2/v3，ICMP，ARP，HTTP，CHAP，PAP，DHCP，NTP，NFS，SMTP， Telnet，FTP，TFTP，PPP，PPPoE·&Modbus协议族:支持ModbusRTU协议、Modbus/TCP协议,ModbusASCII协议·&BACnet协议族:BACNET_MSTP, BACNET_BIP,BA_CJT1882004·&国际标准规约:、ProfiNet、EtherNet、DNP3.0协议、SNMP协议、DTL645协议、CDT协议、NET PING协议等。·&电力规约: 电力IEC101规约、电力IEC103规约、电力IEC104规约（IEC,IEC,IEC,IEC)等·&西门子PLC通信协议:&西门子PPI、西门子S7协议,西门子200、西门子300、西门子400、西门子1200、西门子1500, 西门子200 SMart协议，PLC_SIEMENS_S7_SMART·&欧姆龙PLC通信协议：PLC_OMRON_HOSTLINK协议·&富士通PLC通信协议：PLC_FUJI_SPH2000协议·&GE PLC通信协议:PLC_GE_ETHERNET协议·&三菱PLC通信协议:PLC_MITSUBISHI_FX协议，PLC_MITSUBISHI_Q_TCP协议·&ABB PLC通信协议:PLC_AB_DF1协议,PLC_AB_ETH协议,PLC_AB_LOGIX_CIP协议·&OPC协议族: OPC DA协议, OPC XML DA协议·&支持台达、浙江中控等国产PLC·&其他国标规约:环保协议、消防协议、粉尘监测、212&环保规约、住建部能耗规约等·&其他规约:CDT91,1997版本DLT645,2007版本DLT645·&支持自定义的驱动程序&3.&构建高性能、高并发应用系统支持接入各种主流MQTT服务器（如Mosquitto/ActiveMQ/百度天工云/阿里IOT等等）和消息队列等各种高性能平台服务套件，实现复杂的高性能、高并发的系统；通过使用成熟的PAAS服务实现按量收费、弹性伸缩，节省项目的研发和建设成本。4.&强大的安全功能1）数据传输安全 ：支持数据加密压缩安全传输。2）网络防护安全：内置防火墙；内置独立硬件加密电路，保护用户IP。3)所有节点提供身份验证和端到端加密服务，这些节点包括设备端和各个云服务，物联网套件还提供了设备级的权限粒度服务，这个服务保证设备或者应用程序只有具有相应的访问权限，才能操作某些资源。5.开放式嵌入式平台、支持定制化开发高性能CPU的计算能力胜任各种复杂计算；丰富的系统资源适合开发各种复杂的应用。采用开放式平台设计理念，可以针对特定的应用场景和应用需求让客户自行或者由多比物联开发团队开发相应的APP并加载到网关系统中。二、产品应用举例1、数据采集、协议分析通过多比物联的MQTT智能网关的协议分析器把现场各种设备的数据读取到智能网关内部进行协议解析和边缘计算，然后对数据进行标准化处理后用MQTT的方式接入到物联网套件中。支持对接各种仪器仪表、支持对接各种Modbus采集器、支持对接485/232传感器,支持对接主流的大部分PLC设备（如施耐德、台达、三菱、西门子、欧姆龙、倍福、ABB等）2、远程定义、远程部署配置多比物联MQTT智能网关支持采集方式、变量表（点表）和规则设定在云平台上定义好，然后远程把配置工程下发到现场网关；然后现场网关根据平台定义的方式对设备进行数据挖掘和分析，并以一定的周期和方式上报到平台。3、状态监控，远程运维支持远程监控网关的系统状态、MQTT的链路状态、网络状态，支持远程维护网关和远程维护设备，支持远程部署应用程序到网关上。三、规格参数&主系统CPU：工业级Cortex-A8架构，800MHzRAM：512 DDR3 SDRAMFlash：512MB Flash存储扩展： 内嵌大容量SD存储卡，最大64GB网络接口LAN：10/100Mbps自适应，&RJ45隔离保护：15KV空气放电及8KV接触放电保护串行接口RS485串口（DATA＋、DATA－、GND），RS232串口（TXD、RXD、GND）光电隔离： &每通道独立光电隔离串口保护： &所有信号线均提供 15KV ESD流向控制： &RS485 自动数据流向控制GPRS/3G/4GGPRS射频波段：四频850/900/MHz无线通讯GPRS等级：Class 8/10编码机制：CS1～CS43G射频波段：00MHz标准：CDMA2000/WCDMA/TD-SCDMA4G射频波段：00MHz标准：TDD-LTE/FDD-LTE按钮功能：支持“重置为出厂默认设置”LED指示灯系统：电源、运行串口：TX/RX网络：ACT/LINK（位于 RJ45 连接器）GPRS：工作状态指示DI/DO：输入/输出状态指示RTCRTC： 内嵌后备锂电池RTC机械特性外壳：型材（&1.5mm）重量：600g尺寸：137×89×55 mm安装方式：导轨安装安全性看门狗 ：硬件看门狗（WDT）监控MTBF：大于10万小时硬件加密： 内建独立硬件加密电路，保护用户IP工作环境工作温度：-40～80℃工作湿度：5～95% RH存储温度：-50～100℃抗震性能：1G@IEC-68-2-6，正弦波，5～500 Hz，1 Oct./min，1 hr/axis抗冲击：5G@IEC-68-2-27，半正弦波，30 ms电源需求电源输入：12～30VDC，推荐使用24V DC系统功耗：&10 W&
Recent Search Keywords}