core

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

README

微信公众号 SDK 核心 package

微信公众号的处理逻辑都在这个 package 里面, 其他的模块都是在这个 package 基础上的再封装!

回调请求处理

一个回调地址(多个公众号可以共用一个回调地址)的 http 请求对应了一个 http handler(http.Handler, gin.HandlerFunc…), 这个 http handler 里面的主要逻辑是调用对应公众号的 core.Server 的 ServeHTTP 方法来处理回调请求, core.Server.ServeHTTP 做签名的验证和消息解密, 然后调用 core.Server 的 core.Handler 属性的 ServeMsg 方法来处理消息(事件).
回调请求处理逻辑图

Documentation

Overview

微信公众平台(订阅号&服务号) SDK 的核心库

Index

Examples

Constants

View Source 
const (
	ErrCodeOK                 = 0
	ErrCodeInvalidCredential  = 40001 // access_token 过期错误码
	ErrCodeAccessTokenExpired = 42001 // access_token 过期错误码(maybe!!!)
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessTokenServer 

type AccessTokenServer interface {
	Token() (token string, err error) // 请求中控服务器返回缓存的 access_token
	Debug() bool
	SetDebug(bool)
	RefreshToken(currentToken string) (token string, err error) // 请求中控服务器刷新 access_token
	SetSecret(appId string, appSecret string)
	RefreshTokenWithExpires(currentToken string) (token string, expiresIn int64, err error) // 请求中控服务器刷新 access_token
	IID01332E16DF5011E5A9D5A4DB30FED8E1()                                                   // 接口标识, 没有实际意义
}

access_token 中控服务器接口.

type AddExpressPathAction added in v1.1.10 

type AddExpressPathAction struct {
	// ActionTime 轨迹节点 Unix 时间戳
	ActionTime int64 `xml:"ActionTime" json:"ActionTime"`
	// ActionType 轨迹节点类型
	ActionType int `xml:"ActionType" json:"ActionType"`
	// ActionMsg 轨迹节点详情
	ActionMsg string `xml:"ActionMsg" json:"ActionMsg"`
}

AddExpressPathAction 轨迹列表

type ArticleUrlResult 

type ArticleUrlResult struct {
	Count      int `xml:"Count" json:"Count"`
	ResultList []struct {
		ArticleIdx uint   `xml:"ArticleIdx" json:"ArticleIdx"`
		ArticleUrl string `xml:"ArticleUrl" json:"ArticleUrl"`
	} `xml:"ResultList>item,omitempty" json:"ResultList>item,omitempty"`
}

type Client 

type Client struct {
	AccessTokenServer
	HttpClient *http.Client
}

func NewClient 

func NewClient(srv AccessTokenServer, clt *http.Client) *Client

NewClient 创建一个新的 Client. 

如果 clt == nil 则默认用 util.DefaultHttpClient

func NewClientWithToken 

func NewClientWithToken(token string, clt *http.Client) *Client

func (*Client) GetJSON 

func (clt *Client) GetJSON(incompleteURL string, response interface{}) (err error)

GetJSON HTTP GET 微信资源, 然后将微信服务器返回的 JSON 用 encoding/json 解析到 response. 

NOTE:
1. 一般不需要调用这个方法, 请直接调用高层次的封装函数;
2. 最终的 URL == incompleteURL + access_token;
3. response 格式有要求, 要么是 *Error, 要么是下面结构体的指针(注意 Error 必须是第一个 Field):
    struct {
        Error
        ...
    }

func (*Client) PostJSON 

func (clt *Client) PostJSON(incompleteURL string, request interface{}, response interface{}) (err error)

PostJSON 用 encoding/json 把 request marshal 为 JSON, HTTP POST 到微信服务器, 然后将微信服务器返回的 JSON 用 encoding/json 解析到 response. 

NOTE:
1. 一般不需要调用这个方法, 请直接调用高层次的封装函数;
2. 最终的 URL == incompleteURL + access_token;
3. response 格式有要求, 要么是 *Error, 要么是下面结构体的指针(注意 Error 必须是第一个 Field):
    struct {
        Error
        ...
    }

func (*Client) PostMultipartForm 

func (clt *Client) PostMultipartForm(incompleteURL string, fields []MultipartFormField, response interface{}) (err error)

PostMultipartForm 通用上传接口. 

--BOUNDARY
Content-Disposition: form-data; name="FIELDNAME"; filename="FILENAME"
Content-Type: application/octet-stream

FILE-CONTENT
--BOUNDARY
Content-Disposition: form-data; name="FIELDNAME"

JSON-DESCRIPTION
--BOUNDARY--

NOTE:
1. 一般不需要调用这个方法, 请直接调用高层次的封装函数;
2. 最终的 URL == incompleteURL + access_token;
3. response 格式有要求, 要么是 *Error, 要么是下面结构体的指针(注意 Error 必须是第一个 Field):
    struct {
        Error
        ...
    }

type Context 

type Context struct {
	ResponseWriter http.ResponseWriter
	Request        *http.Request

	QueryParams  url.Values // 回调请求 URL 的查询参数集合
	EncryptType  string     // 回调请求 URL 的加密方式参数: encrypt_type
	MsgSignature string     // 回调请求 URL 的消息体签名参数: msg_signature
	Signature    string     // 回调请求 URL 的签名参数: signature
	Timestamp    int64      // 回调请求 URL 的时间戳参数: timestamp
	Nonce        string     // 回调请求 URL 的随机数参数: nonce

	MsgCiphertext []byte    // 消息的密文文本
	MsgPlaintext  []byte    // 消息的明文文本, xml格式
	MixedMsg      *MixedMsg // 消息

	Token  string // 当前消息所属公众号的 Token
	AESKey []byte // 当前消息加密所用的 aes-key, read-only!!!
	Random []byte // 当前消息加密所用的 random, 16-bytes
	AppId  string // 当前消息加密所用的 AppId
	// contains filtered or unexported fields
}

Context 是 Handler 处理消息(事件)的上下文环境. 非并发安全!

func (*Context) AESResponse 

func (ctx *Context) AESResponse(msg interface{}, timestamp int64, nonce string, random []byte) (err error)

AESResponse 回复aes加密的消息给微信服务器. 

msg:       经过 encoding/xml.Marshal 得到的结果符合微信消息格式的任何数据结构
timestamp: 时间戳, 如果为 0 则默认使用 Context.Timestamp
nonce:     随机数, 如果为 "" 则默认使用 Context.Nonce
random:    16字节的随机字符串, 如果为 nil 则默认使用 Context.Random

func (*Context) Abort 

func (ctx *Context) Abort()

Abort 阻止系统调用当前 handler 后续的 handlers, 即当前的 handler 处理完毕就返回, 一般在 middleware 中调用.

func (*Context) Get 

func (ctx *Context) Get(key string) (value interface{}, exists bool)

Get 返回 Context 中 key 对应的 value, 如果 key 存在的返回 (value, true), 否则返回 (nil, false).

func (*Context) IsAborted 

func (ctx *Context) IsAborted() bool

IsAborted 返回 true 如果 Context.Abort() 被调用了, 否则返回 false.

func (*Context) MustGet 

func (ctx *Context) MustGet(key string) interface{}

MustGet 返回 Context 中 key 对应的 value, 如果 key 不存在则会 panic.

func (*Context) Next 

func (ctx *Context) Next()

Next 中断当前 handler 程序逻辑执行其后续的 handlers, 一般在 middleware 中调用.

func (*Context) NoneResponse 

func (ctx *Context) NoneResponse() (err error)

NoneResponse 表示没有消息回复给微信服务器.

func (*Context) RawResponse 

func (ctx *Context) RawResponse(msg interface{}) (err error)

RawResponse 回复明文消息给微信服务器. 

msg: 经过 encoding/xml.Marshal 得到的结果符合微信消息格式的任何数据结构

func (*Context) Set 

func (ctx *Context) Set(key string, value interface{})

Set 存储 key-value pair 到 Context 中.

func (*Context) SetHandlers 

func (ctx *Context) SetHandlers(handlers HandlerChain)

SetHandlers 设置 handlers 给 Context.Next() 调用, 务必在 Context.Next() 调用之前设置, 否则会 panic. 

NOTE: 此方法一般用不到, 除非你自己实现一个 Handler 给 Server 使用, 参考 ServeMux.

type DefaultAccessTokenServer 

type DefaultAccessTokenServer struct {
	// contains filtered or unexported fields
}

DefaultAccessTokenServer 实现了 AccessTokenServer 接口. 

NOTE:
1. 用于单进程环境.
2. 因为 DefaultAccessTokenServer 同时也是一个简单的中控服务器, 而不是仅仅实现 AccessTokenServer 接口,
   所以整个系统只能存在一个 DefaultAccessTokenServer 实例!

func NewDefaultAccessTokenServer 

func NewDefaultAccessTokenServer(appId, appSecret string, httpClient *http.Client) (srv *DefaultAccessTokenServer)

NewDefaultAccessTokenServer 创建一个新的 DefaultAccessTokenServer, 如果 httpClient == nil 则默认使用 util.DefaultHttpClient.

func (*DefaultAccessTokenServer) Debug 

func (srv *DefaultAccessTokenServer) Debug() bool

func (*DefaultAccessTokenServer) IID01332E16DF5011E5A9D5A4DB30FED8E1 

func (srv *DefaultAccessTokenServer) IID01332E16DF5011E5A9D5A4DB30FED8E1()

func (*DefaultAccessTokenServer) RefreshToken 

func (srv *DefaultAccessTokenServer) RefreshToken(currentToken string) (token string, err error)

func (*DefaultAccessTokenServer) RefreshTokenWithExpires 

func (srv *DefaultAccessTokenServer) RefreshTokenWithExpires(currentToken string) (token string, expiresIn int64, err error)

func (*DefaultAccessTokenServer) SetDebug 

func (srv *DefaultAccessTokenServer) SetDebug(debug bool)

func (*DefaultAccessTokenServer) SetSecret 

func (srv *DefaultAccessTokenServer) SetSecret(appId string, appSecret string)

func (*DefaultAccessTokenServer) Token 

func (srv *DefaultAccessTokenServer) Token() (token string, err error)

type Error 

type Error struct {
	ErrCode int64  `json:"errcode"`
	ErrMsg  string `json:"errmsg"`
}

func (*Error) Error 

func (err *Error) Error() string

type ErrorHandler 

type ErrorHandler interface {
	ServeError(http.ResponseWriter, *http.Request, error)
}
var DefaultErrorHandler ErrorHandler = ErrorHandlerFunc(defaultErrorHandlerFunc)

type ErrorHandlerFunc 

type ErrorHandlerFunc func(http.ResponseWriter, *http.Request, error)

func (ErrorHandlerFunc) ServeError 

func (fn ErrorHandlerFunc) ServeError(w http.ResponseWriter, r *http.Request, err error)

type EventType 

type EventType string

type Handler 

type Handler interface {
	ServeMsg(*Context)
}

type HandlerChain 

type HandlerChain []Handler

type HandlerFunc 

type HandlerFunc func(*Context)

func (HandlerFunc) ServeMsg 

func (fn HandlerFunc) ServeMsg(ctx *Context)

type MixedMsg 

type MixedMsg struct {
	XMLName struct{} `xml:"xml" json:"-"`
	MsgHeader
	EventType EventType `xml:"Event,omitempty" json:"Event,omitempty"`

	MsgId        int64   `xml:"MsgId,omitempty"        json:"MsgId,omitempty"`        // request
	Content      string  `xml:"Content,omitempty"      json:"Content,omitempty"`      // request
	MediaId      string  `xml:"MediaId,omitempty"      json:"MediaId,omitempty"`      // request
	PicURL       string  `xml:"PicUrl,omitempty"       json:"PicUrl,omitempty"`       // request
	Format       string  `xml:"Format,omitempty"       json:"Format,omitempty"`       // request
	Recognition  string  `xml:"Recognition,omitempty"  json:"Recognition,omitempty"`  // request
	ThumbMediaId string  `xml:"ThumbMediaId,omitempty" json:"ThumbMediaId,omitempty"` // request
	LocationX    float64 `xml:"Location_X,omitempty"   json:"Location_X,omitempty"`   // request
	LocationY    float64 `xml:"Location_Y,omitempty"   json:"Location_Y,omitempty"`   // request
	Scale        int     `xml:"Scale,omitempty"        json:"Scale,omitempty"`        // request
	Label        string  `xml:"Label,omitempty"        json:"Label,omitempty"`        // request
	Title        string  `xml:"Title,omitempty"        json:"Title,omitempty"`        // request
	Description  string  `xml:"Description,omitempty"  json:"Description,omitempty"`  // request
	URL          string  `xml:"Url,omitempty"          json:"Url,omitempty"`          // request
	EventKey     string  `xml:"EventKey,omitempty"     json:"EventKey,omitempty"`     // request, menu
	Ticket       string  `xml:"Ticket"       json:"Ticket"`                           // request
	Latitude     float64 `xml:"Latitude"     json:"Latitude"`                         // request
	Longitude    float64 `xml:"Longitude"    json:"Longitude"`                        // request
	Precision    float64 `xml:"Precision"    json:"Precision"`                        // request

	ComponentVerifyTicket        string `xml:"ComponentVerifyTicket,omitempty"      json:"ComponentVerifyTicket,omitempty"`
	AuthorizerAppid              string `xml:"AuthorizerAppid,omitempty" json:"AuthorizerAppid,omitempty"`                           // 公众号或小程序
	AuthorizationCode            string `xml:"AuthorizationCode,omitempty" json:"AuthorizationCode,omitempty"`                       // 授权码，可用于换取公众号的接口调用凭据
	AuthorizationCodeExpiredTime string `xml:"AuthorizationCodeExpiredTime,omitempty" json:"AuthorizationCodeExpiredTime,omitempty"` // 授权码过期时间
	PreAuthCode                  string `xml:"PreAuthCode,omitempty" json:"PreAuthCode,omitempty"`                                   // 预授权码

	// menu
	MenuId       int64 `xml:"MenuId,omitempty" json:"MenuId,omitempty"`
	ScanCodeInfo *struct {
		ScanType   string `xml:"ScanType"   json:"ScanType"`
		ScanResult string `xml:"ScanResult" json:"ScanResult"`
	} `xml:"ScanCodeInfo,omitempty" json:"ScanCodeInfo,omitempty"`
	SendPicsInfo *struct {
		Count   int `xml:"Count" json:"Count"`
		PicList []struct {
			PicMd5Sum string `xml:"PicMd5Sum" json:"PicMd5Sum"`
		} `xml:"PicList>item,omitempty" json:"PicList,omitempty"`
	} `xml:"SendPicsInfo,omitempty" json:"SendPicsInfo,omitempty"`
	SendLocationInfo *struct {
		LocationX float64 `xml:"Location_X" json:"Location_X"`
		LocationY float64 `xml:"Location_Y" json:"Location_Y"`
		Scale     int     `xml:"Scale"      json:"Scale"`
		Label     string  `xml:"Label"      json:"Label"`
		PoiName   string  `xml:"Poiname"    json:"Poiname"`
	} `xml:"SendLocationInfo,omitempty" json:"SendLocationInfo,omitempty"`

	MsgID       int64  `xml:"MsgID,omitempty"  json:"MsgID,omitempty"`            // template, mass
	Status      string `xml:"Status,omitempty" json:"Status,omitempty"`           // template, mass
	TotalCount  int    `xml:"TotalCount,omitempty"  json:"TotalCount,omitempty"`  // template, mass
	FilterCount int    `xml:"FilterCount,omitempty" json:"FilterCount,omitempty"` // template, mass
	SentCount   int    `xml:"SentCount,omitempty"   json:"SentCount,omitempty"`   // template, mass
	ErrorCount  int    `xml:"ErrorCount,omitempty"  json:"ErrorCount,omitempty"`  // template, mass

	ExpiredTime int64  `xml:"ExpiredTime,omitempty" json:"ExpiredTime,omitempty"`
	FailTime    int64  `xml:"FailTime,omitempty"    json:"FailTime,omitempty"`
	FailReason  string `xml:"FailReason,omitempty"  json:"FailReason,omitempty"`

	KfAccount     string `xml:"KfAccount,omitempty"     json:"KfAccount,omitempty"`
	FromKfAccount string `xml:"FromKfAccount,omitempty" json:"FromKfAccount,omitempty"`
	ToKfAccount   string `xml:"ToKfAccount,omitempty"   json:"ToKfAccount,omitempty"`

	// poi
	UniqId string `xml:"UniqId,omitempty" json:"UniqId,omitempty"`
	PoiId  int64  `xml:"PoiId,omitempty"  json:"PoiId,omitempty"`
	Result string `xml:"Result,omitempty" json:"Result,omitempty"`
	Msg    string `xml:"Msg,omitempty"    json:"Msg,omitempty"`

	// card
	CardId              string `xml:"CardId,omitempty"              json:"CardId,omitempty"`
	RefuseReason        string `xml:"RefuseReason,omitempty"        json:"RefuseReason,omitempty"`
	IsGiveByFriend      int    `xml:"IsGiveByFriend,omitempty"      json:"IsGiveByFriend,omitempty"`
	FriendUserName      string `xml:"FriendUserName,omitempty"      json:"FriendUserName,omitempty"`
	UserCardCode        string `xml:"UserCardCode,omitempty"        json:"UserCardCode,omitempty"`
	OldUserCardCode     string `xml:"OldUserCardCode,omitempty"     json:"OldUserCardCode,omitempty"`
	ConsumeSource       string `xml:"ConsumeSource,omitempty"       json:"ConsumeSource,omitempty"`
	OuterId             int64  `xml:"OuterId,omitempty"             json:"OuterId,omitempty"`
	LocationName        string `xml:"LocationName,omitempty"        json:"LocationName,omitempty"`
	StaffOpenId         string `xml:"StaffOpenId,omitempty"         json:"StaffOpenId,omitempty"`
	VerifyCode          string `xml:"VerifyCode,omitempty"          json:"VerifyCode,omitempty"`
	RemarkAmount        string `xml:"RemarkAmount,omitempty"        json:"RemarkAmount,omitempty"`
	OuterStr            string `xml:"OuterStr,omitempty"            json:"OuterStr,omitempty"`
	Detail              string `xml:"Detail,omitempty"              json:"Detail,omitempty"`
	IsReturnBack        int    `xml:"IsReturnBack,omitempty"        json:"IsReturnBack,omitempty"`
	IsChatRoom          int    `xml:"IsChatRoom,omitempty"          json:"IsChatRoom,omitempty"`
	IsRestoreMemberCard int    `xml:"IsRestoreMemberCard" json:"IsRestoreMemberCard,omitempty"`
	IsRecommendByFriend int    `xml:"IsRecommendByFriend,omitempty" json:"IsRecommendByFriend,omitempty"`
	PageId              string `xml:"PageId,omitempty"              json:"PageId,omitempty"`
	OrderId             string `xml:"OrderId,omitempty"             json:"OrderId,omitempty"`

	// bizwifi
	ConnectTime int64  `xml:"ConnectTime,omitempty" json:"ConnectTime,omitempty"`
	ExpireTime  int64  `xml:"ExpireTime,omitempty"  json:"ExpireTime,omitempty"`
	VendorId    string `xml:"VendorId,omitempty"    json:"VendorId,omitempty"`
	PlaceId     int64  `xml:"PlaceId,omitempty"     json:"PlaceId,omitempty"`
	DeviceNo    string `xml:"DeviceNo,omitempty"    json:"DeviceNo,omitempty"`

	// file
	FileKey      string `xml:"FileKey,omitempty"      json:"FileKey,omitempty"`
	FileMd5      string `xml:"FileMd5,omitempty"      json:"FileMd5,omitempty"`
	FileTotalLen string `xml:"FileTotalLen,omitempty" json:"FileTotalLen,omitempty"`

	// shakearound
	ChosenBeacon *struct {
		UUID     string  `xml:"Uuid"     json:"Uuid"`
		Major    int     `xml:"Major"    json:"Major"`
		Minor    int     `xml:"Minor"    json:"Minor"`
		Distance float64 `xml:"Distance" json:"Distance"`
	} `xml:"ChosenBeacon,omitempty" json:"ChosenBeacon,omitempty"`
	AroundBeacons []struct {
		UUID     string  `xml:"Uuid"     json:"Uuid"`
		Major    int     `xml:"Major"    json:"Major"`
		Minor    int     `xml:"Minor"    json:"Minor"`
		Distance float64 `xml:"Distance" json:"Distance"`
	} `xml:"AroundBeacons>AroundBeacon,omitempty" json:"AroundBeacons,omitempty"`
	ArticleUrlResult *ArticleUrlResult `xml:"ArticleUrlResult,omitempty" json:"ArticleUrlResult,omitempty"`

	// add express path
	DeliveryID string                 `xml:"DeliveryID,omitempty" json:"DeliveryID,omitempty"` // 快递公司ID
	WaybillID  string                 `xml:"WayBillId,omitempty" json:"WayBillId,omitempty"`   // 运单ID
	Version    int                    `xml:"Version,omitempty" json:"Version,omitempty"`       // 轨迹版本号（整型）
	Count      int                    `xml:"Count,omitempty" json:"Count,omitempty"`           // 轨迹节点数（整型）
	Actions    []AddExpressPathAction `xml:"Actions,omitempty" json:"Actions,omitempty"`       // 轨迹列表

	// 小程序订阅消息
	SubscribeMsgPopupEvent *SubscribeMsgPopupEvent `xml:"SubscribeMsgPopupEvent,omitempty" json:"SubscribeMsgPopupEvent,omitempty"`
}

微信服务器推送过来的消息(事件)的合集.

type MsgHeader 

type MsgHeader struct {
	AppId        string  `xml:"AppId,omitempty" json:"AppId,omitempty"`
	InfoType     string  `xml:"InfoType,omitempty" json:"InfoType,omitempty"`
	ToUserName   string  `xml:"ToUserName"   json:"ToUserName"`
	FromUserName string  `xml:"FromUserName" json:"FromUserName"`
	CreateTime   int64   `xml:"CreateTime"   json:"CreateTime"`
	MsgType      MsgType `xml:"MsgType"      json:"MsgType"`
}

微信服务器推送过来的消息(事件)的通用消息头.

type MsgType 

type MsgType string

type MultipartFormField 

type MultipartFormField struct {
	IsFile   bool
	Name     string
	FileName string
	Value    io.Reader
}

type ServeMux 

type ServeMux struct {
	// contains filtered or unexported fields
}

ServeMux 是一个消息(事件)路由器, 同时也是一个 Handler 的实现. 

NOTE: ServeMux 非并发安全, 如果需要并发安全的 Handler, 可以参考 ServeMux 实现一个.

func NewServeMux 

func NewServeMux() *ServeMux

func (*ServeMux) DefaultEventHandle 

func (mux *ServeMux) DefaultEventHandle(handlers ...Handler)

DefaultEventHandle 设置 handlers 以处理没有匹配到具体类型的 HandlerChain 的事件.

func (*ServeMux) DefaultEventHandleFunc 

func (mux *ServeMux) DefaultEventHandleFunc(handlers ...func(*Context))

DefaultEventHandleFunc 设置 handlers 以处理没有匹配到具体类型的 HandlerChain 的事件.

func (*ServeMux) DefaultMsgHandle 

func (mux *ServeMux) DefaultMsgHandle(handlers ...Handler)

DefaultMsgHandle 设置 handlers 以处理没有匹配到具体类型的 HandlerChain 的消息.

func (*ServeMux) DefaultMsgHandleFunc 

func (mux *ServeMux) DefaultMsgHandleFunc(handlers ...func(*Context))

DefaultMsgHandleFunc 设置 handlers 以处理没有匹配到具体类型的 HandlerChain 的消息.

func (*ServeMux) EventHandle 

func (mux *ServeMux) EventHandle(eventType EventType, handlers ...Handler)

EventHandle 设置 handlers 以处理特定类型的事件.

func (*ServeMux) EventHandleFunc 

func (mux *ServeMux) EventHandleFunc(eventType EventType, handlers ...func(*Context))

EventHandleFunc 设置 handlers 以处理特定类型的事件.

func (*ServeMux) MsgHandle 

func (mux *ServeMux) MsgHandle(msgType MsgType, handlers ...Handler)

MsgHandle 设置 handlers 以处理特定类型的消息.

func (*ServeMux) MsgHandleFunc 

func (mux *ServeMux) MsgHandleFunc(msgType MsgType, handlers ...func(*Context))

MsgHandleFunc 设置 handlers 以处理特定类型的消息.

func (*ServeMux) ServeMsg 

func (mux *ServeMux) ServeMsg(ctx *Context)

ServeMsg 实现 Handler 接口.

func (*ServeMux) Use 

func (mux *ServeMux) Use(middlewares ...Handler)

Use 注册(新增) middlewares 使其在所有消息(事件)的 Handler 之前处理该处理消息(事件).

func (*ServeMux) UseForEvent 

func (mux *ServeMux) UseForEvent(middlewares ...Handler)

UseForEvent 注册(新增) middlewares 使其在所有事件的 Handler 之前处理该处理事件.

func (*ServeMux) UseForMsg 

func (mux *ServeMux) UseForMsg(middlewares ...Handler)

UseForMsg 注册(新增) middlewares 使其在所有消息的 Handler 之前处理该处理消息.

func (*ServeMux) UseFunc 

func (mux *ServeMux) UseFunc(middlewares ...func(*Context))

UseFunc 注册(新增) middlewares 使其在所有消息(事件)的 Handler 之前处理该处理消息(事件).

func (*ServeMux) UseFuncForEvent 

func (mux *ServeMux) UseFuncForEvent(middlewares ...func(*Context))

UseFuncForEvent 注册(新增) middlewares 使其在所有事件的 Handler 之前处理该处理事件.

func (*ServeMux) UseFuncForMsg 

func (mux *ServeMux) UseFuncForMsg(middlewares ...func(*Context))

UseFuncForMsg 注册(新增) middlewares 使其在所有消息的 Handler 之前处理该处理消息.

type Server 

type Server struct {
	// contains filtered or unexported fields
}

Server 用于处理微信服务器的回调请求, 并发安全! 

通常情况下一个 Server 实例用于处理一个公众号的消息(事件), 此时建议指定 oriId(原始ID) 和 appId(明文模式下无需指定) 用于约束消息(事件);
特殊情况下也可以一个 Server 实例用于处理多个公众号的消息(事件), 此时要求这些公众号的 token 是一样的, 并且 oriId 和 appId 必须设置为 "".

func NewServer 

func NewServer(oriId, appId, token, base64AESKey string, handler Handler, errorHandler ErrorHandler) (srv *Server)

NewServer 创建一个新的 Server. 

oriId:        可选; 公众号的原始ID(微信公众号管理后台查看), 如果设置了值则该Server只能处理 ToUserName 为该值的公众号的消息(事件);
appId:        可选; 公众号的AppId, 如果设置了值则安全模式时该Server只能处理 AppId 为该值的公众号的消息(事件);
token:        必须; 公众号用于验证签名的token;
base64AESKey: 可选; aes加密解密key, 43字节长(base64编码, 去掉了尾部的'='), 安全模式必须设置;
handler:      必须; 处理微信服务器推送过来的消息(事件)的Handler;
errorHandler: 可选; 用于处理Server在处理消息(事件)过程中产生的错误, 如果没有设置则默认使用 DefaultErrorHandler.

func (*Server) AppId 

func (srv *Server) AppId() string

func (*Server) OriId 

func (srv *Server) OriId() string

func (*Server) ServeHTTP 

func (srv *Server) ServeHTTP(w http.ResponseWriter, r *http.Request, query url.Values)

ServeHTTP 处理微信服务器的回调请求, query 参数可以为 nil.

Example 
package main

import (
	"net/http"

	"github.com/bububa/wechat/mp/core"
)

func main() {
	mux := core.NewServeMux() // 创建 core.Handler, 也可以用自己实现的 core.Handler

	// 注册消息(事件)处理 Handler, 都不是必须的!
	{
		mux.UseFunc(func(ctx *core.Context) { // 注册中间件, 处理所有的消息(事件)
			// TODO: 中间件处理逻辑
		})
		mux.UseFuncForMsg(func(ctx *core.Context) { // 注册中间件, 处理所有的消息
			// TODO: 中间件处理逻辑
		})
		mux.UseFuncForEvent(func(ctx *core.Context) { // 注册中间件, 处理所有的事件
			// TODO: 中间件处理逻辑
		})

		mux.DefaultMsgHandleFunc(func(ctx *core.Context) { // 设置默认消息处理 Handler
			// TODO: 消息处理逻辑
		})
		mux.DefaultEventHandleFunc(func(ctx *core.Context) { // 设置默认事件处理 Handler
			// TODO: 事件处理逻辑
		})

		mux.MsgHandleFunc("{MsgType}", func(ctx *core.Context) { // 设置具体类型的消息处理 Handler
			// TODO: 消息处理逻辑
		})
		mux.EventHandleFunc("{EventType}", func(ctx *core.Context) { // 设置具体类型的事件处理 Handler
			// TODO: 事件处理逻辑
		})
	}

	// 创建 Server, 设置正确的参数.
	// 通常一个 Server 对应一个公众号, 当然一个 Server 也可以对应多个公众号, 这个时候 oriId 和 appId 都应该设置为空值!
	srv := core.NewServer("{oriId}", "{appId}", "{token}", "{base64AESKey}", mux, nil)

	// 在回调 URL 的 Handler 里处理消息(事件)
	http.HandleFunc("/wechat_callback", func(w http.ResponseWriter, r *http.Request) {
		srv.ServeHTTP(w, r, nil)
	})
}

Output:

func (*Server) SetAESKey 

func (srv *Server) SetAESKey(base64AESKey string) (err error)

SetAESKey 设置aes加密解密key. 

base64AESKey: aes加密解密key, 43字节长(base64编码, 去掉了尾部的'=').

func (*Server) SetToken 

func (srv *Server) SetToken(token string) (err error)

SetToken 设置签名token.

type SimpleAccessTokenServer 

type SimpleAccessTokenServer struct {
	// contains filtered or unexported fields
}

func NewSimpleAccessTokenServer 

func NewSimpleAccessTokenServer(token string, httpClient *http.Client) (srv *SimpleAccessTokenServer)

func (*SimpleAccessTokenServer) Debug 

func (srv *SimpleAccessTokenServer) Debug() bool

func (*SimpleAccessTokenServer) IID01332E16DF5011E5A9D5A4DB30FED8E1 

func (srv *SimpleAccessTokenServer) IID01332E16DF5011E5A9D5A4DB30FED8E1()

func (*SimpleAccessTokenServer) RefreshToken 

func (srv *SimpleAccessTokenServer) RefreshToken(currentToken string) (token string, err error)

func (*SimpleAccessTokenServer) RefreshTokenWithExpires 

func (srv *SimpleAccessTokenServer) RefreshTokenWithExpires(currentToken string) (token string, expiresIn int64, err error)

func (*SimpleAccessTokenServer) SetDebug 

func (srv *SimpleAccessTokenServer) SetDebug(debug bool)

func (*SimpleAccessTokenServer) SetSecret 

func (srv *SimpleAccessTokenServer) SetSecret(appId string, appSecret string)

func (*SimpleAccessTokenServer) Token 

func (srv *SimpleAccessTokenServer) Token() (token string, err error)

type SubscribeMsgPopupEvent added in v1.1.10 

type SubscribeMsgPopupEvent struct {
	List []SubscribeMsgPopupEventItem `xml:"List" json:"List"`
}

小程序订阅消息事件

type SubscribeMsgPopupEventItem added in v1.1.10 

type SubscribeMsgPopupEventItem struct {
	TemplateID            string `xml:"TemplateId" json:"TemplateId"`
	SubscribeStatusString string `xml:"SubscribeStatusString" json:"SubscribeStatusString"`
	PopupScene            string `xml:"PopupScene" json:"PopupScene"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.