rabbitmq生产者的消息确认

【RabbitMQ】6、rabbitmq生产者的消息确认,rabbitmq生产者

通过Publisher Confirms and
Returns机制,生产者可以判断消息是否发送到了exchange及queue,而通过消费者确认机制,Rabbitmq可以决定是否重发消息给消费者,以保证消息被处理。

通过Publisher Confirms and
Returns机制,生产者可以判断消息是否发送到了exchange及queue,而通过消费者确认机制,Rabbitmq可以决定是否重发消息给消费者,以保证消息被处理。

1.什么是Publisher Confirms and Returns?

Delivery processing acknowledgements from consumers to RabbitMQ are
known as acknowledgements in AMQP 0-9-1 parlance; broker
acknowledgements to publishers are a protocol extension called publisher
confirms. 
地址:

根据RabbitMq官网定义,rabbitmq代理(broker)对发布者(publishers)的确认被称作发布者确认(publisher
confirms),这种机制是Rabbitmq对标准Amqp协议的扩展。因此通过这种机制可以确认消息是否发送给了目标。

1.什么是Publisher Confirms and Returns?

Delivery processing acknowledgements from consumers to RabbitMQ are
known as acknowledgements in AMQP 0-9-1 parlance; broker
acknowledgements to publishers are a protocol extension called publisher
confirms. 
地址:

根据RabbitMq官网定义,rabbitmq代理(broker)对发布者(publishers)的确认被称作发布者确认(publisher
confirms),这种机制是Rabbitmq对标准Amqp协议的扩展。因此通过这种机制可以确认消息是否发送给了目标。

2.如何通过Spring amqp来使用Publisher Confirms and Returns机制?

Confirmed and returned messages are supported by setting the
CachingConnectionFactory’s publisherConfirms and publisherReturns
properties to ‘true’ respectively.When these options are set, Channel s
created by the factory are wrapped in an PublisherCallbackChannel, which
is used to facilitate the callbacks. When such a channel is obtained,
the client can register a PublisherCallbackChannel.Listener with the
Channel. The PublisherCallbackChannel implementation contains logic to
route a confirm/return to the appropriate listener. These features are
explained further in the following sections. 

通过Spring
amqp文档可以看到,要使用这种机制需要将Template模版的设publisherConfirms
或publisherReturns
属性设置为true,此外ConnectionFactory要配置为CachingConnectionFactory。

    <bean id="connectionFactory"
        class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
        <property name="host" value="192.168.2.133" />
        <property name="port" value="5672" />
        <property name="username" value="sun" />
        <property name="password" value="123456" />
        <property name="publisherConfirms" value="true" />
        <property name="publisherReturns" value="true" />
    </bean>

2.如何通过Spring amqp来使用Publisher Confirms and Returns机制?

Confirmed and returned messages are supported by setting the
CachingConnectionFactory’s publisherConfirms and publisherReturns
properties to ‘true’ respectively.When these options are set, Channel s
created by the factory are wrapped in an PublisherCallbackChannel, which
is used to facilitate the callbacks. When such a channel is obtained,
the client can register a PublisherCallbackChannel.Listener with the
Channel. The PublisherCallbackChannel implementation contains logic to
route a confirm/return to the appropriate listener. These features are
explained further in the following sections. 

通过Spring
amqp文档可以看到,要使用这种机制需要将Template模版的设publisherConfirms
或publisherReturns
属性设置为true,此外ConnectionFactory要配置为CachingConnectionFactory。

    <bean id="connectionFactory"
        class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
        <property name="host" value="192.168.2.133" />
        <property name="port" value="5672" />
        <property name="username" value="sun" />
        <property name="password" value="123456" />
        <property name="publisherConfirms" value="true" />
        <property name="publisherReturns" value="true" />
    </bean>

发表评论

电子邮件地址不会被公开。 必填项已用*标注