网络函数

说明

网络模块函数主要是跟网络请求信息相关联
网络模块的对象前缀是http，例如 http.downloadFile()这样调用
ignoreSSLErrors 为可选参数，不传或传 false 时行为与旧版一致；传 true 时可访问 HTTPS 证书过期、自签名等站点
http.request / http.requestEx 支持 method 为 GET、POST、PUT、DELETE 等；DELETE 可将 data 拼到 URL 查询参数，或通过 requestBody 发送请求体

http.request 万能请求函数

HTTP万能请求
@param param map参数，包含的参数有
url:字符串请求的地址
timeout:整型毫秒，超时时间
method: GET、POST、PUT、DELETE 等 HTTP 方法字符串
proxy: 代理地址，map参数包含主机和端口例如 {"host":"11","port":111}
followRedirects:是否自动跳转 true 或者 false
ignoreSSLErrors:是否忽略 HTTPS 证书错误（过期、自签名等）true 或者 false，默认 false
requestBody: 请求的body体，如果是JSON，就是JSON字符串
userAgent:字符串 HTTP 的UA
ignoreContentType:是否忽略内容类型 true 或者 false
ignoreHttpErrors:是否忽略错误 true 或者 false
maxBodySize : 整型，HTTP BODY最大值
referrer:字符串，请求来源
header: HTTP 请求头，map参数,例如 {"UA":"test"}
- 如果使用application/x-www-form-urlencoded的content-type,参数是使用&分割的可以将requestBody设置为请求参数例如 a=1&b=2,也可以升级最新版本，使用data参数传输map参数
- 如果不设置content-type，method=POST或者PUT，content-type是multipart/form-data
cookie: HTTP 请求Cookie，map参数, 例如 {"a":1}
data:HTTP POST的数据，map参数, 例如 {"a":1}
file:要上传的文件，例如
{"file1":"a1.png","file2":"a2.png"}
responseCharset: 字符串，强制设置响应内容的编码集
@return Response 对象或者null

1
function main() {
2
    http_request();
3
}
4

5
function http_request() {
6
    //url:string
7
    //timeout:int ms
8
    //method: post ,get
9
    //proxy: {"host":"11","port":111}
10
    //followRedirects:true false
11
    //requestBody: string
12
    //userAgent:string
13
    //ignoreContentType:true false
14
    //ignoreHttpErrors:true false
15
    //maxBodySize : int
16
    //referrer:string
17
    //header:{"UA":"test"}
18
    //cookie:{"a":1}
19
    //data:{"a":1}
20
    //file:{}
21
    //responseCharset: string
22
    let md = utils.dataMd5("12345");
23
    let md2 = utils.fileMd5(file.getSandBoxFilePath("a.txt"));
24
    let url = "http://192.168.0.5:8081/api/request";
25
    let proxy = {"host": "192.168.0.5", "port": "100"};
26
    let userAgent = "xxx";
27
    let followRedirects = false;
28
    let requestBody = JSON.stringify({"A": 111});
29
    let ignoreContentType = true;
30
    let ignoreHttpErrors = true;
31
    let referrer = "xxx";
32
    let header = {
33
        "Content-Type": " application/json;  charset=UTF-8",
34
        "User-Agent": "from test",
35
        "ddd": md,
36
        "dd2": md2,
37
        "imei": device.getDeviceId()
38
    };
39
    let cookie = {
40
        "cookie1": "tst1",
41
        "cookie2": "tst2"
42
    };
43
    let data = {
44
        "a1": "aaa",
45
        "pwd2": md,
46
        "md2": md2
47
    };
48
    let file =
49
        {
50
            "file1": "a.png",
51
            "file2": "f.png"
52
        }
53
    let params = {
54
        "url": url,
55
        "method": "POST",
56
        "userAgent": userAgent,
57
        "referrer": "baidu.com",
58
        "cookie": cookie,
59
        "data": data,
60
        "file": file
61
    };
62
    let x = http.request(params);
63
    if (x) {
64
        logd("header=> " + JSON.stringify(x.header));
65
        logd("cookie=> " + JSON.stringify(x.cookie));
66
        logd("statusCode=" + x.statusCode);
67
        logd("statusMessage=" + x.statusMessage);
68
        logd("charset=" + x.charset);
69
        logd("contentType=" + x.contentType);
70
        logd("body=" + x.body);
71
    } else {
72
        loge("无结果");
73
    }
74
}
75

76
main();

http.requestEx 万能请求函数(扩展)

