将附加参数传递给回调

Question

我正在使用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}

Answer 1

您有 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

  // ...

}

Answer 2

您需要从 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{})

}