二、MQTT C Client实战

了解更多可以阅读《MQTT C Client for Posix and Windows》一文，下面根据官网资料，摘录了几个C语言实现MQTT的小DEMO。

MQTT使用起来也十分容易，基本上就那四五个函数：MQTTClient_create（创建客户端）、MQTTClient_connect（连接服务端）、MQTTClient_publishMessage（客户端->服务端发送消息）、MQTTClient_subscribe（客户端订阅某个主题）等等。其中，很多异步回调函数，需要自己去实现，如，

MQTTAsync_setCallbacks(mqtt->_client, mqtt->_client, connlost, msgarrvd, NULL);

MQTTAsync_setCallbacks中，

• connlost函数指针，是当MQTT意外断开链接时会回调的函数，由自己实现；
• msgarrvd函数指针，是当服务器有消息推送回来时，客户端在此处接受服务端消息内容。

另外，就是一些函数执行是否成功的回调函数，C语言封装回调之后，就是这么写法，看起来有些变扭。有兴趣的可以看《浅谈C/C++回调函数（Callback）& 函数指针》文章，再了解以下回调函数。

mqtt->_conn_opts.onSuccess = onConnect;
mqtt->_conn_opts.onFailure = onConnectFailure;

最后，不得不说的就是，MQTT有些发送或者是订阅的内容时（某些函数中），在编程最好将参数中传进来的值在内存中拷贝一份再操作，笔者当时开发时，就是因为这样的问题，折腾了较长时间，后来在wireshark中发现数据包中根本没有内容，才知道是由于函数参数是指针形式，直接在异步中使用可能会发生一些未知的错误。

参考文档：

https://yq.aliyun.com/articles/521549?spm=5176.10695662.1996646101.searchclickresult.39f82372vfl8ed

三、MQTT client for Node.js

Installation

You can install it as dependency with npm.

$ # save into package.json dependencies with -S

$ npm install aliyun-iot-mqtt -S

Usage

Aliyun IoT Hub mqtt client with authrozied by productKey & deviceName & deviceSecret.

GET Data

