Golang与IBM MQ通信时出现MQRC_CONNECTION_BROKEN错误

珍惜时间，勤奋学习！今天给大家带来《Golang与IBM MQ通信时出现MQRC_CONNECTION_BROKEN错误》，正文内容主要涉及到等等，如果你正在学习Golang，或者是对Golang有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

我现在正在使用 golang 连接 ibm websphere mq-esb，我用来与 mq-esb 通信的库是

https://github.com/ibm-messaging/mq-golang
https://github.com/ibm-messaging/mq-golang-jms20

一般情况下，它可以将消息发送到 mq-esb ，但是当发生错误时，会出现错误 mq connection broken。这导致我的应用程序无法再将消息发送到 mq-esb。重启服务是解决这个问题的方法（但不是解决问题的方法）。有人有想法吗？ 谢谢

这是创建 mq 连接的代码

func newibmmqconnection(mqconnconfig *mqjms.connectionfactoryimpl) jms20subset.jmscontext {
if !viper.getbool("mq.openconnection") {
    return &mqjms.contextimpl{}
}

logx.withfields(logrus.fields{
    "queue manager": viper.getstring("mq.qmanager"),
    "host":          viper.getstring("mq.host"),
    "port":          viper.getint("mq.port"),
    "channel":       viper.getstring("mq.qchannel"),
}).infof("[config] [mdm ibmmq]")

conn, exception := mqconnconfig.createcontext()
if exception != nil {
    if exception.getlinkederror() != nil {
        logx.fatalf("new mdm mq error: %s", exception.getlinkederror())
    }
}
return conn
}

func newibmmqconfig() *mqjms.connectionfactoryimpl {
    return &mqjms.connectionfactoryimpl{
        qmname:      viper.getstring("mq.qmanager"),
        hostname:    viper.getstring("mq.host"),
        portnumber:  viper.getint("mq.port"),
        channelname: viper.getstring("mq.qchannel"),
        username:    viper.getstring("mq.login"),
        password:    viper.getstring("mq.pass"),
    }
}

这是 main.go 中实例化连接的代码

func main() {
    db := newgormdb()
    defer closedb(db)

    mq := ibmmq.newibmmqconnection(ibmmq.newibmmqconfig())
    defer mq.close()
    ibmmq := ibmmq.new(mq)

    ...

    ... 

    go startserver()

    shutdown()
}

这是代码产生消息

func (i *IBMMQ) ProduceMSGToMQ(ctx context.Context, msg string) error {
logx.WithContext(ctx).Infof("Producing Message queueName: message: %s", msg)
err := i.producer.SendString(i.queueCDDEMoeny, msg)

if err != nil {
    logx.WithSeverityError(ctx).Errorf("Send msg to mq error: %s", err.GetErrorCode()+"-"+err.GetReason()+"-"+err.GetLinkedError().Error())
    return errors.New("Send msg to mq error: " + err.GetErrorCode() + "-" + err.GetReason() + "-" + err.GetLinkedError().Error())
}
return nil
}

解决方案

我不是 go 语言专家，只是 ibm mq 专家，但我想说的是（没有双关语！）。

我不知道你在哪里调用 producemsgtomq 函数，但我想象是这样的：-

error := ibmmq.ProduceMSGToMQ(...)
if error != nil && (error.GetReason() == "MQRC_CONNECTION_BROKEN") {
    mq := ibmmq.NewIBMMQConnection(ibmmq.NewIBMMQConfig())
}

希望能有点帮助。

今天关于《Golang与IBM MQ通信时出现MQRC_CONNECTION_BROKEN错误》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！