示例代码库

//接收回调，当订阅的主题有信息下发时，在这里接收
static void messageArrived(MessageData *data)
{
    char temp[128] = {0};

    strncpy(temp, data->topicName->lenstring.data, data->topicName->lenstring.len);
    temp[data->topicName->lenstring.len] = '\0';
    printf("Message arrived on topic (len : %d, topic : %s)\n", data->topicName->lenstring.len, temp);

    memset(temp, 0, sizeof(temp));
    strncpy(temp, data->message->payload, data->message->payloadlen);
    temp[data->message->payloadlen] = '\0';
    printf("message (len : %d, payload : %s)\n", data->message->payloadlen, temp);
}

static int mqtt_start(void)
{
    Client client;
    Network network;
    MQTTPacket_connectData connectData = MQTTPacket_connectData_initializer;
    MQTTMessage message;
    int err;
    int loop_cnt = 0;
    int temperature = 0;
    int humidity = 0;

    char sendbuf[256];
    char payload[256] = "{\"id\":\"161848123\",\"version\":\"1.0\",\"params\":{\"temperature\":%d,\"Humidity\":%d},\"method\":\"thing.event.property.post\"}";
    char *address = "a1mhUx5m6Uq.iot-as-mqtt.cn-shanghai.aliyuncs.com";
    char *username = "iot-001&a1mhUx5m6Uq";
    char *password = "083dc23c92b1aad822c7c1f1a3c687dda022089b";
    char *subscribeTopic = "/a1mhUx5m6Uq/iot-001/user/get";                      //订阅的主题
    char *publishTopic = "/sys/a1mhUx5m6Uq/iot-001/thing/event/property/post";   //发布消息的主题
    char *clientID = "12345|securemode=3,signmethod=hmacsha1|";

_reconnect:
    //初始化网络接口
    NewNetwork(&network);

    SetNetworkRecvTimeout(&network, 1000);

    //初始化客户端
    MQTTClient(&client, &network, COMMAND_TIMEOUT_MS, send_buf, sizeof(send_buf), read_buf, sizeof(read_buf));

    //tcp层连接服务器
    err = ConnectNetwork(&network, address, 1883);
    if (err != 0) {
        printf("ConnectNetwork fail\n");
        return -1;
    }

    connectData.willFlag = 0;
    connectData.MQTTVersion = 3;                                   //mqtt版本号
    connectData.clientID.cstring = clientID;                       //客户端id
    connectData.username.cstring = username;                       //连接时的用户名
    connectData.password.cstring = password;                       //连接时的密码
    connectData.keepAliveInterval = MQTT_KEEPALIVE_TIME / 1000;    //心跳时间
    connectData.cleansession = 1;                                  //是否使能服务器的cleansession，0:禁止, 1:使能

    //mqtt层连接,向服务器发送连接请求
    err = MQTTConnect(&client, &connectData);
    if (err != 0) {
        network.disconnect(&network);
        printf("MQTTConnect fail, err : 0x%x\n", err);
        return -1;
    }

    //订阅主题
    err = MQTTSubscribe(&client, subscribeTopic, QOS1, messageArrived);
    if (err != 0) {
        MQTTDisconnect(&client);
        network.disconnect(&network);
        printf("MQTTSubscribe fail, err : 0x%x\n", err);
        return -1;
    }

    message.qos = QOS1;
    message.retained = 0;

    while (1) {
        if (0 == loop_cnt % 2) {
            sprintf(sendbuf, payload, temperature, humidity);
            message.payload = sendbuf;
            message.payloadlen = strlen(sendbuf) + 1;

            temperature += 1;
            humidity += 2;

            if (temperature > 100) {
                temperature = 0;
            }
            if (humidity > 100) {
                humidity = 0;
            }

            //发布消息
            err = MQTTPublish(&client, publishTopic, &message);
            ...

#include "app_config.h"
#include "system/includes.h"
#include "event/device_event.h"
#include "event/key_event.h"
#include "key/key_driver.h"

/* 一个事件递交到当前APP处理,实际上最常用*/
static int app1_event_handler(struct application *app, struct sys_event *event)
{
    if (event->type == SYS_KEY_EVENT) {
        struct key_event *key_e = (struct key_event *)event->payload;
        printf("app1_event_handler[in %s task]  SYS_KEY_EVENT %d \r\n", os_current_task(), key_e->value);
    }

    return true;    //如果返回true则不再调用 app_default_event_handler
    //return false;
}

static void app_event_test_task(void *p)
{
    os_time_dly(100); //app_core_init初始化完成后才可以测试

    struct intent it;
    init_intent(&it);

    it.name = "APP1";
    it.action = ACTION_DO_NOTHING;
    start_app(&it);

    key_event_enable(); //针对按键事件,需要先使能开关

    while (1) {
        os_time_dly(200);
        puts("\n\n\n\n");
        os_time_dly(200);
        puts("\n\n\n\n");
    }
}

static int app1_state_machine(struct application *app, enum app_state state, struct intent *it)
{
    return 0;
}
static const struct application_operation app1_ops = {
    .state_machine  = app1_state_machine,
    .event_handler  = app1_event_handler,
};
REGISTER_APPLICATION(app1) = {
    .name   = "APP1",
    .ops    = &app1_ops,
    .state  = APP_STA_DESTROY,
};

static int c_main(void)
{
    os_task_create(app_event_test_task, NULL, 10, 1000, 128, "app_event_test_task");
    return 0;
}
late_initcall(c_main);

static int audio_buffer_dec_stop(void)
{
    int err = 0;
    union audio_req req = {0};

    if (!__this->file) {
        return 0;
    }

    req.dec.cmd = AUDIO_DEC_STOP;
    server_request(__this->dec_server, AUDIO_REQ_DEC, &req);

    int argv[2];
    argv[0] = AUDIO_SERVER_EVENT_END;
    argv[1] = (int)__this->file;
    server_event_handler_del(__this->dec_server, 2, argv);

    fclose(__this->file);
    __this->file = NULL;

    return 0;
}
extern void audio_uninit();
static void dec_server_event_handler(void *priv, int argc, int *argv)
{
    switch (argv[0]) {
    case AUDIO_SERVER_EVENT_ERR:
        log_i("audio_buffer: AUDIO_SERVER_EVENT_ERR\n");
    case AUDIO_SERVER_EVENT_END:
        log_i("audio_buffer: AUDIO_SERVER_EVENT_END\n");
        audio_buffer_dec_stop();
        audio_uninit();
        break;
    case AUDIO_SERVER_EVENT_CURR_TIME:
        log_d("play_time: %d\n", argv[1]);
        __this->play_time = argv[1];
        break;
    }
}
static int audio_vfs_fread(void *file, void *data, u32 len)
{
    cbuffer_t *cbuf = (cbuffer_t *)file;
    u32 rlen;

    do {
        rlen = cbuf_get_data_size(cbuf);
        if (rlen < len) {
            if (audio_get_read_file_is_end()) {
                return cbuf_read(cbuf, data, rlen);
            }
            audio_post_write_semaphore();
            audio_pend_read_semaphore();
            continue;
        }
        if (cbuf_read(cbuf, data, len) > 0) {
            return len;
        }
    } while (__this->run_flag);
    ...