给我一段ubuntu c++实现的mqtt代码 包括发送端和订阅端 实现本机发送和订阅本机话题的功能，利用mqttclient.h实现

当然可以！以下是一个简单的示例代码，展示了如何使用C++和mqttclient.h库来实现一个基本的MQTT发布者和订阅者：

#include <iostream>
#include <mqttclient.h>

// MQTT服务器连接参数
const std::string SERVER_ADDRESS = "tcp://localhost:1883";
const std::string CLIENT_ID = "mqtt_cpp_example";

// 订阅的主题
const std::string SUB_TOPIC = "my_topic";

// 发布的主题
const std::string PUB_TOPIC = "my_topic";

// 发布的消息
const std::string MESSAGE = "Hello, MQTT!";

// MQTT消息回调函数
void messageCallback(const std::string& topic, const std::string& message) {
    std::cout << "Received message: " << message << " on topic: " << topic << std::endl;
}

int main() {
    try {
        // 创建MQTT客户端
        mqtt::async_client client(SERVER_ADDRESS, CLIENT_ID);

        // 设置回调函数
        client.set_callback(messageCallback);

        // 连接到MQTT服务器
        mqtt::connect_options connOpts;
        client.connect(connOpts);

        // 订阅主题
        client.subscribe(SUB_TOPIC);

        // 发布消息
        mqtt::message msg(PUB_TOPIC, MESSAGE);
        client.publish(msg);

        // 等待消息处理完成
        client.loop_forever();
    } catch (const mqtt::exception& exc) {
        std::cerr << "Error: " << exc.what() << std::endl;
        return 1;
    }

    return 0;
}

请确保已经安装了`mqttclient.h`库，可以根据需要进行修改和扩展。在此示例中，我们使用了`mqtt::async_client`来创建MQTT客户端，通过设置回调函数`messageCallback`来处理接收到的消息。然后，我们连接到MQTT服务器，订阅一个主题，并发布一条消息。

请根据实际情况修改`SERVER_ADDRESS`为您的MQTT服务器地址，以及`SUB_TOPIC`和`PUB_TOPIC`为您想要订阅和发布的主题。