我正在使用phao mqtt模塊與mqtt服務器進行通信。現在我想訂閱一個主題，為此我需要傳遞一個帶有MessageHandler類型的回調。是否可以以某種方式將附加參數傳遞給 ？MessageHandler到目前為止，我的處理程序看起來像這樣：var MyMessageHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) { fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic()) # Call here a stuct method}
2 回答
九州編程
TA貢獻1785條經驗 獲得超4個贊
您有 2 種選擇：
定義一個返回并接受結構的函數
mqtt.MessageHandler在結構上定義一個方法，并使用相同的簽名
mqtt.MessageHandler
type S struct{}
func MessageHandler(s S) mqtt.MessageHandler {
return func(client mqtt.Client, msg mqtt.Message) {
// use `s`
// ...
}
}
func (s *S) MessageHandler(client mqtt.Client, msg mqtt.Message) {
// use `s`
// ...
}
用法：
func main() {
s := S{}
mh := MessageHandler(s)
mh = s.MessageHandler // same type
// use mh
// ...
}
精慕HU
TA貢獻1845條經驗 獲得超8個贊
您需要從 func 返回處理程序，在需要調用其方法的結構對象周圍創建一個閉包。
這是一種方法。請注意，我沒有使用過lib，所以下面的主要功能可能無法編譯，但你會明白：
package main
import (
"fmt"
)
type SomeStruct struct{}
func (ss *SomeStruct) Invoke() {
fmt.Println("struct method called")
}
func GetHandler(s *SomeStruct) mqtt.MessageHandler {
return func(client mqtt.Client, msg mqtt.Message) {
fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
s.Invoke()
}
}
func main() {
handler := GetHandler(&SomeStruct{})
//pass to lib or assume it is invoked by lib
//handler(Client{}, Message{})
}
- 2 回答
- 0 關注
- 126 瀏覽
添加回答
舉報
0/150
提交
取消