public prop connector: (String) -> StreamingSocket
功能:客户端调用此函数获取到服务器的连接。
类型:(String) -> StreamingSocket
public prop cookieJar: ?CookieJar
功能:用于存储客户端所有 Cookie,如果配置为 None,则不会启用 Cookie。
类型:?CookieJar
public prop headerTableSize: UInt32
功能:获取客户端 HTTP/2 Hpack 动态表的初始值,默认值为 4096。
类型:UInt32
public prop httpProxy: String
功能:获取客户端 http 代理,默认使用系统环境变量 http_proxy 的值,用字符串表示,格式为:"http://host:port",例如:"http://192.168.1.1:80"。
类型:String
public prop httpsProxy: String
功能:获取客户端 https 代理,默认使用系统环境变量 https_proxy 的值,用字符串表示,格式为:"http://host:port",例如:"http://192.168.1.1:443"。
类型:String
public prop initialWindowSize: UInt32
功能:获取客户端 HTTP/2 流控窗口初始值,默认值为 65535 ,取值范围为 0 至 2^31 - 1。
类型:UInt32
public prop logger: Logger
功能:获取客户端日志记录器,设置 logger.level 将立即生效,记录器应该是线程安全的。
类型:Logger
public prop maxConcurrentStreams: UInt32
功能:获取客户端 HTTP/2 初始最大并发流数量,默认值为 2^31 - 1。
类型:UInt32
public prop maxFrameSize: UInt32
功能:获取客户端 HTTP/2 初始最大帧大小。默认值为 16384. 取值范围为 2^14 至 2^24 - 1。
类型:UInt32
public prop maxHeaderListSize: UInt32
功能:获取客户端支持的 HTTP/2 最大头部(Header)大小。这个大小指的是响应头部中所有头部字段(Header Field)的最大允许长度之和,其中包括所有字段名称(name)的长度、字段值(value)的长度以及每个字段自动添加的伪头开销(通常每个字段会有32字节的开销,这包括了HTTP/2协议本身为头部字段添加的伪头部信息)。默认情况下,这个最大长度被设置为 UInt32.Max。
类型:UInt32
public prop poolSize: Int64
功能:配置 HTTP/1.1 客户端使用的连接池的大小,亦可表示对同一个主机(host:port)同时存在的连接数的最大值。
类型:Int64
public func connect(url: String, header!: HttpHeaders = HttpHeaders(), version!: Protocol = HTTP1_1): (HttpResponse, ?StreamingSocket)
功能:发送 CONNECT 请求与服务器建立隧道,返回建连成功后的连接,连接由用户负责关闭。服务器返回 2xx 表示建连成功,否则建连失败(不支持自动重定向,3xx 也视为失败)。
参数:
返回值:
异常:
public func delete(url: String): HttpResponse
功能:请求方法为 DELETE 的便捷请求函数。
参数:
返回值:
异常:
public func get(url: String): HttpResponse
功能:请求方法为 GET 的便捷请求函数。
参数:
返回值:
异常:
public func getTlsConfig(): ?TlsClientConfig
功能:获取客户端设定的 TLS 层配置。
返回值:
public func head(url: String): HttpResponse
功能:请求方法为 HEAD 的便捷请求函数。
参数:
返回值:
异常:
public func options(url: String): HttpResponse
功能:请求方法为 OPTIONS 的便捷请求函数。
参数:
返回值:
异常:
public func post(url: String, body: Array<UInt8>): HttpResponse
功能:请求方法为 POST 的便捷请求函数。
参数:
返回值:
异常:
public func post(url: String, body: InputStream): HttpResponse
功能:请求方法为 POST 的便捷请求函数。
参数:
返回值:
异常:
public func post(url: String, body: String): HttpResponse
功能:请求方法为 POST 的便捷请求函数。
参数:
返回值:
异常:
public func put(url: String, body: Array<UInt8>): HttpResponse
功能:请求方法为 PUT 的便捷请求函数。
参数:
返回值:
异常:
public func put(url: String, body: InputStream): HttpResponse
功能:请求方法为 PUT 的便捷请求函数。
参数:
返回值:
异常:
public func put(url: String, body: String): HttpResponse
功能:请求方法为 PUT 的便捷请求函数。
参数:
返回值:
异常:
public func send(req: HttpRequest): HttpResponse
功能:通用请求函数,发送 HttpRequest 到 url 中的服务器,接收 HttpResponse。
参数:
返回值:
异常:
public func upgrade(req: HttpRequest): (HttpResponse, ?StreamingSocket)
功能:发送请求并升级协议,用户设置请求头,返回升级后的连接(如果升级成功),连接由用户负责关闭。
参数:
返回值:
异常:
public class ClientBuilder {
public init()
} 功能:用于 Client 实例的构建,Client 没有公开的构造函数,用户只能通过 ClientBuilder 得到 Client 实例。ClientBuilder 文档中未明确说明支持版本的配置,在 HTTP/1.1 与 HTTP/2 都会生效。
public func autoRedirect(auto: Bool): ClientBuilder
功能:配置客户端是否会自动进行重定向。重定向会请求 Location 头的资源,协议规定,Location 只能包含一个 URI 引用Location = URI-reference,详见 RFC 9110 10.2.2.。304 状态码默认不重定向。
参数:
返回值:
public func build(): Client
功能:构造 Client 实例。
返回值:
异常:
public func connector(connector: (String)->StreamingSocket): ClientBuilder
功能:客户端调用此函数获取到服务器的连接。
参数:
返回值:
public func cookieJar(cookieJar: ?CookieJar): ClientBuilder
功能:用于存储客户端所有 Cookie。
参数:
返回值:
public func enablePush(enable: Bool): ClientBuilder
功能:配置客户端 HTTP/2 是否支持服务器推送。
参数:
返回值:
public func headerTableSize(size: UInt32): ClientBuilder
功能:配置客户端 HTTP/2 Hpack 动态表初始值。
参数:
返回值:
public func httpProxy(addr: String): ClientBuilder
功能:设置客户端 http 代理,默认使用系统环境变量 http_proxy 的值。
参数:
返回值:
public func httpsProxy(addr: String): ClientBuilder
功能:设置客户端 https 代理,默认使用系统环境变量 https_proxy 的值。
参数:
返回值:
public func initialWindowSize(size: UInt32): ClientBuilder
功能:配置客户端 HTTP/2 流控窗口初始值。
参数:
返回值:
public func logger(logger: Logger): ClientBuilder
功能:设定客户端的 logger,默认 logger 级别为 INFO,logger 内容将写入 Console.stdout。
参数:
返回值:
public func maxConcurrentStreams(size: UInt32): ClientBuilder
功能:配置客户端 HTTP/2 初始最大并发流数量。
参数:
返回值:
public func maxFrameSize(size: UInt32): ClientBuilder
功能:配置客户端 HTTP/2 初始最大帧大小。
参数:
返回值:
public func maxHeaderListSize(size: UInt32): ClientBuilder
功能:获取客户端支持的 HTTP/2 最大头部(Header)大小。这个大小指的是响应头部中所有头部字段(Header Field)的最大允许长度之和,其中包括所有字段名称(name)的长度、字段值(value)的长度以及每个字段自动添加的伪头开销(通常每个字段会有32字节的开销,这包括了HTTP/2协议本身为头部字段添加的伪头部信息)。默认情况下,这个最大长度被设置为 UInt32.Max。
参数:
返回值:
public func noProxy(): ClientBuilder
功能:调用此函数后,客户端不使用任何代理。
返回值:
public func poolSize(size: Int64): ClientBuilder
功能:配置 HTTP/1.1 客户端使用的连接池的大小,亦可表示对同一个主机(host:port)同时存在的连接数的最大值。
参数:
返回值:
异常:
public func readTimeout(timeout: Duration): ClientBuilder
功能:设定客户端读取一个响应的最大时长。
参数:
返回值:
public func tlsConfig(config: TlsClientConfig): ClientBuilder
功能:设置 TLS 层配置,默认不对其进行设置。
参数:
返回值:
public func writeTimeout(timeout: Duration): ClientBuilder
功能:设定客户端发送一个请求的最大时长。
参数:
返回值:
public class Cookie {
public init(name: String, value: String, expires!: ?DateTime = None, maxAge!: ?Int64 = None,
domain!: String = "", path!: String = "", secure!: Bool = false, httpOnly!: Bool = false)
} 功能:HTTP 本身是无状态的,server 为了知道 client 的状态,提供个性化的服务,便可以通过 Cookie 来维护一个有状态的会话。
public init(name: String, value: String, expires!: ?DateTime = None, maxAge!: ?Int64 = None,
domain!: String = "", path!: String = "", secure!: Bool = false, httpOnly!: Bool = false) 功能:提供 Cookie 对象的公开构造器说明:该构造器会检查传入的各项属性是否满足协议要求,如果不满足则会产生 IllegalArgumentException。具体要求见 RFC 6265 4.1.1.。
Cookie 各属性中只有 cookie-name,cookie-value 是必需的,必须传入 name,value 参数,但 value 参数可以传入空字符串。
参数:
name: String - cookie-name 属性。
name = token
token = 1*tchar
tchar = "!" / "#" / "$" / "%" / "&" / "'" / "*"
/ "+" / "-" / "." / "^" / "_" / "`" / "|" / "~"
/ DIGIT / ALPHA value: String - cookie-value 属性。
value = *cookie-octet / ( DQUOTE *cookie-octet DQUOTE )
cookie-octet = %x21 / %x23-2B / %x2D-3A / %x3C-5B / %x5D-7E
; US-ASCII characters excluding CTLs,
; whitespace DQUOTE, comma, semicolon,
; and backslash expires!: ?DateTime - 设置 Cookie 的过期时间,默认为 None,时间必须在 1601 年之后。
maxAge!: ?Int64 - Cookie 的最大生命周期,默认为 None,如果 Cookie 既有 expires 属性,也有 maxAge,则表示该 Cookie 只维护到会话结束(维护到 Client 关闭之前,Client 关闭之后设置了过期的 Cookie 也不再维护)。
max-age-av = "Max-Age=" non-zero-digit *DIGIT
non-zero-digit = %x31-39
; digits 1 through 9
DIGIT = %x30-39
; digits 0 through 9 domain!: String - 默认为空字符串,表示该收到该 Cookie 的客户端只会发送该 Cookie 给原始服务器。如果设置了合法的 domain,则收到该 Cookie 的客户端只会发送该 Cookie 给所有该 domain 的子域(且满足其他属性条件要求才会发)。
domain = <subdomain> | " " <subdomain> ::= <label> | <subdomain> "." <label> <label> ::= <letter> [ [ <ldh-str> ] <let-dig> ] <ldh-str> ::= <let-dig-hyp> | <let-dig-hyp> <ldh-str> <let-dig-hyp> ::= <let-dig> | "-" <let-dig> ::= <letter> | <digit> <letter> ::= any one of the 52 alphabetic characters A through Z in upper case and a through z in lower case <digit> ::= any one of the ten digits 0 through 9 RFC 1035 2.3.1. 而 RFC 1123 2.1. 放松了对 label 首字符必须是 letter 的限制 因此,对 domain 的要求为: 1、总长度小于等于 255,由若干个 label 组成 2、label 与 label 之间通过 "." 分隔,每个 label 长度小于等于 63 3、label 的开头和结尾必须是数字或者字母,label 的中间字符必须是数字、字母或者 "-"
path!: String - 默认为空字符串,客户端会根据 url 计算出默认的 path 属性,见 RFC 6265 5.1.4.。 收到该 Cookie 的客户端只会发送该 Cookie 给所有该 path 的子目录(且满足其他属性条件要求才会发)。
path = <any RUNE except CTLs or ";"> RUNE = <any [USASCII] character> CTLs = <controls>
httpOnly!: Bool - 默认为 false,如果设置为 true,该 Cookie 只会在 HTTP 协议请求中发送。
异常:
public func toSetCookieString(): String
功能:提供将 Cookie 转成字符串形式的函数,方便 server 设置 Set-Cookie header。
返回值:
public class FileHandler <: HttpRequestHandler {
public init(path: String, handlerType!: FileHandlerType = DownLoad, bufferSize!: Int64 = 64 * 1024)
} 功能:用于处理文件下载或者文件上传。
文件下载:
文件上传:
public init(path: String, handlerType!: FileHandlerType = DownLoad, bufferSize!: Int64 = 64 * 1024)
功能:FileHandler 的构造函数。
参数:
异常:
public func handle(ctx: HttpContext): Unit
功能:根据请求对响应数据进行处理。
参数:
public class FuncHandler <: HttpRequestHandler {
public FuncHandler((HttpContext) -> Unit)
} 功能:HttpRequestHandler 接口包装类,把单个函数包装成 HttpRequestHandler。
public FuncHandler(let handler: (HttpContext) -> Unit)
功能:FuncHandler 的构造函数。
参数:
public func handle(ctx: HttpContext): Unit
功能:处理 Http 请求。
参数:
public prop clientCertificate: ?Array<X509Certificate>
功能:获取 Http 客户端证书。
类型:?Array<X509Certificate>
public class HttpHeaders <: Iterable<(String, Collection<String>)> {
public init()
} 功能:此类用于表示 Http 报文中的 header 和 trailer,定义了相关增、删、改、查操作。
示例:
Example-Field: Foo, Bar key: Example-Field, value: Foo, Bar field-name = token token = 1*tchar tchar = "!" / "#" / "$" / "%" / "&" / "'" / "*" / "+" / "-" / "." / "^" / "_" / "`" / "|" / "~" / DIGIT / ALPHA ; any VCHAR, except delimiters
public func add(name: String, value: String): Unit
功能:添加指定键值对。如果 name 已经存在,将在其对应的值列表中添加 value;如果 name 不存在,则添加 name 字段及其值 value。
参数:
异常:
public func del(name: String): Unit
功能:删除指定 name 对应的键值对。
参数:
public func get(name: String): Collection<String>
功能:获取指定 name 对应的 value 值。
参数:
返回值:
public func getFirst(name: String): ?String
功能:获取指定 name 对应的第一个 value 值。
参数:
返回值:
public func isEmpty(): Bool
功能:判断当前实例是否为空,即没有任何键值对。
返回值:
public func iterator(): Iterator<(String, Collection<String>)>
功能:获取迭代器,可用于遍历所有键值对。
返回值:
public func set(name: String, value: String): Unit
功能:设置指定键值对。如果 name 已经存在,传入的 value 将会覆盖之前的值。
参数:
异常:
public class HttpRequest <: ToString
功能:此类为 Http 请求类。
客户端发送请求时,需要构造一个 HttpRequest 实例,再编码成字节报文发出。
服务端处理请求时,需要把收到的请求解析成 HttpRequest 实例,并传给 handler 处理函数。
public prop body: InputStream
功能:获取 body。
类型:InputStream
public prop bodySize: Option<Int64>
功能:获取请求 body 长度。
public prop close: Bool
功能:表示该请求 header 是否包含 Connection: close。
类型:Bool
public prop form: Form
功能:获取请求中的表单信息。
类型:Form
public prop headers: HttpHeaders
功能:获取 headers,headers 详述见 HttpHeaders 类,获取后,可通过调用 HttpHeaders 实例成员函数,修改该请求的 headers。
类型:HttpHeaders
public prop method: String
功能:获取 method,如 "GET", "POST",request 实例的 method 无法修改。
类型:String
public prop readTimeout: ?Duration
功能:表示该请求的请求级读超时时间。None 表示没有设置;Some(Duration) 表示设置了读超时时间。
类型:?Duration
public prop remoteAddr: String
功能:用于服务端,获取对端地址,即客户端地址,格式为 ip: port,用户无法设置,自定义的 request 对象调用该属性返回 "",服务端 handler 中调用该属性返回客户端地址。
类型:String
public prop trailers: HttpHeaders
功能:获取 trailers,trailers 详述见 HttpHeaders 类,获取后,可通过调用 HttpHeaders 实例成员函数,修改该请求的 trailers。
类型:HttpHeaders
public prop version: Protocol
功能:获取 http 版本,如 HTTP1_1 和 HTTP2_0,request 实例的 version 无法修改。
类型:Protocol
public prop writeTimeout: ?Duration
功能:表示该请求的请求级写超时时间,None 表示没有设置;Some(Duration) 表示设置了写超时时间。
类型:?Duration
public override func toString(): String
功能:把请求转换为字符串,包括 start line,headers,body size,trailers。
例如:"GET /path HTTP/1.1\r\nhost: www.example.com\r\n\r\nbody size: 5\r\nbar: foo\r\n"。
返回值:
public class HttpRequestBuilder {
public init()
} 功能:HttpRequestBuilder 类用于构造 HttpRequest 实例。
public init(request: HttpRequest)
功能: 通过 request 构造一个具有 request 属性的 HttpRequestBuilder。由于 body 成员是一个 InputStream,对原始的 request 的 body 的操作会影响到复制得到的 HttpRequest 的 body。HttpRequestBuilder 的 headers 和 trailers 是入参 request 的深拷贝。其余元素都是入参 request 的浅拷贝(因为是不可变对象,无需深拷贝)。
参数:
public func addHeaders(headers: HttpHeaders): HttpRequestBuilder
功能:向请求 header 添加参数 HttpHeaders 中的键值对。
参数:
返回值:
public func addTrailers(trailers: HttpHeaders): HttpRequestBuilder
功能:向请求 trailer 添加参数 HttpHeaders 中的键值对。
参数:
返回值:
public func body(body: Array<UInt8>): HttpRequestBuilder
功能:设置请求 body。如果已经设置过,调用该函数将替换原 body。
参数:
返回值:
public func body(body: InputStream): HttpRequestBuilder
功能:设置请求 body。如果已经设置过,调用该函数将替换原 body。
参数:
返回值:
public func body(body: String): HttpRequestBuilder
功能:设置请求 body,如果已经设置过,调用该函数将替换原 body调用该函数设置请求 body,则 body 将以内置的 InputStream 实现类表示,其大小已知。
参数:
返回值:
public func build(): HttpRequest
功能:根据 HttpRequestBuilder 实例生成一个 HttpRequest 实例。
返回值:
public func connect(): HttpRequestBuilder
功能:构造 method 为 "CONNECT" 的请求的便捷函数。
返回值:
public func delete(): HttpRequestBuilder
功能:构造 method 为 "DELETE" 的请求的便捷函数。
返回值:
public func get(): HttpRequestBuilder
功能:构造 method 为 "GET" 的请求的便捷函数。
返回值:
public func head(): HttpRequestBuilder
功能:构造 method 为 "HEAD" 的请求的便捷函数。
返回值:
public func header(name: String, value: String): HttpRequestBuilder
功能:向请求 header 添加指定键值对,规则同 HttpHeaders 类的 add 函数。
参数:
返回值:
异常:
public func method(method: String): HttpRequestBuilder
功能:设置请求 method,默认请求 method 为 "GET"。
参数:
返回值:
异常:
public func options(): HttpRequestBuilder
功能:构造 method 为 "OPTIONS" 的请求的便捷函数。
返回值:
public func post(): HttpRequestBuilder
功能:构造 method 为 "POST" 的请求的便捷函数。
返回值:
public func priority(urg: Int64, inc: Bool): HttpRequestBuilder
功能:设置 priority 头的便捷函数,调用此函数后,将生成 priority 头,形如:"priority: urgency=x, i"。如果通过设置请求头的函数设置了 priority 字段,调用此函数无效。如果多次调用此函数,以最后一次为准。
参数:
返回值:
public func put(): HttpRequestBuilder
功能:构造 method 为 "PUT" 的请求的便捷函数。
返回值:
public func readTimeout(timeout: Duration): HttpRequestBuilder
功能:设置此请求的读超时时间。如果传入的 Duration 为负,则会自动转为 0。如果用户设置了此读超时时间,那么该请求的读超时以此为准;如果用户没有设置,那么该请求的读超时以 Client 为准。
参数:
返回值:
public func setHeaders(headers: HttpHeaders): HttpRequestBuilder
功能:设置请求 header,如果已经设置过,调用该函数将替换原 header。
参数:
返回值:
public func setTrailers(trailers: HttpHeaders): HttpRequestBuilder
功能:设置请求 trailer,如果已经设置过,调用该函数将替换原 trailer。
参数:
返回值:
public func trace(): HttpRequestBuilder
功能:构造 method 为 "TRACE" 的请求的便捷函数。
返回值:
public func trailer(name: String, value: String): HttpRequestBuilder
功能:向请求 trailer 添加指定键值对,规则同 HttpHeaders 类的 add 函数。
参数:
返回值:
异常:
public func url(rawUrl: String): HttpRequestBuilder
功能:设置请求 url,默认 url 为空的 URL 对象。
参数:
返回值:
异常:
public func url(url: URL): HttpRequestBuilder
功能:设置请求 url,默认 url 为空的 URL 对象,即 URL.parse("")。
参数:
返回值:
public func version(version: Protocol): HttpRequestBuilder
功能:设置请求的 http 协议版本,默认为 UnknownProtocol(""),客户端会根据 tls 配置自动选择协议。
参数:
返回值:
public func writeTimeout(timeout: Duration): HttpRequestBuilder
功能:设置此请求的写超时时间。如果传入的 Duration 为负,则会自动转为 0。如果用户设置了此写超时时间,那么该请求的写超时以此为准;如果用户没有设置,那么该请求的写超时以 Client 为准。
参数:
返回值:
public class HttpResponse <: ToString
功能:Http 响应类。
此类定义了 http 中响应 Response 的相关接口,客户端用该类读取服务端返回的响应。
public prop body: InputStream
功能:获取 body。
类型:InputStream
public prop bodySize: Option<Int64>
功能:获取响应 body 长度。
public prop close: Bool
功能:表示该响应 header 是否包含 Connection: close。
对于服务端,close 为 true 表示处理完该请求应该关闭连接;
对于客户端,close 为 true 表示如果收到响应后服务端未关闭连接,客户端应主动关闭连接。
类型:Bool
public prop headers: HttpHeaders
功能:获取 headers,headers 详述见 HttpHeaders 类,获取后,可通过调用 HttpHeaders 实例成员函数,修改该请求的 headers。
类型:HttpHeaders
public prop request: Option<HttpRequest>
功能:获取该响应对应的请求,默认为 None。
类型:Option<HttpRequest>
public prop status: UInt16
功能:获取响应的状态码,默认值为 200。状态码由 100~599 的三位数字组成,状态码所反映的具体信息可参考 RFC 9110。
类型:UInt16
public prop trailers: HttpHeaders
功能:获取 trailers,trailers 详述见 HttpHeaders 类,获取后,可通过调用 HttpHeaders 实例成员函数,修改该请求的 trailers。
类型:HttpHeaders
public func getPush(): ?<ArrayList<HttpResponse>>
功能:获取服务器推送的响应,返回 None 代表未开启服务器推送功能,返回空 ArrayList 代表无服务器推送的响应。
返回值:
public override func toString(): String
功能:把响应转换为字符串,包括 status-line,headers,body size, trailers。
例如:HTTP/1.1 200 OK\r\ncontent-length: 5\r\n\r\nbody size: 5\r\nbar: foo\r\n。
返回值:
public class HttpResponseBuilder {
public init()
} 功能:用于构造 HttpResponse 实例。
public func addHeaders(headers: HttpHeaders): HttpResponseBuilder
功能:向响应 header 添加参数 HttpHeaders 中的键值对。
参数:
返回值:
public func addTrailers(trailers: HttpHeaders): HttpResponseBuilder
功能:向响应 trailer 添加参数 HttpHeaders 中的键值对。
参数:
返回值:
public func body(body: Array<UInt8>): HttpResponseBuilder
功能:设置响应 body,如果已经设置过,调用该函数将替换原 body。
参数:
返回值:
public func body(body: InputStream): HttpResponseBuilder
功能:设置响应 body,如果已经设置过,调用该函数将替换原 body调用该函数设置请求 body。
参数:
返回值:
public func body(body: String): HttpResponseBuilder
功能:设置响应 body,如果已经设置过,调用该函数将替换原 body调用该函数设置请求 body。
参数:
返回值:
public func build(): HttpResponse
功能:根据 HttpResponseBuilder 实例生成一个 HttpResponse 实例。
返回值:
public func header(name: String, value: String): HttpResponseBuilder
功能:向响应 header 添加指定键值对,规则同 HttpHeaders 类的 add 函数。
参数:
返回值:
异常:
public func request(request: HttpRequest): HttpResponseBuilder
功能:设置响应对应的请求。
参数:
返回值:
public func setHeaders(headers: HttpHeaders): HttpResponseBuilder
功能:设置响应 header,如果已经设置过,调用该函数将替换原 header。
参数:
返回值:
public func setTrailers(trailers: HttpHeaders): HttpResponseBuilder
功能:设置响应 trailer,如果已经设置过,调用该函数将替换原 trailer。
参数:
返回值:
public func status(status: UInt16): HttpResponseBuilder
功能:设置 http 响应状态码。
参数:
返回值:
异常:
public func trailer(name: String, value: String): HttpResponseBuilder
功能:向响应 trailer 添加指定键值对,规则同 HttpHeaders 类的 add 函数。
参数:
返回值:
异常:
public func version(version: Protocol): HttpResponseBuilder
功能:设置 http 响应协议版本。
参数:
返回值:
public class HttpResponsePusher
功能:HTTP/2 服务器推送。
如果服务器收到请求后,认为客户端后续还需要某些关联资源,可以将其提前推送到客户端;
服务端推送包括推送请求和推送响应;
启用服务端推送需要先调用 push 函数发送推送请求,并向服务器注册该请求对应的 handler,用以生成推送响应;
客户端可设置拒绝服务端推送;
不允许嵌套推送,即不允许在推送请求对应的 handler 中再次推送。嵌套推送情况下,服务端将不执行推送,并打印日志进行提示。
public static func getPusher(ctx: HttpContext): ?HttpResponsePusher
功能:获取 HttpResponsePusher 实例,如果客户端拒绝推送,将返回 None。
参数:
返回值:
public func push(path: String, method: String, header: HttpHeaders): Unit
功能:向客户端发送推送请求,path 为请求地址,method 为请求方法,header 为请求头。
参数:
public class HttpResponseWriter {
public HttpResponseWriter(let ctx: HttpContext)
} 功能:HTTP response 消息体 Writer,支持用户控制消息体的发送过程。
第一次调用 write 函数时,将立即发送 header 和通过参数传入的 body,此后每次调用 write,发送通过参数传入的 body。
对于 HTTP/1.1,如果设置了 transfer-encoding: chunked,用户每调用一次 write,将发送一个 chunk。
对于 HTTP/2,用户每调用一次 write,将把指定数据封装并发出。
public HttpResponseWriter(let ctx: HttpContext)
功能:构造一个 HttpResponseWriter 实例。
参数:
public func write(buf: Array<Byte>): Unit
功能:发送 buf 中数据到客户端。
参数:
异常:
public class NotFoundHandler <: HttpRequestHandler {
public init()
} 功能:便捷的 Http 请求处理器,404 Not Found 处理器。
public func handle(ctx: HttpContext): Unit
功能:处理 Http 请求,回复 404 响应。
参数:
public class OptionsHandler <: HttpRequestHandler {
public init()
} 功能:便捷的 Http 处理器,用于处理 OPTIONS 请求。固定返回 "Allow: OPTIONS,GET,HEAD,POST,PUT,DELETE" 响应头。
public func handle(ctx: HttpContext): Unit
功能:处理 Http OPTIONS 请求。
参数:
public abstract class ProtocolService
功能:Http 协议服务实例,为单个客户端连接提供 Http 服务,包括对客户端 request 报文的解析、 request 的分发处理、 response 的发送等。
public init(url: String, code: UInt16)
功能:RedirectHandler 的构造函数。
参数:
异常:
public func handle(ctx: HttpContext): Unit
功能:处理 Http 请求,回复重定向响应。
参数:
public prop distributor: HttpRequestDistributor
功能:获取请求分发器,请求分发器会根据 url 将请求分发给对应的 handler。
public prop enableConnectProtocol: Bool
功能:HTTP/2 专用,用来限制对端发送的报文是否支持通过 connect 方法升级协议,true 表示支持。
类型:Bool
public prop headerTableSize: UInt32
功能:获取服务端 HTTP/2 Hpack 动态表的初始值,默认值为 4096。
类型:UInt32
public prop httpKeepAliveTimeout: Duration
功能:HTTP/1.1 专用,获取服务器设定的保持长连接的超时时间。
类型:Duration
public prop initialWindowSize: UInt32
功能:HTTP/2 专用,用来限制对端发送的报文stream 初始流量窗口大小。默认值为 65535 ,取值范围为 0 至 2^31 - 1。
类型:UInt32
public prop logger: Logger
功能:获取服务器日志记录器,设置 logger.level 将立即生效,记录器应该是线程安全的。
类型:Logger
public prop maxConcurrentStreams: UInt32
功能:HTTP/2 专用,用来限制连接同时处理的最大请求数量。
类型:UInt32
public prop maxFrameSize: UInt32
功能:HTTP/2 专用,用来限制对端发送的报文一个帧的最大长度。默认值为 16384. 取值范围为 2^14 至 2^24 - 1。
类型:UInt32
public prop maxHeaderListSize: UInt32
功能:获取客户端支持的 HTTP/2 最大头部(Header)大小。这个大小指的是响应头部中所有头部字段(Header Field)的最大允许长度之和,其中包括所有字段名称(name)的长度、字段值(value)的长度以及每个字段自动添加的伪头开销(通常每个字段会有32字节的开销,这包括了HTTP/2协议本身为头部字段添加的伪头部信息)。默认情况下,这个最大长度被设置为 UInt32.Max。
类型:UInt32
public prop maxRequestBodySize: Int64
功能:获取服务器设定的读取请求的请求体最大值,仅对于 HTTP/1.1 且未设置 "Transfer-Encoding: chunked" 的请求生效。
类型:Int64
public prop maxRequestHeaderSize: Int64
功能:获取服务器设定的读取请求的请求头最大值。仅对 HTTP/1.1 生效,HTTP/2 中有专门的配置 maxHeaderListSize。
类型:Int64
public prop protocolServiceFactory: ProtocolServiceFactory
功能:获取协议服务工厂,服务协议工厂会生成每个协议所需的服务实例。
public prop readHeaderTimeout: Duration
功能:获取服务器设定的读取请求头的超时时间。
类型:Duration
public func afterBind(f: ()->Unit): Unit
功能:注册服务器启动时的回调函数,服务内部 ServerSocket 实例 bind 之后,accept 之前将调用该函数。重复调用将覆盖之前注册的函数。
参数:
public func close(): Unit
功能:关闭服务器,服务器关闭后将不再对请求进行读取与处理,重复关闭将只有第一次生效(包括 close 和 closeGracefully)。
public func closeGracefully(): Unit
功能:关闭服务器,服务器关闭后将不再对请求进行读取,当前正在进行处理的服务器待处理结束后进行关闭。
public func getTlsConfig(): ?TlsServerConfig
功能:获取服务器设定的 TLS 层配置。
返回值:
public func onShutdown(f: ()->Unit): Unit
功能:注册服务器关闭时的回调函数,服务器关闭时将调用该回调函数,重复调用将覆盖之前注册的函数。
参数:
public func serve(): Unit
功能:启动服务端进程,不支持重复启动。
h1 request 检查和处理:
h1 response 检查和处理:
启用 h2 服务:tlsConfig 中 supportedAlpnProtocols 需包含 "h2",此后如果 tls 层 alpn 协商结果为 h2,则启用 h2 服务。
h2 request 检查和处理:
h2 response 检查和处理:
h2 server 发完 response 之后,如果 stream 状态不是 CLOSED,会发送带 NO_ERROR 错误码的 RST 帧关闭 stream,避免已经处理完毕的 stream 继续占用服务器资源。
h2 流量控制:
h2 请求优先级:
默认 ProtocolServiceFactory 协议选择:
异常:
public func updateCA(newCa: Array<X509Certificate>): Unit
功能:对 CA 证书进行热更新。
参数:
异常:
public func updateCA(newCaFile: String): Unit
功能:对 CA 证书进行热更新。
参数:
异常:
public func updateCert(certChain: Array<X509Certificate>, certKey: PrivateKey): Unit
功能:对 TLS 证书进行热更新。
参数:
异常:
public func updateCert(certificateChainFile: String, privateKeyFile: String): Unit
功能:对 TLS 证书进行热更新。
参数:
异常:
public class ServerBuilder {
public init()
} 功能:提供 Server 实例构建器。
支持通过如下参数构造一个 Http Server:
除地址端口、shutdown 回调外,均提供默认实现,用户在构造 server 过程中可不指定其他构建参数。
ServerBuilder 文档中未明确说明支持版本的配置,在 HTTP/1.1 与 HTTP/2 都会生效。
public func addr(addr: String): ServerBuilder
功能:设置服务端监听地址,若 listener 被设定,此值被忽略。
参数:
返回值:
public func afterBind(f: ()->Unit): ServerBuilder
功能:注册服务器启动时的回调函数,服务内部 ServerSocket 实例 bind 之后,accept 之前将调用该函数。重复调用将覆盖之前注册的函数。
参数:
返回值:
public func build(): Server
功能:根据设置的属性构建 Server 实例。
返回值:
异常:
public func distributor(distributor: HttpRequestDistributor): ServerBuilder
功能:设置请求分发器,请求分发器会根据 url 将请求分发给对应的 handler。不设置时使用默认请求分发器。
参数:
返回值:
public func enableConnectProtocol(flag: Bool): ServerBuilder
功能:HTTP/2 专用,设置本端是否接收 CONNECT 请求,默认 false。
参数:
返回值:
public func headerTableSize(size: UInt32): ServerBuilder
功能:设置服务端 HTTP/2 Hpack 动态表的初始值,默认值为 4096。
参数:
返回值:
public func httpKeepAliveTimeout(timeout: Duration): ServerBuilder
功能:HTTP/1.1 专用,设定服务端连接保活时长,该时长内客户端未再次发送请求,服务端将关闭长连接,默认不进行限制。
参数:
返回值:
public func initialWindowSize(size: UInt32): ServerBuilder
功能:HTTP/2 专用,设置当前服务器上每个流的接收报文的初始流量窗口大小,默认值为 65535。取值范围为 0 至 2^31 - 1。
参数:
返回值:
public func listener(listener: ServerSocket): ServerBuilder
功能:服务端调用此函数对指定 socket 进行绑定监听。
参数:
返回值:
public func logger(logger: Logger): ServerBuilder
功能:设定服务器的 logger,默认 logger 级别为 INFO,logger 内容将写入 Console.stdout。
参数:
返回值:
public func maxConcurrentStreams(size: UInt32): ServerBuilder
功能:HTTP/2 专用,设置本端同时处理的最大请求数量,限制对端并发发送请求的数量,默认值为 100。
参数:
返回值:
public func maxFrameSize(size: UInt32): ServerBuilder
功能:HTTP/2 专用,设置本端接收的一个帧的最大长度,用来限制对端发送帧的长度,默认值为 16384. 取值范围为 2^14 至 2^24 - 1。
参数:
返回值:
public func maxHeaderListSize(size: UInt32): ServerBuilder
功能:获取客户端支持的 HTTP/2 最大头部(Header)大小。这个大小指的是响应头部中所有头部字段(Header Field)的最大允许长度之和,其中包括所有字段名称(name)的长度、字段值(value)的长度以及每个字段自动添加的伪头开销(通常每个字段会有32字节的开销,这包括了HTTP/2协议本身为头部字段添加的伪头部信息)。默认情况下,这个最大长度被设置为 UInt32.Max。
参数:
返回值:
public func maxRequestBodySize(size: Int64): ServerBuilder
功能:设置服务端允许客户端发送单个请求的请求体最大长度,请求体长度超过该值时,将返回状态码为 413 的响应。默认值为 2M。仅对于 HTTP/1.1 且未设置 "Transfer-Encoding: chunked" 的请求生效。
参数:
返回值:
异常:
public func maxRequestHeaderSize(size: Int64): ServerBuilder
功能:设定服务端允许客户端发送单个请求的请求头最大长度,请求头长度超过该值时,将返回状态码为 431 的响应;仅对 HTTP/1.1 生效,HTTP/2 中有专门的配置 maxHeaderListSize。
参数:
返回值:
异常:
public func onShutdown(f: ()->Unit): ServerBuilder
功能:注册服务器关闭时的回调函数,服务器关闭时将调用该回调函数,重复调用将覆盖之前注册的函数。
参数:
返回值:
public func port(port: UInt16): ServerBuilder
功能:设置服务端监听端口,若 listener 被设定,此值被忽略。
参数:
返回值:
public func protocolServiceFactory(factory: ProtocolServiceFactory): ServerBuilder
功能:设置协议服务工厂,服务协议工厂会生成每个协议所需的服务实例,不设置时使用默认工厂。
参数:
返回值:
public func readHeaderTimeout(timeout: Duration): ServerBuilder
功能:设定服务端读取客户端发送一个请求的请求头最大时长,超过该时长将不再进行读取并关闭连接,默认不进行限制。
参数:
返回值:
public func readTimeout(timeout: Duration): ServerBuilder
功能:设定服务端读取一个请求的最大时长,超过该时长将不再进行读取并关闭连接,默认不进行限制。
参数:
返回值:
public func servicePoolConfig(cfg: ServicePoolConfig): ServerBuilder
功能:服务过程中使用的协程池相关设置,具体说明见 ServicePoolConfig 结构体。
参数:
返回值:
public func tlsConfig(config: TlsServerConfig): ServerBuilder
功能:设置 TLS 层配置,默认不对其进行设置。
参数:
返回值:
public func transportConfig(config: TransportConfig): ServerBuilder
功能:设置传输层配置,默认配置详见 TransportConfig 结构体说明。
参数:
返回值:
public func writeTimeout(timeout: Duration): ServerBuilder
功能:设定服务端发送一个响应的最大时长,超过该时长将不再进行写入并关闭连接,默认不进行限制。
参数:
返回值:
public class WebSocket
功能:提供 WebSocket 服务的相关类,提供 WebSocket 连接的读、写、关闭等函数。用户通过 upgradeFrom 函数以获取 WebSocket 连接。
详细说明见下文接口说明,接口行为以 RFC 6455 为准。
public prop subProtocol: String
功能:获取与对端协商到的 subProtocol,协商时,客户端提供一个按偏好排名的 subProtocols 列表,服务器从中选取一个或零个子协议。
类型:String
public static func upgradeFromClient(client: Client, url: URL, version!: Protocol = HTTP1_1, subProtocols!: ArrayList<String> = ArrayList<String>(), headers!: HttpHeaders = HttpHeaders()): (WebSocket, HttpHeaders)
功能:提供客户端升级到 WebSocket 协议的函数。
客户端的升级流程为:传入 client 对象,url 对象,构建升级请求,请求服务器后验证其响应,如果握手成功,则返回 WebSocket 对象用于 WebSocket 通讯,并返回 101 响应头的 HttpHeaders 对象给用户。暂不支持 extensions如果子协议协商成功,用户可通过调用返回的 WebSocket 的 subProtocol 查看子协议。
参数:
返回值:
异常:
public static func upgradeFromServer(ctx: HttpContext, subProtocols!: ArrayList<String> = ArrayList<String>(),
origins!: ArrayList<String> = ArrayList<String>(),
userFunc!:(HttpRequest) -> HttpHeaders = {_: HttpRequest => HttpHeaders()}): WebSocket 功能:提供服务端升级到 WebSocket 协议的函数,通常在 handler 中使用。
服务端升级的流程为:收到客户端发来的升级请求,验证请求,如果验证通过,则回复 101 响应并返回 WebSocket 对象用于 WebSocket 通讯。
参数:
返回值:
public func closeConn(): Unit
功能:提供关闭底层 WebSocket 连接的函数。
直接关闭底层连接。正常的关闭流程需要遵循协议规定的握手流程,即先发送 Close 帧给对端,并等待对端回应的 Close 帧。握手流程结束后方可关闭底层连接。
public func read(): WebSocketFrame
功能:从连接中读取一个帧,如果连接上数据未就绪会阻塞,非线程安全(即对同一个 WebSocket 对象不支持多线程读)。
read 函数返回一个 WebSocketFrame 对象,用户可以调用 WebSocketFrame 的 frameType,fin 属性确定其帧类型和是否是分段帧调用。通过 WebSocketFrame 的 payload 函数得到原始二进制数据数组:Array<UInt8>
返回值:
异常:
public func write(frameType: WebSocketFrameType, byteArray: Array<UInt8>, frameSize!: Int64 = FRAMESIZE)
功能:发送数据,非线程安全(即对同一个 WebSocket 对象不支持多线程写)。
write 函数将数据以 WebSocket 帧的形式发送给对端;
参数:
异常:
public func writeCloseFrame(status!: ?UInt16 = None, reason!: String = ""): Unit
功能:发送 Close 帧。
协议规定,Close 帧发送之后,禁止再发送数据帧。如果用户不设置 status,那么 reason 不会被发送(即有 reason 必有 status);控制帧的 payload 不超过 125 bytes,Close 帧的前两个 bytes 为 status,因此 reason 不能超过 123 bytes,closeConn 关闭连接后调用写,抛出异常。
参数:
异常:
public func writePingFrame(byteArray: Array<UInt8>): Unit
功能:提供发送 Ping 帧的快捷函数,closeConn 关闭连接后调用写,抛出异常。
参数:
异常:
public func writePongFrame(byteArray: Array<UInt8>): Unit
功能:提供发送 Pong 帧的快捷函数,closeConn 关闭连接后调用写,抛出异常。
参数:
异常:
public class WebSocketFrame
功能:WebSocket 用于读的基本单元。
WebSocketFrame 提供了三个属性,其中 fin 和 frameType 共同说明了帧是否分段和帧的类型。payload 为帧的载荷。
由于控制帧可以穿插在分段帧之间,用户在拼接分段帧的 payload 时需要单独处理控制帧。分段帧之间仅可穿插控制帧,如果用户在分段帧之间接收到其他数据帧,则需要当作错误处理。
public prop fin: Bool
功能:获取 WebSocketFrame 的 fin 属性,fin 与 frameType 共同说明了帧是否分段和帧的类型。
类型:Bool
public prop frameType: WebSocketFrameType
功能:获取 WebSocketFrame 的帧类型,fin 与 frameType 共同说明了帧是否分段和帧的类型。
public prop payload: Array<UInt8>
功能:获取 WebSocketFrame 的帧载荷。如果是分段数据帧,用户需要在接收到完整的 message 后,将所有分段的 payload 按接收序拼接。