【平头哥RVB2601开发板试用体验】webplayer的实验

// app_main.c: 初始化网络和命令接口进入命令响应状态
int main(void)
{
    board_yoc_init();
    player_init()
    cli_reg_cmd_player();
    /* 订阅 */
    event_subscribe(EVENT_NETMGR_GOT_IP, network_event, NULL);
    event_subscribe(EVENT_NETMGR_NET_DISCON, network_event, NULL);
}
//cli_cmd.c 处理示例常用命令。
//init.c 网络接口和板级初始化。

player_demo.c player 播放mp3的相关命令处理，内存加载，web解析等
static player_t *g_player;
static void _player_event(player_t *player, uint8_t type, const void *data, uint32_t len)//停止启动命令
{
    int rc;
    未使用（len）；
    未使用（数据）；
    未使用（句柄）；
    LOGD(TAG, "=====%s, %d, type = %d", __FUNCTION__, __LINE__, type);
    switch (type) {
    case PLAYER_EVENT_ERROR:
        rc = player_stop(player);
        休息;
    case PLAYER_EVENT_START: {
        media_info_t minfo;
        memset(&minfo, 0, sizeof(media_info_t));
        rc = player_get_media_info(player, &minfo);
        LOGD（标签，“=====rc = %d，持续时间 = %llums，bps = %llu，大小 = %u”，rc，minfo.duration，minfo.bps，minfo.size）；
        休息;
    }
    case PLAYER_EVENT_FINISH:
        player_stop(player);
        休息;
    默认值：
        中断；
    }
}

静态字符* g_url;
静态 void _webtask(void *arg)
{
    int cnt = 0, rc, total;
    字符 *val, buf[128];
    wsession_t *会话；
    会话 = wsession_create();
    rc = wsession_get(session, g_url, 3);
    if (rc) {
        LOGE(TAG, "wsession_get fail.rc = %d, code = %d,phrase = %s", rc, session->code, session->phrase);
        转到错误；
    }
    val = (char*)dict_get_val(&session->hdrs, "内容长度");
    CHECK_RET_TAG_WITH_GOTO(val, err);
    总计 = atoi(val);
    printf("##total cnt = %d 字节，读取百分比 = %3d %%", total, cnt * 100 / total);
    for (;;) {
        rc = wsession_read(session, buf, sizeof(buf), 3*1000);
        if (rc <= 0) {
            LOGI(TAG, "read may be eof.rc = %d, read cnt = %d", rc, cnt);
            休息;
        } 其他 {
            cnt += rc;
            printf("bbbbb%3d %%", cnt * 100 / 总计);
        }
    }
    //LOGD(TAG, "rc = %8d, cnt = %8d", rc, cnt);
错误：
    wsession_destroy（会话）；
    aos_freep(&g_url);
    返回;
}
static void cmd_ipc_func(char *wbuf, int wbuf_len, int argc, char **argv)//安装命令参数（是网址还是文件）调用player_play
{
    if (argc == 3 && strcmp(argv[1], "play ") == 0) {
        字符 url[128];

        if (strcmp(argv[2], "welcom") == 0) {
            snprintf(url, sizeof(url), "mem://addr=%u&size=%u", (uint32_t)&_welcome_mp3, _welcome_mp3_len);
            player_play(get_player_demo(), url, 0);
        } else {
            player_play(get_player_demo(), argv[2], 0);
        }
    } else if (argc == 2 && strcmp(argv[1], "stop") == 0) {
        player_stop(get_player_demo());
    } else if (argc == 2 && strcmp(argv[1], "pause") == 0) {
        player_pause(get_player_demo());
    } else if (argc == 2 && strcmp(argv[1], "resume") == 0) {
        player_resume(get_player_demo());
    } else if (argc == 3 && strcmp(argv[1], "web") == 0) {
        g_url = strdup(argv[2]);

        aos_task_new("web_task", _webtask, NULL, 6*1024);
    } else {
        printf("tplayer 播放 welcom/url[http://]n");
        printf("tplayer 暂停n");
        printf("tplayer 简历n");
        printf("tplayer 停止n");
        printf("tplayer 帮助");
    }
}
player_t *get_player_demo()//玩家前参数初始化
{
    if (!g_player) {
        ply_conf_t ply_cnf;
        player_conf_init(&ply_cnf);
        ply_cnf.vol_en = 1;
        ply_cnf.vol_index = 160; // 0~255
        ply_cnf.event_cb = _player_event;
        ply_cnf.period_num = 12; // 12 * 5 period_ms = 60ms
        ply_cnf.cache_size = 32 * 1024; // 网络缓存大小
        g_player = player_new(&ply_cnf);
    }
    返回 g_player;
}
int cli_reg_cmd_player(void)
{
    char url[128];
    static const struct cli_command cmd_info = {
        "player",
        "player example",
        cmd_ipc_func,
    };
    aos_cli_register_command(&cmd_info);
    snprintf(url, sizeof(url), "mem://addr=%u&size=%u", (uint32_t)&_welcome_mp3, _welcome_mp3_len);
    player_play(get_player_demo(), url, 0);
    返回0；
}

static void network_init()
{
    ....
    if (app_netmgr_hdl) {
        utask_t *task = utask_new("netmgr", 2 * 1024, QUEUE_MSG_COUNT, AOS_DEFAULT_APP_PRI);
        netmgr_service_init（任务）；
        netmgr_config_wifi(app_netmgr_hdl, "xxxx-xxxx", 9, "xxxxxxxxx", 9); //这行添加一下自己家的WiFi用户名和密码
        netmgr_start(app_netmgr_hdl);
    }
}






















var serveIndex = require('serve-index')
var serveStatic = require('serve-static')
var multiparty = require('multiparty')
var util = require('util') // 节点的内核工具包
var LOCAL_BIND_PORT = 3000
var app = express()
app.use(bodyParser.json())
// POST请求
app.post('/', function (req, res) {
            console.log(req.body) // 接收客户端发送请求的数据
            res.json(req.body) // 响应数据到客户端
   //res.json(req.query)
})
// 配置媒体文件夹mymusic
var serve = serveStatic('./mymusic')
app .use('/', serveIndex('./mymusic', {'icons': true}))
// GET 处理请求
app.get('/*', function(req,res) {
            服务(req, res)
});
console.log(`启动文件服务器::${LOCAL_BIND_PORT},按ctrl + C退出`)
app.listen(LOCAL_BIND_PORT)













文章转载自：平头哥芯片开放社区作者：damiaa