如果客户确认未完成，会发生什么？

Question

我有：

• hornetq-2.2.14-final独立服务器

C1使用jmstemboard在CLIENT_ACKNOWLEDGE模式下发送消息：

<bean name="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory" />
    <property name="sessionAcknowledgeModeName" value="CLIENT_ACKNOWLEDGE" />
    <property name="sessionTransacted" value="true" />
</bean>

因此指挥与控制应手动确认消息：

@Override
@Transactional
public void onMessage(Message message) 
{
    try 
    {
        messageHandlerService.handleReceivedMessage(message);
        message.acknowledge();
    } 
    catch (DeserializeXmlException e) 
    {
        // TODO log
        e.printStackTrace();
    }   
    catch (InvalidMessageException e) 
    {
        //TODO log
        e.printStackTrace();
    }
    catch (JMSException e) 
    {
        //TODO log
        e.printStackTrace();
    }   
}

我的问题：

• 当客户端C2收到该消息但在确认之前崩溃时，消息会发生什么？
• 是否有超时机制？如果是，确认的默认超时是什么？我如何修改它？

Answer 1

任何未确认的消息将在客户关闭或回滚时发送回队列。

在服务器崩溃的情况下，如果消息是非持久性的，则会重新传递消息，就像什么都没有发生一样。

请注意，系统可能会在您调用ack时崩溃，但在ack实际到达服务器之前。

ack超时是通过更改连接工厂上的callTimeout来配置的。

注意，如果您有两个要更新的资源，并且希望保证ack和数据库插入之间的一次提交（或者接下来要做的任何事情），那么您需要执行XA事务以保证两个分支都会提交。

崩溃后消息将被重新发送。如果您需要100%保证收到，则需要XA。