如何使用 amqp 保持 azure 事件中心连接以接收批处理诊断答案

【问题标题】：how to keep azure event hub connection alive for receiving batch diagnostic using amqp如何使用 amqp 保持 azure 事件中心连接以接收批处理诊断
【发布时间】：2019-04-26 19:43:30
【问题描述】：

我们在批处理帐户上启用了诊断功能，以将事件流式传输到我们在应用程序中捕获的事件中心，以便根据批处理任务状态采取行动。然而，我们注意到连接会自动关闭（可能是因为整晚没有发生任何事件），因此我们必须每隔一段时间将服务器弹回以再次接收事件/消息。

我们仍然依赖 java 7，以下是我们为批处理添加的依赖项：

       //azure dependency
        compile('com.microsoft.azure:azure-storage:7.0.0')
        compile('com.microsoft.azure:azure-batch:5.0.1') {
            //do not get transitive dependency com.nimbusds:nimbus-jose-jw because spring security still rely on old version of it
            excludes group: 'com.nimbusds', module: 'nimbus-jose-jw'
        }
        compile('com.fasterxml.jackson.core:jackson-core:2.9.8')
        compile('org.apache.qpid:qpid-amqp-1-0-common:0.32')
        compile('org.apache.qpid:qpid-amqp-1-0-client:0.32')
        compile('org.apache.qpid:qpid-amqp-1-0-client-jms:0.32')
        compile('org.apache.qpid:qpid-jms-client:0.40.0')
        compile('org.apache.geronimo.specs:geronimo-jms_1.1_spec:1.1.1')
        //end of azure dependency

这是用于连接的代码片段，实际上我们使用了此处给出的代码示例：http://theitjourney.blogspot.com/2015/12/sendreceive-messages-using-amqp-in-java.html，因为我们在 azure doc 本身中找不到任何适用于 java 7 的示例。

     /**
     * Set up connection to the service bus using AMQP mechanism.
     * NOTE: Messages received from the message bus are not guaranteed to follow order.
     * */
    MessageConsumer initiateConsumer(MessageListener messageListener, Integer partitionInx, BatchEventHubConfig batchEventHubConfig) {
        // set up JNDI context
        String queueName = "EventHub"
        String connectionFactoryName = "SBCFR"

        Hashtable<String, String> hashtable = new Hashtable<>()
        hashtable.put("connectionfactory.${connectionFactoryName}", batchEventHubConfig.getAMQPConnectionURI())
        hashtable.put("queue.${queueName}", "${batchEventHubConfig.name}/ConsumerGroups/${batchEventHubConfig.consumerGroup}/Partitions/${partitionInx}")
        hashtable.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory")
        Context context = new InitialContext(hashtable)

        ConnectionFactory factory = (ConnectionFactory) context.lookup(connectionFactoryName)
        Destination queue = (Destination) context.lookup(queueName)
        Connection connection = factory.createConnection(batchEventHubConfig.sasPolicyName, batchEventHubConfig.sasPolicyKey)
        connection.setExceptionListener(new BatchExceptionListener())

        connection.start()
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
        MessageConsumer messageConsumer = session.createConsumer(queue)
        messageConsumer.setMessageListener(messageListener)
        messageConsumer
    }

那么有没有办法跟踪连接是否关闭，如果关闭则重新启动连接？
任何进一步诊断此问题的信息也将不胜感激。

【问题讨论】：

标签： azure azure-eventhub azure-batch

【解决方案1】：

我想我找到了问题，我曾使用“SBCFR”作为 connectionFactoryName，仔细查看链接中的示例，我应该使用“SBCF”。我还将库“org.apache.qpid:qpid-jms-client”从版本“0.40.0”更新为“0.41.0”

同样在上面的代码中，我不应该使用 AUTO_ACKNOWLEGDE，因为在很长一段时间内我都认为有问题，因为我从未在本地设置中接收到事件。结果发现其他机器也连接到同一个消费者组并且已经确认了消息。

【讨论】：