1

我正在使用独立运行的 HornetQ(v2.2.13) 消费者来读取 JBOSS 服务器发布的持久主题（7.1.1 最终版）。一切顺利几个小时（2-6 之间），然后消费者停止接收来自主题的消息。从服务器上的日志文件中，我看到数据不断从管道中抽出，但消费者日志文件表明客户端停止读取数据。我从客户端推断出它最后一次从主题中读取消息的时间是 12:00:00，而服务器日志说它最后一次向主题推送消息的时间是 14:00:00。

我尝试过调整 HornetQ 的配置，但它似乎并没有持续持续的时间。

我用来与主题交流的代码如下。

private TransportConfiguration getTC(String hostname) {
        Map<String,Object> params = new HashMap<String, Object>();
        params.put(TransportConstants.HOST_PROP_NAME, hostname);
        params.put(TransportConstants.PORT_PROP_NAME, 5445);
        TransportConfiguration tc = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
        return tc;

    }

    private Topic createDestination(String destinationName) {
        Topic topic = new HornetQTopic(destinationName);
        return topic;

    }

    private HornetQConnectionFactory createCF(TransportConfiguration tc) {
        HornetQConnectionFactory cf = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType .CF, tc);
        return cf == null ? null : cf;

    }

创建会话并启动它的代码片段：

TransportConfiguration tc = this.getTC(this.hostname);
        HornetQConnectionFactory cf = this.createCF(tc);
        cf.setRetryInterval(4000);
        cf.setReconnectAttempts(10);
        cf.setConfirmationWindowSize(1000000);

        Destination destination = this.createDestination(this.topicName);
        logger.info("Starting Topic Connection");
        try {
            this.connection = cf.createConnection();

            connection.start();
            this.session = connection.createSession(transactional, ackMode);
            MessageConsumer consumer = session.createConsumer(destination);
            consumer.setMessageListener(this);

            logger.info("Started topic connection");
        } catch (Exception ex) {
            ex.printStackTrace();
            logger.error("EXCEPTION!");
        }
4

1 回答 1

1

您不会在服务器端获得任何有关服务器断开连接的日志。

您是否尝试过使用 client-failure-check-period 和其他 ping 参数？

虚拟机设置呢？

您如何确认消息？我看到您将其创建为事务。您确定在收到消息时提交 TX 吗？

于 2012-04-27T19:48:59.433 回答