czg_team
/
cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mq队列 关闭监听端 

队列存活时间
This commit is contained in:
wangw 2025-02-25 17:55:12 +08:00
parent 6b4d9d6758
commit 978f7f1bdb
2 changed files with 46 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
cash-api/order-server/src/main/java/com/czg/mq/RabbitmqReceiver.java
View File

@ -1,44 +1,44 @@
package com.czg.mq; //package com.czg.mq;
//
import com.czg.config.RabbitConstants; //import com.czg.config.RabbitConstants;
import com.rabbitmq.client.Channel; //import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j; //import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message; //import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.*; //import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component; //import org.springframework.stereotype.Component;
//
import java.io.IOException; //import java.io.IOException;
//
/** ///**
* @author GYJoker // * @author GYJoker
*/ // */
@Slf4j //@Slf4j
@Component //@Component
public class RabbitmqReceiver { //public class RabbitmqReceiver {
//
/** // /**
* 消费者监听，绑定队列 // * 消费者监听，绑定队列
* Queue RabbitConfig类的 orderPrintQueue // * Queue RabbitConfig类的 orderPrintQueue
*/ // */
@RabbitListener( // @RabbitListener(
bindings = @QueueBinding(value = @Queue(value = "#{orderPrintQueue.name}", durable = "true", // bindings = @QueueBinding(value = @Queue(value = "#{orderPrintQueue.name}", durable = "true",
arguments = {@Argument(name = "x-message-ttl", value = "180000", type = "java.lang.Long")}), // arguments = {@Argument(name = "x-message-ttl", value = "180000", type = "java.lang.Long")}),
exchange = @Exchange(value = RabbitConstants.Exchange.CASH_EXCHANGE)), // exchange = @Exchange(value = RabbitConstants.Exchange.CASH_EXCHANGE)),
concurrency = "10" // concurrency = "10"
) // )
@RabbitHandler // @RabbitHandler
public void receiveOrderPrintQueue(Channel channel, String orderId, Message message) throws IOException { // public void receiveOrderPrintQueue(Channel channel, String orderId, Message message) throws IOException {
try { // try {
log.info("订单监听 消息体：{},消息内容：{}", message, orderId); // log.info("订单监听 消息体：{},消息内容：{}", message, orderId);
// 手动确认消息，multiple 参数表示是否批量确认 // // 手动确认消息，multiple 参数表示是否批量确认
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); // channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
} catch (Exception e) { // } catch (Exception e) {
log.error(e.getMessage(), e); // log.error(e.getMessage(), e);
// 判断是否需要重新入队 // // 判断是否需要重新入队
boolean requeue = false; // boolean requeue = false;
// 拒绝消息，requeue 为 true 表示将消息重新放回队列 // // 拒绝消息，requeue 为 true 表示将消息重新放回队列
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, requeue); // channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, requeue);
} // }
//
} // }
} //}

4
cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConfig.java
View File

@ -25,8 +25,8 @@ public class RabbitConfig {
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
// 设置消息过期时间为 180000 毫秒（即 180 秒） // 设置消息过期时间为 180000 毫秒（即 180 秒）
args.put("x-message-ttl", 180000); args.put("x-message-ttl", 180000);
// return new Queue(activeProfile + "-" + RabbitConstants.Queue.ORDER_PRINT_QUEUE, true, false, false, args); return new Queue(activeProfile + "-" + RabbitConstants.Queue.ORDER_PRINT_QUEUE, true, false, false, args);
return new Queue(activeProfile + "-" + RabbitConstants.Queue.ORDER_PRINT_QUEUE, true, false, false, null); // return new Queue(activeProfile + "-" + RabbitConstants.Queue.ORDER_PRINT_QUEUE, true, false, false, null);
} }
@Bean @Bean