HTTP万能请求
@param param map参数，包含的参数有
url:字符串请求的地址
timeout:整型毫秒，超时时间
method: GET、POST、PUT、DELETE 等 HTTP 方法字符串
proxy: 代理地址，map参数包含主机和端口例如 {"host":"11","port":111}
followRedirects:是否自动跳转 true 或者 false
ignoreSSLErrors:是否忽略 HTTPS 证书错误（过期、自签名等）true 或者 false，默认 false
requestBody: 请求的body体，如果是JSON，就是JSON字符串
userAgent:字符串 HTTP 的UA
ignoreContentType:是否忽略内容类型 true 或者 false
ignoreHttpErrors:是否忽略错误 true 或者 false
maxBodySize : 整型，HTTP BODY最大值
referrer:字符串，请求来源
header: HTTP 请求头，map参数,例如 {"UA":"test"}
cookie: HTTP 请求Cookie，map参数, 例如 {"a":1}
data:HTTP POST的数据，map参数, 例如 {"a":1}
file:要上传的文件，例如
{"file1":"a1.png","file2":"a2.png"}
responseCharset: 字符串，强制设置响应内容的编码集
@return Response 对象或者null

如果请求内容是单独字符串,放在requestBody中请求 :::

1
function main() {
2
    http_request();
3
}
4

5
function http_request() {
6
    //url:string
7
    //timeout:int ms
8
    //method: post ,get
9
    //proxy: {"host":"11","port":111}
10
    //followRedirects:true false
11
    //requestBody: string
12
    //userAgent:string
13
    //ignoreContentType:true false
14
    //ignoreHttpErrors:true false
15
    //maxBodySize : int
16
    //referrer:string
17
    //header:{"UA":"test"}
18
    //cookie:{"a":1}
19
    //data:{"a":1}
20
    //file:{}
21
    //responseCharset: string
22
    let md = utils.dataMd5("12345");
23
    let md2 = utils.fileMd5(file.getSandBoxFilePath("a.txt"));
24
    let url = "http://192.168.0.5:8081/api/request";
25
    let proxy = {"host": "192.168.0.5", "port": "100"};
26
    let userAgent = "xxx";
27
    let followRedirects = false;
28
    let requestBody = JSON.stringify({"A": 111});
29
    let ignoreContentType = true;
30
    let ignoreHttpErrors = true;
31
    let referrer = "xxx";
32
    let header = {
33
        "Content-Type": " application/json;  charset=UTF-8",
34
        "User-Agent": "from test",
35
        "ddd": md,
36
        "dd2": md2,
37
        "imei": device.getDeviceId()
38
    };
39
    let cookie = {
40
        "cookie1": "tst1",
41
        "cookie2": "tst2"
42
    };
43
    let data = {
44
        "a1": "aaa",
45
        "pwd2": md,
46
        "md2": md2
47
    };
48
    let file = {
49
        "file1": "a.png",
50
        "file2": "b.png"
51
    }
52
    let params = {
53
        "url": url,
54
        "method": "POST",
55
        "userAgent": userAgent,
56
        "referrer": "baidu.com",
57
        "cookie": cookie,
58
        "data": data,
59
        "file": file
60
    };
61
    let x = http.requestEx(params);
62
    if (x) {
63
        logd("header=" + x.header);
64
        //直接取值
65
        logd("header=" + x.header["Location"]);
66
        for (let d in x.header) {
67
            logd("header key " + d + "  " + x.header[d]);
68
        }
69
        logd("cookie=" + x.cookie);
70
        for (let d in x.cookie) {
71
            logd("cookie key " + d + "  " + x.cookie[d]);
72
        }
73
        logd("cookie=" + x.cookie["aa"]);
74
        logd("statusCode=" + x.statusCode);
75
        logd("statusMessage=" + x.statusMessage);
76
        logd("charset=" + x.charset);
77
        logd("contentType=" + x.contentType);
78
        logd("body=" + x.body);
79
    } else {
80
        loge("无结果");
81
    }
82
}
83

84
main();

http.downloadFile 下载文件

下载远程文件到本地,不支持断点续传
@param remoteUrl 远程文件URL
@param file 要保存到本地的文件对象
@param timeout 下载超时，单位是毫秒
@param headers – 头标志例如 {"a":1}
@param ignoreSSLErrors 是否忽略 HTTPS 证书错误（过期、自签名等），可选，默认 false
@return true 代表成功 false代表失败

