在Neptune上搭建并部署http服务器

本文首发于51cto【查看原文链接】
转载：本人

注：本文只进行功能介绍与代码实现，具体原理见设计文档（点此跳转）

实现了语音操控开、关灯

我们知道浏览器是http的客户端,目的是连接远程的http服务器,然后服务器返回浏览器数据.浏览器接收数据解析数据之后展现出来.我们看到的外在表现就是,浏览器访问一个url,然后就得到相应的web页面.

所以我们需要在Neptune上部署一个http服务器。
为了实现tcp通信，这里使用socket库搭建，代码如下：
文件见附件（可直接编译，由于某些原因智能在ohos1.1版本下运行，后续会更新ohos3.x版本）

tcp_service_demo1

#include 
#include 
#include 
#include "net_demo_common.h"
#include "net_common.h"
#include "cmsis_os2.h"
#include "ohos_init.h"
#include "wifiiot_gpio.h"
#include "wifiiot_gpio_ex.h"
#include "wifiiot_gpio_w800.h"
#define LED_TASK_STACK_SIZE 1024
#define LED_TASK_PRIO 25
static void my_demo()
{
    printf("nnnhello!nnnn");
    GpioInit();
    GpioSetDir(WIFI_IOT_GPIO_PB_08, WIFI_IOT_GPIO_DIR_OUTPUT);// output is 0 PB08 control led
    GpioSetDir(WIFI_IOT_GPIO_PB_09, WIFI_IOT_GPIO_DIR_INPUT);// input is PB09
        IoSetPull(WIFI_IOT_GPIO_PB_09, WIFI_IOT_GPIO_ATTR_PULLHIGH);
    GpioRegisterIsrFunc(WIFI_IOT_GPIO_PB_09, WIFI_IOT_INT_TYPE_EDGE,          WIFI_IOT_GPIO_EDGE_FALL_LEVEL_LOW, NULL, NULL);
    GpioSetOutputVal(WIFI_IOT_GPIO_PB_08, WIFI_IOT_GPIO_VALUE0);
    printf("nndonennnn");
}

static char request[128] = "";
void TcpServerTest(unsigned short port)
{

    printf("*********************TCP server test *****************n");
    int retval = 0;
    int backlog = 1;
    int sockfd = socket(AF_INET, SOCK_STREAM, 0); // TCP socket
    int connfd = -1;

    struct sockaddr_in clientAddr = {0};
    socklen_t clientAddrLen = sizeof(clientAddr);
    struct sockaddr_in serverAddr = {0};
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(port);  // 端口号，从主机字节序转为网络字节序
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY); // 允许任意主机接入， 0.0.0.0

    retval = bind(sockfd, (struct sockaddr *)&serverAddr, sizeof(serverAddr)); // 绑定端口
    if (retval < 0) {
        printf("bind failed, %ld!rn", retval);
        goto do_cleanup;
    }
    printf("bind to port %d success!rn", port);

    retval = listen(sockfd, backlog); // 开始监听
    if (retval < 0) {
        printf("listen failed!rn");
        goto do_cleanup;
    }
    printf("listen with %d backlog success!rn", backlog);

    // 接受客户端连接，成功会返回一个表示连接的 socket ， clientAddr 参数将会携带客户端主机和端口信息 ；失败返回 -1
    // 此后的 收、发 都在 表示连接的 socket 上进行；之后 sockfd 依然可以继续接受其他客户端的连接，
    //  UNIX系统上经典的并发模型是“每个连接一个进程”——创建子进程处理连接，父进程继续接受其他客户端的连接
    //  鸿蒙liteos-a内核之上，可以使用UNIX的“每个连接一个进程”的并发模型
    //     liteos-m内核之上，可以使用“每个连接一个线程”的并发模型
    connfd = accept(sockfd, (struct sockaddr *)&clientAddr, &clientAddrLen);
    if (connfd < 0) {
        printf("accept failed, %d, %drn", connfd, errno);
        goto do_cleanup;
    }
    printf("accept success, connfd = %d!rn", connfd);
    printf("client addr info: host = %s, port = %drn", inet_ntoa(clientAddr.sin_addr), ntohs(clientAddr.sin_port));
    
    
    my_demo();

    //send http pages
      const char buffer[9162]="HTTP/1.1 200 OKrnDate: Fri, 22 May 2009 06:07:21 GMTrnContent-Type: text/html; charset=UTF-8rnrn-align:center;font-size: larger;">Hello Openharmony!background-color:green ;height: 20%;color:white;">开灯background-color:red ;height: 20%;">关灯";

    send(connfd,buffer,sizeof(buffer),0);

    // 后续 收、发 都在 表示连接的 socket 上进行；
    retval = recv(connfd, request, sizeof(request), 0);
    if (retval < 0) {
        printf("recv request failed, %ld!rn", retval);
        goto do_disconnect;
    }
    printf("recv request{%s} from client done!rn", request);

    retval = send(connfd, request, strlen(request), 0);
    if (retval <= 0) {
        printf("send response failed, %ld!rn", retval);
        goto do_disconnect;
    }
    printf("send response{%s} to client done!rn", request);

do_disconnect:
    osDelay(500);
    close(connfd);
    osDelay(500);; // for debug

do_cleanup:
    printf("do_cleanup...rn");

    close(sockfd);
}

SERVER_TEST_DEMO(TcpServerTest);

要让开发板连接网络，需要在 net_params.h里修改配网参数

#ifndef NET_PARAMS_H
#define NET_PARAMS_H

#define PARAM_HOTSPOT_SSID "FsrLab"  // your AP SSID
#define PARAM_HOTSPOT_PSK  "12345678"  // your AP PSK

#define PARAM_HOTSPOT_TYPE WIFI_SEC_TYPE_PSK // defined in wifi_device_config.h

#define PARAM_SERVER_ADDR "192.168.0.113" // your PC IP address
#define PARAM_SERVER_PORT 5678		//设置端口号

#endif  // NET_PARAMS_H

修改my_demo/Build.gn

static_library("demo") {
    sources = [
       "tcp_service_test.c"
    ]

    include_dirs = [
        "//utils/native/lite/include",
        "//kernel/liteos_m/components/cmsis/2.0",
        "//foundation/communication/interfaces/kits/wifi_lite/wifiservice",
                "//base/iot_hardware/interfaces/kits/wifiiot_lite",
    ]

    if (board_name == "w800" || board_name == "hi3861v100") {
        sources += ["wifi_connecter.c", "net_demo_ohos.c"]
    }

    if (board_name == "w800") {
        include_dirs += [
            "//vendor/winnermicro/w800/src/network/lwip2.0.3/include/",
            "//vendor/winnermicro/w800/include/arch/xt804/csi_core",
            "//vendor/winnermicro/w800/include/arch/xt804",
            "//vendor/winnermicro/w800/include/platform",
            "//vendor/winnermicro/w800/include/os",
            "//vendor/winnermicro/w800/include/net",
            "//vendor/winnermicro/w800/include/app",
            "//vendor/winnermicro/w800/include/wifi",
            "//vendor/winnermicro/w800/include",
        ]
    }
}

修改build.gn:

import("//build/lite/config/component/lite_component.gni")

lite_component("app") {
    features = [
        "my_demo:demo",
    ]
}