feat(mq): 添加 RocketMQ相关的常量接口
- 新增 GroupConstants 接口，定义了多个消费者组常量- 新增 TopicNameConstants 接口，定义了多个主题名常量 - 新增 TopicTagConstants 接口，定义了多个主题标签常量
This commit is contained in:
HuangLei
parent
a81da88bc4
commit
19889c1f89
|
|
@ -0,0 +1,26 @@
|
|||
package cn.iocoder.yudao.framework.mq.rocketmq.core;
|
||||
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
||||
import org.apache.rocketmq.spring.core.RocketMQListener;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* -
|
||||
*
|
||||
* @author HuangLei
|
||||
* @since 2025-06-18
|
||||
*/
|
||||
@Component
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor
|
||||
@RocketMQMessageListener(
|
||||
topic = TopicNameConstants.PAY_REFUND_ORDER,
|
||||
consumerGroup = GroupConstants.PAY_ORDER_REFUND_GROUP)
|
||||
public class Consumer implements RocketMQListener<String> {
|
||||
@Override
|
||||
public void onMessage(String message) {
|
||||
log.info("【消费】- {}", message);
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,28 @@
|
|||
package cn.iocoder.yudao.framework.mq.rocketmq.core;
|
||||
|
||||
/**
|
||||
* @author bixuan
|
||||
* @version 1.0
|
||||
* @description: TODO
|
||||
* @date 2025/5/4 10:22
|
||||
*/
|
||||
public interface GroupConstants {
|
||||
String BIND_CARD_PACKAGE_GROUP = "bind-card-package-group";
|
||||
String UNBIND_CARD_PACKAGE_GROUP = "unbind-card-package-group";
|
||||
String CHANGE_CARD_PACKAGE_GROUP = "change-card-package-group";
|
||||
String SYNC_BATCH_GROUP = "sync-batch-group";
|
||||
String SYNC_CARD_PACKAGE_GROUP = "sync-card-package-group";
|
||||
String SYNC_CARD_PACKAGE_TRAFFIC_GROUP = "sync-card-package-traffic-group";
|
||||
String SYNC_CARD_POOL_TRAFFIC_GROUP = "sync-card-pool-traffic-group";
|
||||
String SYNC_POOL_TRAFFIC_GROUP = "sync-pool-traffic-group";
|
||||
String SYNC_STATISTICS_CARD_POOL_TRAFFIC_GROUP = "sync-statistics-card-pool-traffic-group";
|
||||
String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_GROUP = "sync-statistics-card-package-traffic-group";
|
||||
String PAY_ORDER_DELAY_CLOSE_GROUP = "pay-order-delay-close-group";
|
||||
String PAY_ORDER_GENERATE_BILL_GROUP = "pay-order-generate-bill-group";
|
||||
String REFUND_ORDER_WRITE_OFF_BILL_GROUP = "refund-order-write-off-bill-group";
|
||||
String SYNC_PACKAGE_TRAFFIC_GROUP = "sync-package-traffic-group";
|
||||
String PAY_ORDER_REFUND_GROUP = "pay-order-refund-group";
|
||||
String EIOT_CLUB_NOTIFY_SUBPKGLIST_GROUP = "eiot-club-notify-subPkgList-group";
|
||||
String EIOT_CLUB_NOTIFY_REFUND_GROUP = "eiot-club-notify-refund-group";
|
||||
|
||||
}
|
||||
|
|
@ -0,0 +1,26 @@
|
|||
package cn.iocoder.yudao.framework.mq.rocketmq.core;
|
||||
|
||||
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
|
||||
import jakarta.annotation.PostConstruct;
|
||||
import lombok.AllArgsConstructor;
|
||||
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* @author HuangLei
|
||||
* @since 2025-06-18
|
||||
*/
|
||||
@Component
|
||||
@AllArgsConstructor
|
||||
public class Product {
|
||||
|
||||
|
||||
private final RocketMQTemplate rocketMQTemplate;
|
||||
|
||||
|
||||
@PostConstruct
|
||||
public void init(){
|
||||
System.out.println("开始发送消息");
|
||||
rocketMQTemplate.convertAndSend("pay-refund-order", JsonUtils.toJsonString("hello world"));
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,41 @@
|
|||
package cn.iocoder.yudao.framework.mq.rocketmq.core;
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* @program: b2b2c-admin
|
||||
* @ClassName TopicNameConstants
|
||||
* @description:
|
||||
* @author: HuangLei
|
||||
* @create: 2025/4/28/周一 9:55
|
||||
* @Version 1.0
|
||||
**/
|
||||
public interface TopicNameConstants {
|
||||
|
||||
|
||||
/**
|
||||
* 运营商主题,相同操作消息可以使用tag区分
|
||||
*/
|
||||
String IOT_OPERATOR = "iot-operator";
|
||||
|
||||
/**
|
||||
* 事务主题,相同操作消息可以使用tag区分
|
||||
*/
|
||||
String IOT_TRANSACTION = "iot-transaction";
|
||||
|
||||
/**
|
||||
* 延时主题,相同操作消息可以使用tag区分
|
||||
*/
|
||||
String IOT_DELAY = "iot-delay";
|
||||
|
||||
/**
|
||||
* 退款主题,相同操作消息可以使用tag区分
|
||||
*/
|
||||
String PAY_REFUND_ORDER = "pay-refund-order";
|
||||
|
||||
|
||||
/**
|
||||
* eiotclub异步通知主题
|
||||
*/
|
||||
String EIOT_CLUB_NOTIFY_TOPIC = "eiot-club-notify";
|
||||
}
|
||||
|
|
@ -0,0 +1,27 @@
|
|||
package cn.iocoder.yudao.framework.mq.rocketmq.core;
|
||||
|
||||
/**
|
||||
* @description: TODO
|
||||
* @author bixuan
|
||||
* @date 2025/5/4 10:22
|
||||
* @version 1.0
|
||||
*/
|
||||
public interface TopicTagConstants {
|
||||
String BIND_CARD_PACKAGE_TAG = "bind_card_package";
|
||||
String UNBIND_CARD_PACKAGE_TAG = "unbind_card_package";
|
||||
String CHANGE_CARD_PACKAGE_TAG = "change_card_package";
|
||||
String SYNC_BATCH_TAG = "sync_batch";
|
||||
String SYNC_CARD_PACKAGE_TAG = "sync_card_package";
|
||||
String SYNC_CARD_PACKAGE_TRAFFIC_TAG = "sync_card_package_traffic";
|
||||
String SYNC_CARD_POOL_TRAFFIC_TAG = "sync_card_pool_traffic";
|
||||
String SYNC_POOL_TRAFFIC_TAG = "sync_pool_traffic";
|
||||
String SYNC_STATISTICS_CARD_POOL_TRAFFIC_TAG = "sync_statistics_card_pool_traffic";
|
||||
String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_TAG = "sync_statistics_card_package_traffic";
|
||||
|
||||
String PAY_ORDER_SUCCESS_BILL_TAG = "pay_order_success_bill";
|
||||
String REFUND_SUCCESS_BILL_TAG = "refund_success_bill";
|
||||
String DELAY_PAY_ORDER_DELAY_CLOSE = "delay_pay_order_close";
|
||||
|
||||
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue