1

我有一个实现消息生产者的 Java 类，它将消息发送到名为 test 的队列。我有另一个类作为客户端，它从同一个队列中获取消息。我对如何知道客户端是否已收到消息感到困惑。我在某个地方读到了我应该使用的东西message.acknowledge()，但我不知道这样做的正确方法。我的代码如下所示：

制片人：

public class Producer {
    private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;

    private static String subject = "que";

    public static void main(String[] args) throws JMSException,
            InterruptedException {

        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false,
                Session.AUTO_ACKNOWLEDGE);

        Destination destination = session.createQueue(subject);

        MessageProducer producer = session.createProducer(destination);

        // 
        int i = 0;
        //while(true)
        // {
        TextMessage message = session
                .createTextMessage("this is a gfjfjf " + i);
        Thread.sleep(2000);
        // 
        producer.send(message);
        i++;
        System.out.println("Sent message '" + message.getText() + "'");
        System.out.println(ActiveMQConnection.DEFAULT_BROKER_URL);
        MessageListener ML = session.getMessageListener();
        System.out.println(ML);
        connection.close();
    }
}

消费者：

public class Consumer {

    private static String url = "failover://tcp://192.168.1.17:61616";

    private static String subject = "que";

    public static void main(String[] args) throws JMSException {
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false,
                Session.AUTO_ACKNOWLEDGE);

        Destination destination = session.createQueue(subject);

        MessageConsumer consumer = session.createConsumer(destination);

        // while(true)
        //  {
        Message message = consumer.receive();

        System.out.println(message);

        if (message instanceof TextMessage) {
            TextMessage textMessage = (TextMessage) message;
            System.out.println("Received message '" + textMessage.getText()
                    + "'");
        }
        if (session.getAcknowledgeMode() == Session.CLIENT_ACKNOWLEDGE) {
            System.out.println(session.getAcknowledgeMode());
            System.out.println(Session.CLIENT_ACKNOWLEDGE);
            message.acknowledge();
        }
        System.out.println(session.getAcknowledgeMode());
        System.out.println(Session.CLIENT_ACKNOWLEDGE);
        message.acknowledge();

    }
}

任何帮助表示赞赏。

4

1 回答 1

3

您不能使用确认来检查是否已收到消息。

实际上，一般的消息传递，特别是 JMS 的设计目的是使发送应用程序不需要知道消息是否已到达客户端。这个概念被称为保证交付。

致谢是其中的一部分。如果您读取队列的消息但未确认，JMS 代理将在稍后尝试重新传递该消息。您可以使用可以提交或回滚的事务将概念提升到另一个层次。

如果您确实需要消息的原始发件人的回执，我建议您发送消息作为回复。JMS 具有使用相关 id 和 ReplyTo 字段的 Request/Reply 示意图。您可以在 Google 上搜索很多示例，但这里是 EIP 中的一个。

于 2013-03-07T08:15:46.263 回答