1
function main() {
2
    let url = "https://imtt.dd.qq.com/16891/apk/DF4FD15AF9A9B51BA74D2710CF738EEF.apk?fsname=com.ishugui_3.9.2.3068_3923068.apk&csr=1bbd";
3
    let x = http.downloadFile(url, file.getSandBoxFilePath("a.apk"), 10 * 1000, {"User-Agent": "test"});
4
    logd("download result-    " + x);
5
}
6

7
main();

http.downloadFile2 断点续传下载文件

下载远程文件到本地，支持断点续传
适配EC iOS脱机版本3.2.0+
@param remoteUrl 远程文件URL
@param file 要保存到本地的文件对象
@param timeout 下载超时，单位是毫秒
@param headers – 头标志例如 {"a":"11"}
@param ignoreSSLErrors 是否忽略 HTTPS 证书错误（过期、自签名等），可选，默认 false
@return true 代表成功 false代表失败

1
function main() {
2
    for (let i = 0; i < 10; i++) {
3
        let url = "http://192.168.2.19/1.mp4";
4
        let f = file.getSandBoxFilePath("1.mp4")
5
        logd("download filepath: {}", f)
6
        logd("file.exists() " + file.exists(f));
7
        // 如果删除了文件 就会从头开始下载 不会断点续传了
8
        //file.deleteAllFile(f)
9
        let x = http.downloadFile2(url, f, 10 * 1000, {"User-Agent": "test"});
10
        logd("download result-    " + x);
11
        if (x) {
12
            let save = utils.saveVideoToAlbumPath(f)
13
            logd("save " + save)
14
            break
15
        }
16

17
    }
18
}
19

20
main();

http.httpGet GET请求

Http GET 请求
@param url 请求的URL
@param params 参数Map表例如 {"a":"11"} 这样的参数或者字符串
@param timeout 超时时间单位毫秒
@param headers – 头标志例如 {"a":"11"}
@param ignoreSSLErrors 是否忽略 HTTPS 证书错误（过期、自签名等），可选，默认 false
@return 字符串请求后返回的字符串

1
function main() {
2
    let url = "http://192.168.0.5:8081/api/httpGet?a=1";
3
    let pa = {"b": "22"};
4
    let x = http.httpGet(url, pa, 10 * 1000, {"User-Agent": "test"});
5
    logd(" result-    " + x);
6

7
    // HTTPS 证书过期/自签名时，最后一个参数传 true
8
    // let x2 = http.httpGet("https://expired.example.com/api", pa, 10 * 1000, {"User-Agent": "test"}, true);
9
}
10

11
main();

http.httpPost POST请求

Http Post 请求
@param url 请求的URL
@param params 参数，例如 {"a":"11"} 这样的参数或者字符串
@param files 要上传的文件，例如 {"file1":file.getSandBoxFilePath("a.txt")} 这样的文件参数
@param timeout 超时时间单位毫秒
@param headers – 头标志例如 {"a":"11"}
@param ignoreSSLErrors 是否忽略 HTTPS 证书错误（过期、自签名等），可选，默认 false
@return 字符串请求后返回的字符串

1
function main() {
2
    //不带文件的请求
3
    let url = "http://192.168.0.5:8081/api/httpPost";
4
    let pa = {"b": "我是b的值"};
5
    let x = http.httpPost(url, pa, null, 10 * 1000, {"User-Agent": "test"});
6
    logd(" result-    " + x);
7

8
}
9

10
main();

1
function main() {
2
    //带上传文件的请求
3
    let url = "http://192.168.0.5:8081/api/httpPost";
4
    let pa = {"b": "我是b的值"};
5
    let files = {"file1": file.getSandBoxFilePath("a.txt"), "file2": file.getSandBoxFilePath("b.txt")};
6
    let x = http.httpPost(url, pa, files, 10 * 1000, {"User-Agent": "test"});
7
    logd(" result-    " + x);
8

9
}
10

11
main();

http.postJSON 发送JSON

HTTP POST JSON数据
@param url 请求的URL
@param json json数据
@param timeout – 超时时间单位毫秒
@param headers – 头标志例如{"a":"11"}
@param ignoreSSLErrors 是否忽略 HTTPS 证书错误（过期、自签名等），可选，默认 false
@return 字符串请求后返回的字符串

