记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 59bc9b06 authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

mq相关提交

parent 95b3a658
Hide whitespace changes
Inline Side-by-side
Showing with 90 additions and 9 deletions
liquidnet-bus-common/liquidnet-common-mq/src/main/java/com/liquidnet/common/mq/constant/MQConst.java
View file @ 59bc9b06
......@@ -9,12 +9,28 @@ public class MQConst {
public static final String QUEUES_SQL_MAIN = "queue.sql.main";
//缺票登记
public static final String EXCHANGES_LIQUIDNET_SQL_PERFORMANCE_LACK = "liquidnet.sql.performance.lack";
public static final String ROUTING_KEY_SQL_PERFORMANCE_LACK = "performance.lack";
public static final String QUEUES_SQL_PERFORMANCE_LACK = "queue.sql.performance.lack";
//创建订单
public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE = "liquidnet.sql.order.create";
public static final String ROUTING_KEY_SQL_ORDER_CREATE = "order.create";
public static final String QUEUES_SQL_ORDER_CREATE = "queue.sql.order.create";
public static final String EXCHANGES_LIQUIDNET_SQL_PERFORMANCE_LACK = "liquidnet.sql.performance.lack";
public static final String ROUTING_KEY_SQL_PERFORMANCE_LACK = "performance.lack";
public static final String QUEUES_SQL_PERFORMANCE_LACK = "queue.sql.performance.lack";
//订单再次支付
public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_AGAIN = "liquidnet.sql.order.again";
public static final String ROUTING_KEY_SQL_ORDER_AGAIN = "order.again";
public static final String QUEUES_SQL_ORDER_AGAIN = "queue.sql.order.again";
//订单关闭
public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE = "liquidnet.sql.order.close";
public static final String ROUTING_KEY_SQL_ORDER_CLOSE = "order.close";
public static final String QUEUES_SQL_ORDER_CLOSE = "queue.sql.order.close";
//订单支付
public static final String EXCHANGES_LIQUIDNET_SQL_ORDER_PAY = "liquidnet.sql.order.pay";
public static final String ROUTING_KEY_SQL_ORDER_PAY = "order.pay";
public static final String QUEUES_SQL_ORDER_PAY = "queue.sql.order.pay";
}
liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/processor/ConsumerProcessor.java
View file @ 59bc9b06
......@@ -48,41 +48,106 @@ public class ConsumerProcessor {
}
}
// 订单创建
@RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_CREATE)
public void consumerOrderCreate(Message msg, Channel channel) {
log.info("DEMO MESSAGE_GETBODY ==> Preparing:{}", new String(msg.getBody()));
log.info("=== CONSUMER_ORDER_CREATE ===");
SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
log.debug("consumer sql_order_create ==> Preparing:{}", JsonUtils.toJson(sqlMessage.getSqls()));
log.debug("consumer sql_order_create ==> Parameters:{}", JsonUtils.toJson(sqlMessage.getArgs()));
try {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_CREATE result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
}
log.debug("batchSqls result of execution:{}", rstBatchSqls);
} catch (Exception e) {
log.error("error:sqlMessage:{}", JsonUtils.toJson(sqlMessage), e);
}
}
@RabbitListener(queues = MQConst.QUEUES_SQL_PERFORMANCE_LACK)
public void consumerPerformanceLAck(Message msg, Channel channel) {
log.info("DEMO MESSAGE_GETBODY ==> Preparing:{}", new String(msg.getBody()));
//订单再次支付
@RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_AGAIN)
public void consumerOrderPayAgain(Message msg, Channel channel) {
log.info("=== CONSUMER_ORDER_PAY_AGAIN ===");
SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
log.debug("consumer sql_order_create ==> Preparing:{}", JsonUtils.toJson(sqlMessage.getSqls()));
log.debug("consumer sql_order_create ==> Parameters:{}", JsonUtils.toJson(sqlMessage.getArgs()));
try {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_PAY_AGAIN result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
}
} catch (Exception e) {
log.error("error:sqlMessage:{}", JsonUtils.toJson(sqlMessage), e);
}
}
//订单关闭
@RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_CLOSE)
public void consumerOrderClose(Message msg, Channel channel) {
log.info("=== CONSUMER_ORDER_CLOSE ===");
SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
log.debug("consumer sql_order_create ==> Preparing:{}", JsonUtils.toJson(sqlMessage.getSqls()));
log.debug("consumer sql_order_create ==> Parameters:{}", JsonUtils.toJson(sqlMessage.getArgs()));
try {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_CLOSE result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
}
} catch (Exception e) {
log.error("error:sqlMessage:{}", JsonUtils.toJson(sqlMessage), e);
}
}
//订单支付
@RabbitListener(queues = MQConst.QUEUES_SQL_ORDER_PAY)
public void consumerOrderPay(Message msg, Channel channel) {
log.info("=== CONSUMER_ORDER_PAY ===");
SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
log.debug("consumer sql_order_create ==> Preparing:{}", JsonUtils.toJson(sqlMessage.getSqls()));
log.debug("consumer sql_order_create ==> Parameters:{}", JsonUtils.toJson(sqlMessage.getArgs()));
try {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_ORDER_PAY result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
}
} catch (Exception e) {
log.error("error:sqlMessage:{}", JsonUtils.toJson(sqlMessage), e);
}
}
//缺票登记
@RabbitListener(queues = MQConst.QUEUES_SQL_PERFORMANCE_LACK)
public void consumerPerformanceLack(Message msg, Channel channel) {
log.info("=== CONSUMER_PERFORMANCE_LACK ===");
SqlMapping.SqlMessage sqlMessage = JsonUtils.fromJson(new String(msg.getBody()), SqlMapping.SqlMessage.class);
log.debug("consumer sql_performance_lack ==> Preparing:{}", JsonUtils.toJson(sqlMessage.getSqls()));
log.debug("consumer sql_performance_lack ==> Parameters:{}", JsonUtils.toJson(sqlMessage.getArgs()));
try {
Boolean rstBatchSqls = baseDao.batchSqls(sqlMessage.getSqls(), sqlMessage.getArgs());
log.debug("CONSUMER_PERFORMANCE_LACK result of execution:{}", rstBatchSqls);
if (rstBatchSqls) {
channel.basicAck(msg.getMessageProperties().getDeliveryTag(), true);
} else {
channel.basicReject(msg.getMessageProperties().getDeliveryTag(), true);
}
log.debug("batchSqls result of execution:{}", rstBatchSqls);
} catch (Exception e) {
log.error("error:sqlMessage:{}", JsonUtils.toJson(sqlMessage), e);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment