# rocket_msgclient

#### 介绍
该组件实现了整合阿里云rocketmq服务,包含消息发送与消费，开箱即用。

#### 软件架构
软件架构说明


#### 安装教程

1.  该消息组件使用前提是开通阿里云rockcet服务
2.  在其控制台创建topic以及消费者分组


#### 使用说明

1.  在自己的项目中pom文件引入
        <dependency>
            <groupId>com.rocket.msgclient</groupId>
            <artifactId>rocket-msgclient</artifactId>
            <version>1.0.0-SNAPSHOT</version>
        </dependency>
2.  项目配置文件添加组件配置
        rocketMq:
        proxy: 内网地址
        consumer_group: 消费端服务名称
        isEnabledIsolation: true
 其中isEnabledIsolation做环境隔离，ture标识区分环境

3.消息发送
   注入：
    @Autowired
    private RocketProducer rocketProducer;
3.消息消费
    @RocketMqMessageListener(topic = MsgTopicEnum.ORDER)
    @Component
    public class qyOrderPaySucDelay implements MsgHandleInterface {
        @Override
        public void onMessage(MessageResult result) {
            log.info("监听到 qy_order_pay_suc_delay 消息==> " + JSON.toJSONString(result));
            MsgFilterTagEnum filterTagEnum = MsgFilterTagEnum.getMsgFilterTagEnum(result.getTag());
            switch (filterTagEnum){- 1. `这里是列表文本`
                case QY_ORDER_PAY_SUCCESS_AUTO_RELATION_SETTLE_PAYMENT_ITEM:
                    shopFnclSettlePaymentItemService.autoCreateShopFnclSettlePayment(result.getBody());
                    break;
                case QY_ORDER_PAY_AUTO_PAUSE_SETTLE_PAYMENT_ITEM:
                    shopFnclSettlePaymentItemService.autoPauseShopFnclSettlePayment(result.getBody());
                    break;
            }

        }
    }

#### 参与贡献

1.  Fork 本仓库
2.  新建 Feat_xxx 分支
3.  提交代码
4.  新建 Pull Request