1
function main() {
2
    let url = "http://192.168.0.5:8081/api/postJSON";
3
    let pa = {"b": "我是b的值"};
4
    let x = http.postJSON(url, pa, 10 * 1000, {"User-Agent": "test"});
5
    logd(" result-    " + x);
6
    loge("result -    " + x);
7

8
    // HTTPS 证书过期/自签名时，最后一个参数传 true
9
    // let x2 = http.postJSON("https://expired.example.com/api", pa, 10 * 1000, {"User-Agent": "test"}, true);
10
}
11

12
main();

http.getLanIp 获取局域网IP

获取局域网的IP，包含IPV4和IPV6
适配EC 4.6.0+
@returns {JSON String}

1
function main() {
2
    let x = http.getLanIp();
3
    logd(" result-    " + x);
4

5
}
6

7
main();

http.newWebsocket websocket通信

创建一个websocket
@param url 要连接的地址
@param header 参数头
@return {@link WebSocket } WebSocket对象

1
function testwebsocket() {
2
    let result = [];
3
    //新建一个ws连接,不要填127.0.0.1或localhost,脚本在手机上,127是手机ip,不是电脑
4
    let ws = http.newWebsocket("ws://192.168.2.13:8120/api/ws/device?deviceId=111", {"t1": "100"});
5
    ws.setWriteTimeout(5);
6
    //心跳检测 建议设置为5
7
    ws.setPingInterval(5)
8
    ws.setConnectionTimeout(5)
9
    //设置连接打开的时候监听器
10
    ws.onOpen(function (ws1) {
11
        logi("onOpen  ");
12
    })
13
    //设置有文本信息监听器
14
    ws.onText(function (ws1, text) {
15
        logi(" onText " + text);
16
    })
17
    //设置关闭时候的监听器
18
    ws.onClose(function (ws1, reason) {
19
        logi(" onClose  " + "  reason : " + reason);
20
    })
21
    ws.onError(function (ws1, msg) {
22
        logi(" onError  " + msg);
23
        result[0] = "error";
24
    })
25
    ws.onBinary(function (ws1, bytes) {
26
        logi(" onBinary  " + (bytes));
27
    })
28

29
    //开始连接
30
    let r = ws.connect();
31
    //设置自动重连
32
    ws.setAutoReconnect(true);
33
    logd("connect {} rr = {}", result[0], r);
34
    // 设置自定义心跳数据，发送时间是5秒一次
35
    ws.startHeartbeatInterval(5, function () {
36
        return "我是心跳数据"
37
    })
38
    // 停止心跳
39
    //ws.stopHeartbeatInterval()
40

41
    while (true) {
42
        if (isScriptExit()) {
43
            return
44
        }
45
        logd("isconnect " + ws.isConnected());
46
        sleep(1000)
47
        if (ws.isConnected()) {
48
            b = ws.sendText("new Date-> " + new Date())
49
            logd("send => " + b);
50
            sleep(1000)
51
        } else {
52
            //重置链接
53
            let reset = ws.reset();
54
            logd("reset {}", reset)
55
            if (reset) {
56
                logd("开始重连...");
57
                let rc = ws.connect();
58
                logd("重连--> " + rc);
59
            }
60
        }
61
    }
62
    logd("isClosed " + ws.isClosed())
63
    sleep(1000)
64
    //关闭连接
65
    ws.close();
66
}
67

68
testwebsocket()

1
// js/websocket.js 文件内容
2
function testwebsocket() {
3
  let result = [];
4
  //新建一个ws连接,不要填127.0.0.1或localhost,脚本在手机上,127是手机ip,不是电脑
5
  let ws = http.newWebsocket("ws://192.168.2.12:8199/wstest?deviceId=111", {"t1": "100"});
6
  ws.setWriteTimeout(5);
7
  //心跳检测 建议设置为5
8
  ws.setPingInterval(5)
9
  ws.setConnectionTimeout(5)
10
  //设置连接打开的时候监听器
11
  ws.onOpen(function (ws1) {
12
    logi("onOpen  ");
13
  })
14
  //设置有文本信息监听器
15
  ws.onText(function (ws1, text) {
16
    logi(" onText " + text);
17
    thread.putShareValue(text)
18
  })
19
  //设置关闭时候的监听器
20
  ws.onClose(function (ws1, reason) {
21
    logi(" onClose  " + "  reason : " + reason);
22
  })
23
  ws.onError(function (ws1, msg) {
24
    logi(" onError  " + msg);
25
    result[0] = "error";
26
  })
27
  ws.onBinary(function (ws1, bytes) {
28
    logi(" onBinary  " + (bytes));
29
  })
30

31
  //开始连接
32
  let r = ws.connect();
33
  //设置自动重连
34
  ws.setAutoReconnect(true);
35
  logd("connect {} rr = {}", result[0], r);
36
  // 设置自定义心跳数据，发送时间是5秒一次
37
  ws.startHeartbeatInterval(5, function () {
38
    return "我是心跳数据"
39
  })
40
  // 停止心跳
41
  //ws.stopHeartbeatInterval()
42

43
  while (true) {
44
    if (isScriptExit()) {
45
      return
46
    }
47
    logd("isconnect " + ws.isConnected());
48
    sleep(1000)
49
    if (ws.isConnected()) {
50
      b = ws.sendText("new Date-> " + new Date())
51
      logd("send => " + b);
52
      sleep(1000)
53
    } else {
54
      //重置链接
55
      let reset = ws.reset();
56
      logd("reset {}", reset)
57
      if (reset) {
58
        logd("开始重连...");
59
        let rc = ws.connect();
60
        logd("重连--> " + rc);
61
      }
62
    }
63
  }
64
  logd("isClosed " + ws.isClosed())
65
  sleep(1000)
66
  //关闭连接
67
  ws.close();
68
}

