broker

type Client struct {
	ClientID string

	Subscribed *topic.Tree

	Cache bytes.Buffer
	// contains filtered or unexported fields
}

type Engine struct {
	Subscribed   *topic.Tree
	Retained     *sync.Map
	Clients      *sync.Map
	Qos1Store    *multimap.MultiMap
	Qos2PubStore *multimap.MultiMap
	Qos2RelStore *multimap.MultiMap

	JwtSecretKey [][]byte
	SelfDdosDeny int
	LazyMsgSend  int
	NilConnDeny  int
	BlockTime    int
	MaxAttempts  int
	IpBlocker    *ipblocker.Blocker // 增加Blocker字段
	// contains filtered or unexported fields
}