nazahttp

Documentation

Index

• Constants
• Variables
• func DownloadHttpFile(url string, saveTo string, timeoutMs int) (int64, error)
• func GetHttpFile(url string, timeoutMs int) ([]byte, error)
• func ParseHttpRequestLine(line string) (method string, uri string, version string, err error)
• func ParseHttpStatusLine(line string) (version string, statusCode string, reason string, err error)
• func PostJson(url string, info interface{}, client *http.Client) (*http.Response, error)
• func ReadHttpHeader(r LineReader) (firstLine string, headers http.Header, err error)
• func UnmarshalRequestJsonBody(r *http.Request, info interface{}, keyFieldList ...string) error
• type HttpMsgCtx
  • func ReadHttpMessage(r HttpReader) (ctx HttpMsgCtx, err error)
• type HttpReader
• type HttpReqMsgCtx
  • func ReadHttpRequestMessage(r HttpReader) (ctx HttpReqMsgCtx, err error)
• type HttpRespMsgCtx
  • func ReadHttpResponseMessage(r HttpReader) (ctx HttpRespMsgCtx, err error)
• type LineReader

Constants

const (
	HeaderFieldContentLength = "Content-Length"
	HeaderFieldContentType   = "application/json"
)

Variables

var (
	ErrHttpHeader   = errors.New("nazahttp: read http header failed")
	ErrFirstLine    = errors.New("nazahttp: parse first line failed")
	ErrParamMissing = errors.New("nazahttp: param missing")
)

Functions

func DownloadHttpFile

func DownloadHttpFile(url string, saveTo string, timeoutMs int) (int64, error)

获取http文件保存至本地

func GetHttpFile

func GetHttpFile(url string, timeoutMs int) ([]byte, error)

TODO(chef): 重命名为GetAll

GetHttpFile 获取http文件保存至字节切片

func ParseHttpRequestLine

func ParseHttpRequestLine(line string) (method string, uri string, version string, err error)

Request-Line = Method SP URI SP Version CRLF

func ParseHttpStatusLine

func ParseHttpStatusLine(line string) (version string, statusCode string, reason string, err error)

Status-Line = Version SP Status-Code SP Reason CRLF

func PostJson

func PostJson(url string, info interface{}, client *http.Client) (*http.Response, error)

@param url 地址 @param info 需要序列化的结构体 @param client 注意，如果为nil，则使用http.DefaultClient

func ReadHttpHeader

func ReadHttpHeader(r LineReader) (firstLine string, headers http.Header, err error)

ReadHttpHeader

@return firstLine: request的request line或response的status line @return headers: request header fields的键值对

func UnmarshalRequestJsonBody

func UnmarshalRequestJsonBody(r *http.Request, info interface{}, keyFieldList ...string) error

@brief 从http请求中解析body中的json字符串，并反序列化至结构体中

@param r http请求对象 @param info 输出参数，用于接收反序列化之后的数据 @param keyFieldList 可选参数，可指定一个或多个json中必须存在的字段

Types

type HttpMsgCtx

type HttpMsgCtx struct {
	ReqMethodOrRespVersion string
	ReqUriOrRespStatusCode string
	ReqVersionOrRespReason string
	Headers                http.Header
	Body                   []byte
}

func ReadHttpMessage

func ReadHttpMessage(r HttpReader) (ctx HttpMsgCtx, err error)

ReadHttpMessage

注意，如果HTTP Header中不包含`Content-Length`，则不会读取HTTP Body，并且err返回值为nil

type HttpReader

type HttpReader interface {
	LineReader
	io.Reader
}

e.g. bufio.Reader

type HttpReqMsgCtx

type HttpReqMsgCtx struct {
	Method  string
	Uri     string
	Version string
	Headers http.Header
	Body    []byte
}

func ReadHttpRequestMessage

func ReadHttpRequestMessage(r HttpReader) (ctx HttpReqMsgCtx, err error)

type HttpRespMsgCtx

type HttpRespMsgCtx struct {
	Version    string
	StatusCode string
	Reason     string
	Headers    http.Header
	Body       []byte
}

func ReadHttpResponseMessage

func ReadHttpResponseMessage(r HttpReader) (ctx HttpRespMsgCtx, err error)

type LineReader

type LineReader interface {
	ReadLine() (line []byte, isPrefix bool, err error)
}