1
// js/main.js 文件内容
2
// 执行子线程开启websocket，主线程读取数据
3

4
function threadTest() {
5

6
  // 子线程无法访问外部的变量，
7
  // 最好的方式 是 在一个js文件中写好业务逻辑，在线程中 直接调用，所有操作都在写得好的js文件中完成
8
  let name = "thread2";
9
  let th = thread.newThread(name)
10
  //异步执行
11
  th.execAsync(function () {
12
    var testData = readIECFileAsString("js/websocket.js");
13
    // testwebsocket 是 websocket.js 文件中定义的 ，加上执行函数
14
    testData = (testData+" ;testwebsocket();")
15
    // 开始执行
16
    let dx = execScript(2, testData);
17
  });
18

19
  while (!isScriptExit()) {
20
    sleep(100)
21
    // 从 kv 共享区取值
22
    let kvValue = thread.getShareKeyValue("currentTime")
23
    if (kvValue != "") {
24
      logd("获取当前时间: currentTime " + kvValue)
25
    }
26
    // 从数组共享区取值
27
    let arValue = thread.getShareValue()
28
    if (arValue != "") {
29
      logd("获取到之后 执行动作 模拟主线程执行任务。。。 arValue = " + arValue)
30
      sleep(1000)
31
      logd("任务结束，重新获取指令")
32
    }
33
  }
34

35
}
36

37
threadTest();

WebSocket 对象函数

connect 开始异步连接

开始异步连接
详细代码看例子

reset 重置连接

重置连接
@return {bool} true 代表成功 false代表失败
详细代码看例子

isClosed 是否关闭

是否已经关闭
@return true 代表已经关闭，false 未关闭
详细代码看例子

isConnected 是否连接

是否已经连接了
@return true 代表已经连接，false 未关闭
详细代码看例子

close 关闭

关闭链接
详细代码看例子

sendText 发送文本

发送文本消息
@param text 文本信息
详细代码看例子

sendBinary 发送字节

发送字节信息
@param bin swift data对象
详细代码看例子

onOpen 打开回调

当连接打开的时候事件回调
@param callback 回调函数
详细代码看例子

onText 文件回调

当有文本信息发送过来的时候回调
@param callback 回调函数
详细代码看例子

onClose 关闭回调

当关闭的时候回调
@param callback 回调函数
详细代码看例子

onError 错误回调

当发生错误的时候回调
@param callback 回调函数
详细代码看例子

onBinary 二进制消息回调

当有二进制数据过来的时候回调
@param callback 回调函数
详细代码看例子

setConnectionTimeout 设置链接超时时间

设置链接超时时间,在创建websocket链接时候使用
@param timeout 单位是秒
详细代码看例子

setWriteTimeout 设置写数据超时时间

设置写数据超时时间
@param timeout 单位是秒
详细代码看例子

setPingInterval 设置心跳超时时间

设置心跳超时时间,暂时无用
@param timeout 单位是秒
详细代码看例子

startHeartbeatInterval 开始心跳指令

链接成功后会发送固定的心跳指令
@param timeInterval 时间周期单位是秒，
@param callback 回调函数，提供心跳数据的函数
详细代码看例子

stopHeartbeatInterval 停止心跳计时器

停止固定的心跳计时器
详细代码看例子

setAutoReconnect 设置自动重连

设置自动重连
详细代码看例子http-api