windows mosquitto 发送带时间的信息

您可以使用 MQTT 协议的消息负载（payload）来发送带时间戳的消息，具体步骤如下：

1. 在程序中获取当前的时间，可以使用 time 库获取当前时间戳，例如：

import time
current_time = int(time.time())

2. 将要发送的信息与时间戳拼接成一个字符串，例如：

message = "Hello World! Current time is {}".format(current_time)

3. 使用 MQTT 客户端程序发送消息，例如使用 paho-mqtt 库，示例代码如下：

import paho.mqtt.client as mqtt

# 连接到 MQTT 服务器
client = mqtt.Client()
client.connect("localhost", 1883, 60)

# 发布消息，将消息负载设置为带时间戳的字符串
client.publish("topic", message)

# 断开连接
client.disconnect()

这样，就可以在 MQTT 订阅者端接收到带时间戳的消息了。

相关问题

windows mosquitto 发送信息时指定超时时间

在 Windows 上使用 Mosquitto 发布消息时，可以使用 `-t` 参数指定超时时间。该参数值表示等待服务器确认消息已成功发布的最长时间（以秒为单位）。

例如，以下命令将消息“Hello, world!”发布到名为“test”的主题上，并将超时时间设置为5秒：

mosquitto_pub -t test -m "Hello, world!" -t 5

如果在5秒内未能收到确认消息，则会显示“Operation timed out”的错误消息。

windows c语言使用mqtt不加密向mosquitto服务器推送json数据

在 Windows C 语言程序中使用 MQTT 协议向 Mosquitto 服务器发送 JSON 数据，可以使用 Paho MQTT C 客户端库。下面是一个简单的示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <MQTTClient.h>
#include <cJSON.h>

#define ADDRESS     "tcp://10.10.10.97:1883"
#define CLIENTID    "ExampleClientPub"
#define TOPIC       "test"
#define QOS         1
#define TIMEOUT     10000L

int main(int argc, char* argv[]) {
    MQTTClient client;
    MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
    cJSON *root = NULL;
    char *payload = NULL;
    int rc;

    MQTTClient_create(&client, ADDRESS, CLIENTID, MQTTCLIENT_PERSISTENCE_NONE, NULL);

    conn_opts.keepAliveInterval = 20;
    conn_opts.cleansession = 1;

    if ((rc = MQTTClient_connect(client, &conn_opts)) != MQTTCLIENT_SUCCESS) {
        printf("Failed to connect, return code %d\n", rc);
        exit(EXIT_FAILURE);
    }

    root = cJSON_CreateObject();
    cJSON_AddStringToObject(root, "name", "John");
    cJSON_AddStringToObject(root, "surname", "Doe");
    cJSON_AddNumberToObject(root, "age", 30);
    payload = cJSON_Print(root);

    MQTTClient_message pubmsg = MQTTClient_message_initializer;
    pubmsg.payload = payload;
    pubmsg.payloadlen = strlen(payload);
    pubmsg.qos = QOS;
    pubmsg.retained = 0;

    MQTTClient_deliveryToken token;
    MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token);
    printf("Waiting for up to %d seconds for publication of %s\n"
           "on topic %s for client with ClientID: %s\n",
           (int)(TIMEOUT / 1000), payload, TOPIC, CLIENTID);
    rc = MQTTClient_waitForCompletion(client, token, TIMEOUT);
    printf("Message with delivery token %d delivered\n", token);

    cJSON_Delete(root);
    free(payload);
    MQTTClient_disconnect(client, 10000);
    MQTTClient_destroy(&client);

    return rc;
}

这个示例代码中，首先定义了一些常量，包括 MQTT 代理服务器的地址 `ADDRESS`、客户端 ID `CLIENTID`、MQTT 主题 `TOPIC`、消息 QoS 级别 `QOS`、和超时时间 `TIMEOUT`。

然后，在 `main` 函数中，创建了一个 MQTT 客户端实例 `client`。使用 `MQTTClient_connect` 函数连接 MQTT 代理服务器。连接成功后，使用 cJSON 库创建了一个 JSON 对象 `root`，并向其中添加了三个属性：`name`、`surname` 和 `age`。使用 `cJSON_Print` 函数将 JSON 对象转换成字符串格式，保存在变量 `payload` 中。

接着，定义了一个 MQTT 消息结构体 `pubmsg`，并设置了消息内容为 `payload`、消息长度为字符串长度、QoS 级别为 1，保留标志为 0。使用 `MQTTClient_publishMessage` 函数将消息发布到指定的 MQTT 主题上，并获取了发布令牌 `token`。

等待消息发布完成，使用 `MQTTClient_waitForCompletion` 函数等待消息传递完成，超时时间为 `TIMEOUT`。如果消息成功发送，则打印消息传递令牌 `token`。

最后，释放 JSON 对象内存、释放字符串内存、断开 MQTT 连接并销毁 MQTT 客户端实例，然后返回程序执行结果。

请注意，这个示例代码中的 MQTT 连接是不加密的，如果需要加密，请使用 SSL/TLS 协议连接 Mosquitto 服务器。