package main import "net/http" // //InWechatMsg what we received currently from wechat type InWechatMsg struct { header CommonHeader body interface{} //dynamic type req *http.Request instantResponse chan string //instance reply channel } func (m *InWechatMsg) init() { m.instantResponse = make(chan string) } func (m *InWechatMsg) destroy() { close(m.instantResponse) } func (m *InWechatMsg) immediateResponse(s string) { m.instantResponse <- s }