我正在尝试使用 go-stom/stomp 连接到由 network rail 托管的

Question

我正在尝试连接到位于此处的 Darwin Push 端口馈送。当我尝试按照wiki的说明进行连接时，出现 2 个错误中的 1 个。

如果我遗漏订阅选项，我会收到身份验证错误，如果我包含它们，它会说我无法创建对队列的持久订阅。

如果有人能告诉我哪个错误更接近连接，那将是一个很大的帮助。

package main

import (

    "fmt"

    "github.com/Showmax/go-fqdn"

    "github.com/go-stomp/stomp"

    "github.com/go-stomp/stomp/frame"

)

var serverAddr = "darwin-dist-44ae45.nationalrail.co.uk:61613"

var messageCount = 10

var topic = "topic/darwin.pushport-v16"

var username = "####"

var password = "###"

var stop = make(chan bool)

    fqdn, err := fqdn.FqdnHostname()

    if err != nil {

        panic(err)

    }

    var connOptions []func(*stomp.Conn) error = []func(*stomp.Conn) error{

        stomp.ConnOpt.Login(username, password),

        stomp.ConnOpt.Host(serverAddr),

        stomp.ConnOpt.Header("client-id", fmt.Sprintf("%v-%v", username, fqdn)),

    }

    conn, err := stomp.Dial("tcp", serverAddr, connOptions...)

    if err != nil {

        println("cannot connect to server", err.Error())

        return

    }

    subOptions := []func(*frame.Frame) error{

        stomp.SubscribeOpt.Header("activemq.subscriptionName", fqdn),

        stomp.SubscribeOpt.Header("durable-subscription-name", fqdn),

    }

    sub, err := conn.Subscribe(topic, stomp.AckClient, subOptions...)

    if err != nil {

        println("cannot subscribe to", topic, err.Error())

        return

    }

    

    for i := 1; i <= messageCount; i++ {

        msg := <-sub.C

        fmt.PrintLn(msg)

        }

    }

    println("receiver finished")

}

我得到的是：

2020/09/04 16:55:35 received ERROR; Closing underlying connection

2020/09/04 16:55:35 Subscription 1: topic/darwin.pushport-v16: ERROR message:Invalid Subscription: cannot durably subscribe to a Queue destination!

Expected: Message #1

Actual: org.apache.activemq.transport.stomp.ProtocolException: Invalid Subscription: cannot durably subscribe to a Queue destination!

        at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSubscribe(ProtocolConverter.java:581)

        at ...

Answer 1

要采用 Tim Bish 对其逻辑结论的回答，您需要在主题描述中添加一个前导斜杠，以便它读取/topic/darwin.pushport-v16而不仅仅是topic/darwin.pushport-v16.&nbsp;然后它将被正确识别为主题（而不是默认为队列）并且应该“正常工作”。

Answer 2

队列和主题的 STOMP 客户端的ActiveMQ中的目标前缀分别是/queue/或/topic/，并且当没有前缀或在您的情况下无效时的默认值是使用队列。