使用 Go-Stomp 缓存 ActiveMQ 连接

Question

使用 Go-Stomp，可以使用以下代码获取连接。if conn, err = stomp.Dial("tcp",        Broker.URI,        stomp.ConnOpt.Login(Broker.User, Broker.Password)); err != nil {        panic(fmt.Sprintf("Could not connect to ActiveMQ using brokerUri %v. Can not continue.", Broker.URI))    }连接是否可以缓存以重复使用以发送不同请求的消息？还是每次要发送消息时都需要获取连接？后来听起来效率低下。连接实例上的Send方法会在出现故障时关闭连接。因此，如果我们缓存它，则必须检查连接是否仍然存在以供后续发送消息调用。但是我没有找到检查连接是否关闭的方法？Conn结构具有封闭成员，但这不会通过任何方法公开。// A Conn is a connection to a STOMP server. Create a Conn using either// the Dial or Connect function.type Conn struct {    conn         io.ReadWriteCloser    readCh       chan *frame.Frame    writeCh      chan writeRequest    version      Version    session      string    server       string    readTimeout  time.Duration    writeTimeout time.Duration    closed       bool    options      *connOptions}

Answer 1

您可以重复使用，直到发生故障的连接，见例如从细末跺脚例子。

没有办法测试是否打开。

在图书馆本身中，他们在读取时吃错误，但在发送时不会：

if err != nil {

        if err == io.EOF {

            log.Println("connection closed:", c.rw.RemoteAddr())

Answer 2

我添加了代码来处理失败并检查特定错误。

if err := conn.Send(queue, "text/plain", []byte(message)); err != nil {

            if err == stomp.ErrAlreadyClosed {

                log.Println("ActiveMQ Connection is in closed state. Reconnecting ...")

                conn = ConnectToBroker()

                err = conn.Send(queue, "text/plain", []byte(message))

            }

            if err != nil {

                log.Printf("Failed to send message to Queue %v.  Error is %v, Payload is %v", queue, err.Error(), message)

            }

            return err

        }

    }