废料回收网站建设电脑 手机 微信网站开发

当前位置： 首页 > news >正文

废料回收网站建设,电脑 手机 微信网站开发,重庆推广网站的方法,花生壳可以做网站吗什么是死信队列#xff1f; 在消息队列中#xff0c;执行异步任务时#xff0c;通常是将消息生产者发布的消息存储在队列中#xff0c;由消费者从队列中获取并处理这些消息。但是#xff0c;在某些情况下#xff0c;消息可能无法正常地被处理和消耗#xff0c;例如 在消息队列中执行异步任务时通常是将消息生产者发布的消息存储在队列中由消费者从队列中获取并处理这些消息。但是在某些情况下消息可能无法正常地被处理和消耗例如格式错误、设备故障等这些未成功处理的消息就被称为“死信”。 为了避免这些未成功处理的消息导致程序异常或对系统造成影响我们需要使用死信队列Dead Letter Queue。当我们设置死信队列后所有无法成功处理的消息将被捕获并重定向到指定的死信交换机中。消费者可以从该交换机中读取并处理这些“死信”。 死信队列的优点 使用死信队列有以下优点 提高系统可靠性避免因未处理的死信而导致程序异常提高系统的可靠性。实现延迟消息可以通过设置TTL时间将超时未消费的消息转移到死信队列中实现延迟消息的功能。防止滥用当某些生产者恶意发送低质量的消息或进行滥用时可以通过丢弃或重定向死信消息来防止滥用和恶意攻击。 死信队列的应用场景 死信队列在以下场景下是非常有用的 消息格式错误当消息格式错误时可能会导致消费者无法正确地解析或处理该消息这个问题通常与生产者的代码有关。为了避免消息失效并提高系统可靠性我们可以使用死信队列。消费者故障另一个常见的场景是消息处理者无法正确地处理或响应到推入到队列中的消息例如消费者创建了一个协程并在逻辑执行完成后未正确地关闭该协程。由于该协程始终处于打开状态它将一直阻止该消费者对其他消息进行正确消费。为了避免这种消息挂起并影响其他消息的正常处理可以将其加入死信中心。 死信队列的实现方式 下面通过RabbitMQ和Spring Boot演示如何实现死信队列。 RabbitMQ实现 创建交换机和队列 import pikadef main():credentials pika.PlainCredentials(guest, guest)parameters pika.ConnectionParameters(localhost, 5672, /, credentials)# 创建死信交换机dlx_exchnage_name my-dlx-exchangewith pika.BlockingConnection(parameters) as connection:channel connection.channel()channel.exchange_declare(exchangedlx_exchnage_name, exchange_typefanout, durableTrue)# 创建死信队列和交换机dead_letter_queue_name dead-letter-queuewith pika.BlockingConnection(parameters) as connection:channel connection.channel()channel.queue_declare(queuedead_letter_queue_name, durableTrue)channel.queue_bind(queuedead_letter_queue_name, exchangedlx_exchnage_name)# 创建消息队列并将其绑定到死信队列上 queue_name job-queuearguments {x-dead-letter-exchange: dlx_exchnage_name} with pika.BlockingConnection(parameters) as connection:channel connection.channel()channel.queue_declare(queuequeue_name, durableTrue,argumentsarguments)channel.queue_bind(exchange, queuequeue_name, routing_keyqueue_name)print(Queue is created)if name main:main()以上代码创建了两个队列一个是my-dlx-exchange一个是dead-letter-queue。同时创建另外一个名为job-queue的队列它绑定了dead-letter-exchange这个交换机。 在发送消息时需要提供一些属性来指定该队列应采取哪些步骤来防止该类丢失的消息。 这里我们可以使用x-dead-letter-exchange和x-message-ttl两个特殊属性告诉RabbitMQ如果消息在某段时间内无法正确处理则将其放入死信队列中。 发送和接收消息 import pikadef send_message():credentials pika.PlainCredentials(guest, guest)parameters pika.ConnectionParameters(localhost, 5672, /, credentials)connection pika.BlockingConnection(parameters)channel connection.channel()# 发送一个消息5秒后过期并且未被消费端确认queue_name job-queueproperties pika.BasicProperties(delivery_mode2,expiration5000)channel.basic_publish(exchange, routing_keyqueue_name, bodyHello World!, propertiesproperties)channel.close()connection.close()def receive_message():credentials pika.PlainCredentials(guest, guest)parameters pika.ConnectionParameters(localhost, 5672, /, credentials)connection pika.BlockingConnection(parameters)channel connection.channel()dlx_exchnage_name my-dlx-exchangedef callback(ch, method, properties, body):print(Receivedmessage: %r % body)ch.basic_ack(delivery_tagmethod.delivery_tag)# 消费来自job-queue的消息queue_name job-queuechannel.basic_consume(queue_name, callback)channel.start_consuming()if name main:send_message()receive_message()以上代码是一个简单的生产者和消费者。send_message()函数发送一个消息并且未被消费端确认receive_message()函数从job-queue中接收消息。 Spring Boot实现 在Spring Boot中我们可以使用RabbitMQ来实现死信队列。 添加依赖 dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId /dependency配置文件 spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest创建死信交换机、队列和绑定 Configuration public class RabbitConfig {// 死信交换机public static final String DLX_EXCHANGE_NAME my-dlx-exchange;// 死信队列public static final String DEAD_LETTER_QUEUE_NAME dead-letter-queue;// 业务处理队列public static final String PROCESS_QUEUE_NAME process-queue;Beanpublic TopicExchange dlxExchange() {return new TopicExchange(DLX_EXCHANGE_NAME);}Beanpublic Queue deadLetterQueue() {return QueueBuilder.durable(DEAD_LETTER_QUEUE_NAME).withArgument(x-dead-letter-exchange, DLX_EXCHANGE_NAME).build();}Beanpublic Queue processQueue() {return QueueBuilder.durable(PROCESS_QUEUE_NAME).withArgument(x-message-ttl, 5000).withArgument(x-dead-letter-exchange, DLX_EXCHANGE_NAME).build();}Beanpublic Binding dlxBinding(Queue deadLetterQueue, TopicExchange dlxExchange) {return BindingBuilder.bind(deadLetterQueue).to(dlxExchange).with(#);}}以上代码创建了my-dlx-exchange死信交换机和dead-letter-queue死信队列。同时创建一个process-queue业务处理队列该队列设置了消息的生存时间为5s并在该时间内未被消费者消费则将该消息转移到死信队列中。 发送和接收消息 Component public class MessageSender {Autowiredprivate RabbitTemplate rabbitTemplate;public void send(String message) {rabbitTemplate.convertAndSend(, RabbitConfig.PROCESS_QUEUE_NAME, message);}}Component public class MessageReceiver {RabbitListener(queues process-queue)public void receive(String message) throws Exception {System.out.println(Received message: message);Thread.sleep(10000);}}以上代码是一个简单的生产者和消费者。生产者使用RabbitTemplate来发送消息到process-queue队列中消费者通过使用注解RabbitListener监听process-queue队列的消息并进行处理。 结语 通过本篇文章我们详细介绍了什么是死信队列、死信队列的优点、应用场景以及如何实现死信队列。通过RabbitMQ和Spring Boot的实现方式不难看出死信队列在项目中的重要性和实际价值。在工程实践中我们可以根据具体业务需求结合技术选型灵活运用死信队列来提高系统的可靠性和稳定性。