0

问题描述：

我正在做一个小项目，我需要将现有的 mqtt 客户端库从 Golang 移植到 Android。我发现使用 gomobile存储库可以防止在不同的编程语言（GO 和 Java）中重复相同的功能。

要使用这个库，我们有两种不同的选择：

  1. 纯粹在 Go 中设计 android 应用程序并使用“gomobile -build”生成 APK 文件。然后可以使用 adb 工具将 APK 文件加载到 android 设备或模拟器。
  2. 实现一些功能，然后使用“gomobile -bind”将它们绑定到现有的 Android 项目中。使用此选项，转换和构建 Golang 对象有一些限制。

对于我的情况，我计划选择第二个选项。还尝试将以下小示例 GO 实现转换为 Android（从此处借用）。

package main

import (
    "fmt"
    mqtt "github.com/eclipse/paho.mqtt.golang"
    "log"
    "time"
)

var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
    fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())
}

var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {
    fmt.Println("Connected")
}

var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {
    fmt.Printf("Connect lost: %v", err)
}

func main() {
    var broker = "broker.emqx.io"
    var port = 1883
    opts := mqtt.NewClientOptions()
    opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
    opts.SetClientID("go_mqtt_client")
    opts.SetUsername("emqx")
    opts.SetPassword("public")
    opts.SetDefaultPublishHandler(messagePubHandler)
    opts.OnConnect = connectHandler
    opts.OnConnectionLost = connectLostHandler
    client := mqtt.NewClient(opts)
    if token := client.Connect(); token.Wait() && token.Error() != nil {
        panic(token.Error())
    }

    sub(client)
    publish(client)

    client.Disconnect(250)
}

func publish(client mqtt.Client) {
    num := 10
    for i := 0; i < num; i++ {
        text := fmt.Sprintf("Message %d", i)
        token := client.Publish("topic/test", 0, false, text)
        token.Wait()
        time.Sleep(time.Second)
    }
}

func sub(client mqtt.Client) {
    topic := "topic/test"
    token := client.Subscribe(topic, 1, nil)
    token.Wait()
  fmt.Printf("Subscribed to topic: %s", topic)
}

我的问题：

转换示例代码后，我不确定如何实现侦听器端。问题是“gomobile -bind”不能转换所有用户数据类型（即客户端到Java）。我可以实现连接、订阅和发布，但不能实现监听器（换句话说，当我在 Android 中调用相应方法时，“opts.SetDefaultPublishHandler(messagePubHandler)”不会重复工作）

有什么建议吗？

这是尝试过的，但它不起作用

var Options *mqtt.ClientOptions
var ReceivedMsg string

func AddBroker(broker string, port int) {
    Options = mqtt.NewClientOptions()
    Options.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))
}
var MessagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
    ReceivedMsg = " Message " + string(msg.Payload()) + " received on topic" + msg.Topic()
    fmt.Printf(ReceivedMsg)
}

 
func Listener(clientId string) {
    Options.SetClientID(clientId)
    Options.SetDefaultPublishHandler(MessagePubHandler)
    Options.OnConnect = ConnectHandler
    Options.OnConnectionLost = ConnectionLostHandler
}
4

0 回答 0