const Mqtt = require('aliyun-iot-mqtt');
const client = Mqtt.getAliyunIotMqttClient({
    productKey: "",
    deviceName: "",
    deviceSecret: "",
    regionId: "cn-shanghai",
    keepalive:120 // mqtt options
client.on('message', function(topic, message) {
    console.log(topic+"," + message.toString())
参考文档：
 
https://www.npmjs.com/package/aliyun-iot-mqtt
                    一、MQTT二、MQTT C Client实战了解更多可以阅读《MQTT C Client for Posix and Windows》一文，下面根据官网资料，摘录了几个C语言实现MQTT的小DEMO。MQTT使用起来也十分容易，基本上就那四五个函数：MQTTClient_create（创建客户端）、MQTTClient_connect（连接服务端）、MQTTClient_publ...
compile 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
compile 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.1.1'
MQTT客户端通常实现在一个Service中(Service保活详见主页文章)，在Service的onStartCommand（）方法中需要先对
同一 mqttClient 先订阅一个主题消息再向另一个主题发送消息（两个主题不一样）
创建 mqttClient  的 clientId 是固定的和随机的都会产生错误
发布消息和订阅消息都成功，未发现其他报错
注释发布消息，只订阅消息，未产生错误
注释消息订阅，只发布消息，未产生错误
..............................
1. Android端实现消息推送的几种方式
轮询：客户端定时向服务器请求数据。伪推送。缺点：费电，费流量。
拦截短信消息。服务器需要向客户端发通知时，发送一条短信，客户端收到特定短信之后，先获取信息，然后拦截短信。伪推送。缺点：贵而且短信可能被安全软件拦截。
持久连接(Push)方式：客户端和服务器之间建立长久连接。真正的推送。
这里订阅的意思就是当服务器没有启动的时候，默认情况下，如果客户端如果直接发送一个调用的请求的话，会立刻抛出一个异常：
failed to connect to all addresses
但是如果我们调用了  subscribe  方法，此时就可以让客户端对服务端的启动进行等待，当服务端完成启动之后，客户端接收到启动的通知后，再对对应的  grpc  方法进行调用。
# 创建一个  channel
channel = grpc.insecure_channel(server_address)
				
推荐一款稳定的基于C编写的MQTT Client开源库 cMQTT
MQTT协议详解及开发教程（一）MQTT协议概述
MQTT协议详解及开发教程（二）MQTT服务器EMQx搭建
MQTT协议详解及开发教程（三）MQTT Client工具软件选择及简单测试
MQTT协议详解及开发教程（四）MQTT协议报文格式
MQTT协议详解及开发教程（五）CONNECT/CONNACK报文分析
MQTT协议详解及开发教程（六）PUBLISH发布QoS0消息报文分析
MQTT协议详解及开发教程（七）PUBLISH发布QoS1
  在文章Paho - MQTT C Cient的实现中，我介绍了如何使用Paho开源项目创建MQTTClient_pulish客户端。但只是简单的介绍了使用方法，而且客户端的结果与之前介绍的并不吻合，今天我就结合新的例子，给大家讲解一下Paho使用MQTT客户端的主要过程。 
  如同前面介绍的，MQTT客户端分为同步客户端和异步客户端。今天主要讲解的是同步客户端，结构还是如同步客户端中
				
看到网上的部分代码，对于订阅主题后，使用mqttCallBack接口来接收消息，虽然这种方法也可以接收到消息，但是mqtt Paho提供了正规的方法去接收消息，这里分享一下自己的demo。
使用callback接口订阅类：
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.cl...
当用户刚进入系统，这个时候，查找storage中是否有用户信息
如果有，则直接使用mqtt.js直接连接，创建client，把client赋值给全局变量
如果没有，跳到login页面，登录成功后，创建client，并将client复制给全局变量
加入现在在客服页面，客服页面应subscrib...
				
### 回答1：
MQTT是一种轻量级的消息传输协议，适用于物联网设备之间的通信。在Linux系统下，可以使用C语言实现MQTT协议。具体实现可以参考MQTT C Client库，该库提供了一些API函数，可以方便地实现MQTT客户端的开发。在使用该库时，需要注意一些细节，如连接服务器、订阅主题、发布消息等。同时，还需要了解MQTT协议的一些基本概念，如QoS、保留消息、遗嘱消息等。总之，使用C语言实现MQTT协议需要一定的技术水平和经验，但是可以为物联网设备的通信提供可靠的支持。   
### 回答2：
MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，适用于物联网设备之间的通信。MQTT协议采用“发布/订阅”模式，订阅者可以在发布者发送消息时接收到消息，从而实现设备间的实时通信。
在Linux系统下，可以使用C语言实现MQTT协议。下面是MQTT C语言库的实现步骤：
1. 下载MQTT库
在Linux系统中，可以下载paho.mqtt.c库。在终端中输入以下命令：
git clone https://github.com/eclipse/paho.mqtt.c.git
这个库是Eclipse提供的一个MQTT C语言客户端库，可以在Linux系统中实现MQTT协议的通信。
2. 编写代码
可以使用C语言编写MQTT协议通信库。具体实现使用Eclipse的Mosquitto库。
3. MQTT库的程序结构
使用MQTT库必须有一个主程序结构，主要包括初始化连接，连接与订阅等操作。主程序结构如下所示：
#include <stdio.h>
#include <mosquitto.h>
int main()
    struct mosquitto *mosq = NULL;
    int rc;
    mosquitto_lib_init();
    mosq = mosquitto_new("subscriber-test", true, NULL);
    if (mosq) {
        rc = mosquitto_connect(mosq, "broker.hivemq.com", 1883, 60);
        if (rc == MOSQ_ERR_SUCCESS) {
            mosquitto_subscribe(mosq, NULL, "test", 0);
            mosquitto_message_callback_set(mosq, my_message_callback);
            mosquitto_loop_forever(mosq, -1, 1);
        } else {
            printf("Failed to connect, return code %d\n", rc);
    } else {
        printf("Failed to create mosquitto client object\n");
    mosquitto_lib_cleanup();
    return 0;
上述代码中mosquitto_new()函数创建了一个MQTT客户端，并连接到了MQTT服务器broker.hivemq.com。然后使用mosquitto_subscribe()函数订阅了“test”主题，并使用mosquitto_message_callback_set()函数设置回调函数。
4. MQTT的回调函数
当MQTT订阅了消息时，服务器会发送消息到客户端。此时需要使用客户端的回调函数响应MQTT服务器的消息。回调函数如下：
void my_message_callback(struct mosquitto *mosq, void *userdata, const struct mosquitto_message *message)
    printf("New message with data %s\n", (char *)message->payload);
    mosquitto_disconnect(mosq);
上述代码中的回调函数使用了mosquitto_disconnect()函数断开了MQTT连接。
5. 编译代码
使用gcc编译MQTT代码，如下：
gcc -lmosquitto -o subscriber-test subscriber-test.c
6. 运行代码
在终端中运行MQTT代码，如下：
./subscriber-test
通过上面的步骤，就可以在Linux系统中使用C语言实现MQTT协议的通信。   
### 回答3：
MQTT（Message Queuing Telemetry Transport，消息队列遥测传输）是一种轻量级的发布/订阅模式的消息传递协议，旨在实现设备与设备之间的通信。它广泛应用于物联网、传感器网络等领域。而在Linux环境下，可以通过C语言实现MQTT协议。
首先，我们需要安装mqtt库。常用的mqtt库包括libmosquitto、paho等。这里我们以libmosquitto为例进行介绍。在Ubuntu系统下，可以通过以下命令安装：
sudo apt-get install libmosquitto-dev
安装完成后，我们可以通过以下的C代码来实现mqtt的发布和订阅：
#include <stdio.h>
#include <stdlib.h>
#include <mosquitto.h>
void on_connect(struct mosquitto *mosq, void *obj, int rc) {
    printf("Connected\n");
void on_message(struct mosquitto *mosq, void *obj, const struct mosquitto_message *msg) {
    printf("Received message: %s\n", msg->payload);
int main (int argc, char *argv[]) {
    struct mosquitto *mosq = NULL;
    mosquitto_lib_init();
    mosq = mosquitto_new("ClientID", true, NULL);
    mosquitto_connect_callback_set(mosq, on_connect);
    mosquitto_message_callback_set(mosq, on_message);
    mosquitto_connect(mosq, "localhost", 1883, 60);
    mosquitto_subscribe(mosq, NULL, "topic", 0);
    mosquitto_publish(mosq, NULL, "topic", strlen("message"), "message", 0, false);
    mosquitto_loop_forever(mosq, -1, 1);
    mosquitto_destroy(mosq);
    mosquitto_lib_cleanup();
    return 0;
在这里，我们首先通过调用mosquitto_lib_init()函数初始化mqtt库，在mosq = mosquitto_new("ClientID", true, NULL)中创建一个新的mqtt客户端，mosquitto_connect()连接到消息代理服务器。然后，通过调用mosquitto_subscribe()和mosquitto_publish()函数来订阅和发布消息。最后，在mosquitto_loop_forever()函数中开启mqtt客户端的接收循环。
在以上代码中，我们也可以通过on_connect()函数和on_message()函数来处理连接和接收消息的回调。这些回调函数可以很好地帮助我们处理mqtt消息。
需要注意的是，使用C语言实现mqtt时，需要手动处理许多细节，包括消息头的处理，连接和消息超时的处理等。因此，如果您没有足够的基础，建议先熟练掌握mqtt的基本概念和用法，再开始写代码。
总之，通过C语言实现mqtt协议可以为物联网和传感器网络的开发提供更多的灵活性和定制性。虽然C语言的编写难度较大，但是它可以提高代码的效率，并提供更多的控制和自定义功能。
                    ArtNowBen: 
                    推荐一个网络压测工具dperf。
dperf可以测试带宽、PPS、新建连接数、并发连接数，能够准确发现丢包。比idperf好用，很多公司用dperf测试防火墙、F5、DPVS等的性能。
项目地址https://github.com/baidu/dperf
它实现了小型的TCP/UDP/http协议栈，实现了HTTP客户端/服务器，性能达到100Gbps，每秒1千万HTTP新建，几十亿并发连接数，里面有设计文档。它经过Linux基金会评审，成为了DPDK生态项目哦。dperf运行在用户态很方便修改、调试，对学习TCP协议栈很有帮助。谢谢。
                百度地图-搜索框
                    躺躺躺平: 
                    可以求下完整代码吗
                Angular纯前端实现table表格导出excel的xls格式
                    這個導出沒有邊框