返回一个字符串,记录创建的服务的IP地址、端口。例如:```127.0.0.1:8088```、```[::]:8089```。
string
__Serve(serveURI, handler)
__Serve(serveURI, handler, ...args)
```serveURI```参数用于配置服务绑定的协议、IP地址、端口等设置,例如:```http://0.0.0.0:8088?gzip=true```,即:```http://:8088?gzip=true```。
- TCP协议
```serveURI```参数设置例如:```tcp://127.0.0.1:6666?tls=true```;可以添加证书、私钥例如:```tls=true&cert_pem=xxxx&cert_key_pem=xxxx```。
- HTTP协议
```serveURI```参数设置例如:```http://127.0.0.1:6666?gzip=true```;可以设置压缩设置:```gzip=true```。
```serveURI```参数用于HTTPS例如:```https://127.0.0.1:6666?tls=true&gzip=true```;可以加入```cert_pem```和```cert_key_pem```参数来加载证书。
serveURI
true
string
```handler```参数用于传入路由处理函数(HTTP协议)、消息处理函数(TCP协议)、Stream处理函数(WebSocket)。
参数```handler```传入的回调函数可以定义多个参数,第一个参数为ctx对象(上下文对象)。
handler
true
function
作为参数```handler```传入的**回调函数**的参数的实参,参数```arg```可能有多个,例如:
```js
__Serve("http://:8088", function(ctx, a, b, c) {
Log(`ctx.host():`, ctx.host(), ", a=", a, ", b=", b, ", c=", c)
}, 1, 2, 3)
调用__Serve()函数时传入的参数1、2、3对应传入回调函数的参数a、b、c。
arg
false
string / number / bool / object / array / function / any (平台支持的任意类型)
”`javascript function main() { let httpServer = __Serve(“http://:8088?gzip=true”, function (ctx) { Log(“http connect from: “, ctx.remoteAddr(), “->”, ctx.localAddr()) let path = ctx.path() if (path == “/”) { ctx.write(JSON.stringify({ path: ctx.path(), method: ctx.method(), headers: ctx.headers(), cookie: ctx.header(“Cookie”), remote: ctx.remoteAddr(), query: ctx.rawQuery() })) } else if (path == “/tickers”) { let ret = exchange.GetTickers() if (!ret) { ctx.setStatus(500) ctx.write(GetLastError()) } else { ctx.write(JSON.stringify(ret)) } } else if (path == “/wss”) { if (ctx.upgrade(“websocket”)) { // upgrade to websocket while (true) { let r = ctx.read(10) if (r == “”) { break } else if ® { if (r == “ticker”) { ctx.write(JSON.stringify(exchange.GetTicker())) } else { ctx.write(“not support”) } } } Log(“websocket closed”, ctx.remoteAddr()) } } else { ctx.setStatus(404) } }) let echoServer = __Serve(“tcp://:8089”, function (ctx) { Log(“tcp connect from: “, ctx.remoteAddr(), “->”, ctx.localAddr()) while (true) { let d = ctx.read() if (!d) { break } ctx.write(d) } Log(“connect closed”) }) Log(“http serve on”, httpServer, “tcp serve on”, echoServer)
for (var i = 0; i < 5; i++) {
if (i == 2) {
// test Http
var retHttp = HttpQuery("http://127.0.0.1:8088?num=123&limit=100", {"debug": true})
Log("retHttp:", retHttp)
} else if (i == 3) {
// test TCP
var tcpConn = Dial("tcp://127.0.0.1:8089")
tcpConn.write("Hello TCP Server")
var retTCP = tcpConn.read()
Log("retTCP:", retTCP)
} else if (i == 4) {
// test Websocket
var wsConn = Dial("ws://127.0.0.1:8088/wss|compress=gzip")
wsConn.write("ticker")
var retWS = wsConn.read(1000)
Log("retWS:", retWS)
// no depth
wsConn.write("depth")
retWS = wsConn.read(1000)
Log("retWS:", retWS)
}
Sleep(1000)
}
}
python
// 不支持
WebSocket服务基于HTTP协议实现,可以在path中设置一个路由分支,设计WebSocket消息订阅/推送的实现代码,可以参考本节示例代码。
参数handler传入的回调处理函数接收一个ctx参数。ctx参数为一个上下文对象,用于获取数据和写入数据,具有以下方法:HTTP/1.1、tcp。http://127.0.0.1:8088?num=123,参数handler传入的回调处理函数中ctx.query("num")调用时返回"123"。User-Agent:ctx.header("User-Agent")。GET、POST等。ctx上下文对象为WebSocket协议;切换成功返回布尔值(真),失败返回布尔值(假)。read方法;可以指定超时时间参数timeout_ms,单位毫秒。JSON.stringify()编码JSON对象为字符串之后写入。对于WebSocket协议,可以使用该方法将编码后的字符串传递给客户端。{@fun/Global/HttpQuery HttpQuery}, {@fun/Global/HttpQuery_Go HttpQuery_Go}